一、介绍 官方教程:https://www.rabbitmq.com/tutorials/tutorial-one-python.html 消息队列(Message Queue)是一种应用程序对应用程序的通信方式,应用程序通过读写出入队列的消息来通信。 消息发送后可以立即返回,由消息系统来确保消息的 ...
分类:
其他好文 时间:
2019-03-24 20:06:11
阅读次数:
365
1.同步 synchronized 2.轮询 while volatile 3.wait/notify机制 syncrhoized加锁的线程的Object类的wait()/notify()/notifyAll() ReentrantLock类加锁的线程的Condition类的await()/sign ...
分类:
编程语言 时间:
2019-03-21 23:07:29
阅读次数:
258
先学习一下RabbitMQ中的六种队列,只学习前五种,具体的官方文档地址是:http://next.rabbitmq.com/getstarted.html 导入maven依赖: 一、简单队列 1、图示 P:消息的生产者 C:消息的消费者 红色:队列 生产者将消息发送到队列,消费者从队列中获取消息。 ...
分类:
其他好文 时间:
2019-03-17 01:24:38
阅读次数:
188
什么叫消息队列 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。 消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁 ...
分类:
其他好文 时间:
2019-03-13 21:31:35
阅读次数:
297
我们以一个订单流转流程来举例,例如订单子系统创建订单,需要将订单数据下发到其他子系统(与第三方系统对接)这个场景,我们通常会将两个系统进行解耦,不直接使用服务调用的方式进行交互。其业务实现步骤通常为: 1、A系统创建订单并入库。 2、发送消息到MQ。 3、MQ消费者消费消息,发送远程RPC服务调用, ...
分类:
其他好文 时间:
2019-03-12 18:33:59
阅读次数:
325
Rabbit的消息确认机制(事务+confirm)在rabbmitmq中我们可以通过持久化数据解决rabbitmq服务器异常的数据丢失问题问题:生产者将消息发送出去之后消息到底有没有到达rabbitmq服务器默认的情况是不知道的;事物两种方式:AMQP实现了事务机制Confirm模式事务机制txSe ...
分类:
其他好文 时间:
2019-02-24 10:30:04
阅读次数:
150
一、UDP广播 广播UDP与单播UDP的区别就是IP地址不同,广播使用广播地址255.255.255.255,将消息发送到在同一广播网络上的每个主机。值得强调的是:本地广播信息是不会被路由器转发。当然这是十分容易理解的,因为如果路由器转发了广播信息,那么势必会引起网络瘫痪。这也是为什么IP协议的设计 ...
分类:
其他好文 时间:
2019-02-22 12:41:37
阅读次数:
176
微信小程序websocket 微信小程序带有websocket可以提供使用,但是官方文档写的东西很少,而且小程序后台能力弱这一点也是十分的坑爹,这就导致了socket长连接一切后台就会出现断开的情况,并且难受的是.这个时候你重新调用链接函数也会链接不上,可能直接影响到你的业务逻辑 解决方法就是手动关 ...
分类:
微信 时间:
2019-02-22 10:43:59
阅读次数:
250
JMS 消息模型 JMS消息服务应用程序结构支持两种模型:点对点模型,发布者/订阅者模型。 (1)点对点模型(Queue) 一个生产者向一个特定的队列发布消息,一个消费者从这个队列中依次读取消息。 模型特点:只有一个消费者获得消息。 (2)发布者/订阅者模型(Topic) 0个或多个订阅者可以接受特 ...
分类:
其他好文 时间:
2019-02-17 00:24:36
阅读次数:
204
将同一个队列的消息发送给多个消费者的模式就是“发布/订阅”, 这种模式的基础是将消息广播到所有的接收器上。 实际上,RabbitMQ中消息传递模型的核心思想是: 生产者不直接发送消息到队列。 实际的运行环境中,生产者是不知道消息会发送到哪个队列上, 她只会将消息发送到一个交换器, 交换器也像一个生产 ...
分类:
其他好文 时间:
2019-02-17 00:20:43
阅读次数:
289