-
消费不了,两个可能:
一是 rabbitmq配置错误,
二是 发送端和消费端的实体类的路径不一致;
查看全部 -
保障100%消息投递成功方案: sender 发送消息后,等待 broker 返回确认,超时未收到返回时通知 (用定时任务扫描状态未成功,且超过时间跨度的消息),则通知 sender 再次发送。
(这步解决了消息发送时丢失的问题,但是产生了重复发送的问题:消息确实发送成功了,但是丢失了返回确认通知,要解决这个问题需要在消费端服务进行幂等)
查看全部 -
演示配置: /etc/hostname (配置主机) /etc/hosts (搭建集群配置)
安装软件:erlang , socat (秘钥工具) , rabbitmq-server (按这个顺序依次安装)
修改控制台的用户名密码: /ebin/rabbit.app 文件编辑 loopback_users
改为 [guest] (去掉双尖括号和双引号,当做常量)
--------------------------------------------------------
rabbitmqctl 集群相关的各种操作
rabbitmq-server 启动服务
验证是否启动成功:# lsof -i:5672(端口)
--------------------------------------------------------
rabbitmq-plugins 安装插件(比如控制台)
#rabbitmq-plugins list ( 打印列表,找到 rabbitmq_management )
#rabbitmq-plugins enable rabbitmq_management (把它 enable )
在浏览器打开管控台(默认 15672)
查看全部 -
基于 AMQP 协议 ,用 erlang 语言编写,延迟度低
特点:集群模式丰富(主要采用镜像队列,保证消息不丢失),表达式配置,ha模式,
--------------------------------------------------------
AMQP 模型: publisher -> [ exchange -> queue] ( 这里就是 broker 或 server ) -> consumer
exchange 与 queue 之间建立了路由关系
查看全部 -
下载rabbitMQ的步骤
如果没删干净的话,会报错,在9:58的位置会有解决方法
查看全部 -
RabbitMQ是一个开源的消息代理和队列服务器,用来通过普通协议在完全不同的应用之间共享数据,RabbitMQ是使用Erlang语言来编写的,并且RabbitMQ是基于AMQP协议的。
开源、性能优秀,稳定性保障
与SpringAMQP完美的整合、API丰富
集群模式丰富,表达式配置,HA模式,镜像队列模型
保证数据不丢失的前提做到可靠性、可用性
AMQP全称:Advanced Message Queuing Protocal(高级消息队列)
查看全部 -
滴滴头条,美团都在用这个
可靠性投递
通过confirm模式
消息入库
ack
查看全部 -
2
查看全部 -
8
查看全部 -
ack手工签收
查看全部 -
手工签收必须依赖通道
分为消息体和消息头
手工签收有一个basicAck的响应
查看全部 -
1
查看全部 -
1
查看全部 -
路由规则
broker就是服务
查看全部 -
publisher-confirms 异步等待消息结果
查看全部
举报