-
消息记录表中消息的状态:0消息发送中,1发送成功,2发送失败
把业务数据、消息记录分别插入相应的数据表
发送消息
监听消息确认(收到确认,消息状态从0改为1)
定时任务:定时获取消息状态为0的消息,重新发送
重新发送三次后如果还是发送不了,状态改为2,人工发送
查看全部 -
保障消息100%投递成功
查看全部 -
AMQP协议模型
查看全部 -
RoutingKey模糊匹配:
order.*匹配一切以"order."开头的、后面不带点的路由名称(order.123,order.abc等)
order.#匹配一个或多个词(order.123.123,order.aaa.bbb等)
查看全部 -
实体对象一般都要implements Serializable
查看全部 -
rabbitMq安装
查看全部 -
RabbitMQ消息是如何流转的: Message与Exchange之间实际上有virtual host这一环节
查看全部 -
AMQP协议模型
查看全部 -
RabbitMQ的整体架构
查看全部 -
保存学习查看全部
-
MQ可靠性投递查看全部
-
Routing key规则:1、order.*(仅仅匹配一个单词,如:order.adc 、order.wer。不能匹配:order.adf.sdf)
2、order.#(可以匹配多个单词)
查看全部 -
AMQP核心概念:1、Server:又称Broker,接受客户端的连接,实现AMQP实体服务
2、Connection:连接,应用程序与Broker的网络连接
3、Channel:网络信道,几乎所有的操作都在Channel中进行,Channel是进行消息读写的通道。客户端可建立多个Channel,每个Channel代表一个回话任务。
4、消息,服务器和应用程序之间传送的数据,RabbitMQ的消息分为Properties和Body组成。Properties可以对消息进行修饰,比如消息的优先 级、延迟等高级特性;Body则是消息体内容。
5、Virtual host:虚拟主机,用于进行逻辑隔离,最上层的消息路由。一个Virtual Host里面可以有若干个Exchange和Queue,同一个Virtual Host里面不能有相同名称的Exchange或Queue。
6、Exchange:交换机,接收消息,根据路由建转发消息到绑定的队列。
7、Binding:Exchange和Queue之间的虚拟连接,bingding中可以包含routing key。
8、Routing key;一个路由规则,虚拟机可以用它来确定如何路由一个特定消息。
9、Queue;也称Message Queue,消息队列,保存消息并将它们转发给消费者。
查看全部 -
RabbitMQ:1、 启动命令:rabbitmq-server start &
内存方式存储:rabbitmq-server start --ram
2、是否启动:lsof -i:5672
3、管理插件:rabbitmq-plugins enable rabbitmq_management
插件列表:rabbitmq-plugins list
4、访问地址:http://192.168.11.76:15672/
查看全部 -
查看未正常关闭掉RabbitMQ的相关进程:ps -ef | grep rabbit
查看全部
举报