1、rabbitmq理论1.1、什么叫消息队列 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。1.2、消息队列通信方式 消息队列(MessageQueue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到MQ中而不用管谁来取,
分类:
其他好文 时间:
2018-05-07 23:52:15
阅读次数:
2019
高可用究竟指的是什么?请参考: "关于高可用的系统" RocketMQ做了以下的事情来保证系统的高可用 多master部署,防止单点故障 消息冗余(主从结构),防止消息丢失 故障恢复(本篇暂不讨论) 那么问题来了: 怎么支持多broker的写? 怎么实现消息冗余? 下面分开说明这两个问题 多mast ...
分类:
其他好文 时间:
2018-05-05 15:27:28
阅读次数:
202
本文主要分享下Spring Boot和Spring Kafka如何配置整合,实现发送和接收来自Spring Kafka的消息。 先前我已经分享了Kafka的基本介绍与集群环境搭建方法。关于Kafka的介绍请阅读Apache Kafka简介与安装(一),关于Kafka安装请阅读Apache Kafka ...
分类:
编程语言 时间:
2018-05-02 16:00:55
阅读次数:
191
一、简介1、是一种跨进程的通信机制,用于上下游传递消息。MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。消息发送上游-》MQ-》消息发送下游。此情况使用MQ调用上游-》被调用下游。此情况不使用MQ。优点与不足:2、不足:1)系统更复杂,多了一个MQ组件。2)通信时间更长,消息传递路径增长,延时会增加。3)消息的可靠性
分类:
其他好文 时间:
2018-04-26 21:11:59
阅读次数:
184
最近给一个客户做了一个聊天,所以就用NodeJS做了一个 原理就是用户第一次进入后,记录它的ID和该用户的ws 等有人发数据的时候,就去查ID,然后找到ID对应的ws,进行消息发送 核心就是用数组做了一个类似python字典的东西 下面是一个简单的连接Demo 里面用到的websocket.js,可 ...
分类:
Web程序 时间:
2018-04-24 17:45:43
阅读次数:
241
一、写RedeliveryPolicy配置文件 二、引用RedeliveryPolicy的配置: ...
分类:
其他好文 时间:
2018-04-23 11:12:56
阅读次数:
303
一 .概述 在前面我们简单的使用的ativemq完成了一个小的例子,最主要的作用就是帮助我们了解一下mq. 在这里我们就需要了解一下jms的规范的主要内容. 二 .JMS是什么 JMS是java消息服务,是jee中的一个技术. jms仅仅只是给出了规范(接口),我们需要使用不同的中间件完成任务. 如 ...
分类:
其他好文 时间:
2018-04-20 22:00:24
阅读次数:
133
一、非持久的Topic消息示例 注意 此种方式消费者只能接收到 消费者启动之后,发送者发送的消息。 发送者 接收者 二、持久订阅例子程序 发送者 消费者,可以有多个消费者 1, 消费者需要在Connection上设置消费者id,来识别消费者 2,需要创建TopicSubscriber 来订阅 3,设 ...
分类:
其他好文 时间:
2018-04-20 13:25:21
阅读次数:
160
一、MQ消息发送 1、发送端MQ-client(消息生产者:Producer)将消息发送给MQ-server; 2、MQ-server将消息落地; 3、MQ-server回ACK给MQ-client(Producer); 4、MQ-server将消息发送给消息接受端MQ-client(消息消费者:C ...
分类:
其他好文 时间:
2018-04-05 23:12:53
阅读次数:
2601
什么叫消息队列 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。 消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁 ...
分类:
其他好文 时间:
2018-03-30 17:25:27
阅读次数:
189