首页 > 其他分享 >消息队列 & RabbitMQ

消息队列 & RabbitMQ

时间:2023-08-24 11:11:42浏览次数:33  
标签:发送到 队列 RabbitMQ 交换机 消息 路由

消息队列 & RabbitMQ 使用总结

1.消息队列 定义:message queue 是消息传递过程中一种存储数据的结构。
2.特点:先进先出,可以设置优先级用于大客户优先发货,持久化,消息确认,延时队列用于订单30分钟未支付取消。
3.作用:应用解耦,肖峰填谷,异步提高响应速度
4.RabbitMQ:四种交换机
直接交换机:通过路由键匹配将消息发送到绑定的队列上;
扇形交换机:直接将消息发送到所有与该交换机绑定的队列上,无效路由键绑定,路由键可以为空;
主题交换机:通过匹配符(*,#)路由键将消息发送到匹配的队列上;
头交换机:不通过路由键转发消息,通过header 参数x-match匹配转发消息(any,all).

5.RabbitMQ消息不是100%发送成功,消息发送失败的补偿机制可以使用数据库,redis 记录来保证)

标签:发送到,队列,RabbitMQ,交换机,消息,路由
From: https://www.cnblogs.com/chenshaojun2008/p/17653672.html

相关文章

  • kafka发送超大消息
    kafka发送超大消息设置 最近开发一cdc框架,为了测试极端情况,需要kafka传递100万条数据过去,1个G左右,由于其他环节限制,不便进行拆包(注:测下来,大包走kafka不一定性能更好,甚至可能更低)。测试百万以上的变更数据时,报消息超过kafkabroker允许的最大值,因此需要修改如下参数,......
  • 服务端向客户端发送消息Server-Sent Events
    今天听说了服务端向客户端发消息的一种方式:Server-SentEventsSSE使用的是HTTP协议,本质上是服务端向客户端发送流式数据。HTTP不支持服务端向客户端发送请求,但是如果客户端向服务端发出请求后,服务端向客户端声明,接下来的数据是流信息,则连接不会关闭,服务端可以继续发送数据流。......
  • priority queue 优先队列
    priorityqueue优先队列1、特性每个元素都有一个优先级,元素按优先级的顺序从队列中删除,如果优先级相同,则遵循先进先出规则。插入和删除都比一般的队列慢,因为必须对元素重新调整顺序,以支持按优先级排序。2、适用情况需要一个带优先级的先进先出结构3、头文件#include<queue>4、复杂......
  • springboot~kafka中延时消息的实现
    应用场景用户下单5分钟后,给他发短信用户下单30分钟后,如果用户不付款就自动取消订单kafka无死信队列kafka本身没有这种延时队列的机制,像rabbitmq有自己的死信队列,当一些消息在一定时间不消费时会发到死信队列,由死信队列来处理它们,上面的两个需求如果是rabbitmq可以通过死信......
  • Leetcode 两个队列实现栈 swift
    queue1 是最后生成的栈queue2是临时队列,把新进来的先放进去,再把queue1里的数据从头到尾读进去,然后互换classMyStack{varqueue1:[Int]=[]varqueue2:[Int]=[]init(){}funcpush(_x:Int){queue2.append(x)whil......
  • 【RocketMQ】消息的存储总结
    当Broker收到生产者的消息发送请求时,会对请求进行处理,从请求中解析发送的消息数据,接下来以单个消息的接收为例,看一下消息的接收过程。数据校验封装消息首先Broker会创建一个MessageExtBrokerInner对象封装从请求中解析到的消息数据,它会将Topic信息、队列ID、消息内容、消息属性......
  • RocketMQ源码(四):RocketMQ生产者发送消息流程
    RocketMQ通过Producer发送消息,以同步方式发送普通消息为例,分析发送消息的整体流程。Producer的示例代码如下:1importorg.apache.rocketmq.client.producer.DefaultMQProducer;2importorg.apache.rocketmq.client.producer.SendResult;3importorg.apache.rocketmq.......
  • Avalonia 实现聊天消息渲染、图文混排(支持Windows、Linux、信创国产OS)
      在实现即时通讯软件或聊天软件时,渲染文字表情、图文混排是一项非常繁琐的工作,再加上还要支持GIF动图、引用消息、撤回消息、名片等不同样式的消息渲染时,就更加麻烦了。    好在我们可以使用ESFramework提供的IChatRender组件,使用它我们就能轻松实现类似于微信......
  • RabbitMQ的学习之快速入门
    快速入门:使用springboot整合springAmqp来创建队列和消息同时创建consumer接收发送的消息第一步:引入依赖,在父类中引入spring-boot-starter-amqp依赖第二步:在yml中建立连接 第三步:创建publisher测试类引入注解,利用 RabbitTemplate生成对象调用方法,这样publisher就创建......
  • 微信开发之一键撤回消息的技术实现
    撤回消息请求URL:http://域名地址/revokeMsg请求方式:POST请求头Headers:Content-Type:application/jsonAuthorization:login接口返回参数:参数名必选类型说明wId是string登录实例标识wcId否string接收方微信id/群idmsgId是long消息msgId(发送类接口返回的msgId)newMsgId是long消息newMsg......