一、需求场景 exactly once 消息重复一直是消息领域的一个痛点,而消息重复可能发生于下面这些场景 1.消息发送端发出消息,服务端落盘以后因为网络等种种原因发送端得到一个发送失败的响应,然后发送端重发消息导致消息重复。 2.消息消费端在消费过程中挂掉另一个消费端启动拿之前记录的位点开始消费, ...
分类:
其他好文 时间:
2018-12-15 21:09:05
阅读次数:
145
一、 RabbitMQ概述 1.1 基本概述 RabbitMQ是一种消息中间件,能够很好的处理来自客户端的异步消息发送及请求,将消息发送放入到服 务端的队列池中,而接收端可以根据RabbitMQ配置的转发机制接收和过滤服务端转发来的消息。RabbitMQ 可以根据指定的消息转发规则进行消息的转发、缓 ...
分类:
其他好文 时间:
2018-12-10 15:51:43
阅读次数:
219
下载安装Erlang和RabbitMQ Erlang和RabbitMQ:https://www.cnblogs.com/theRhyme/p/10069611.html 项目创建和依赖 推荐SpringCloud项目在线创建:https://start.spring.io/ 不用上面这个也行,下面有 ...
分类:
编程语言 时间:
2018-12-05 17:25:23
阅读次数:
204
1.mq解决的问题 + 系统异步处理 + 应用解耦 + 流量削峰 + 日志处理 + 消息通信 2.消息中间件的2中模型 2.1 Point to Point(P2P) / 点对点 / 类比:送快递 特点: + 一个消费生产者必须有一个消息消费者。一对一的关系 + 一个消息发送到queue中,如果mq ...
分类:
其他好文 时间:
2018-12-02 01:20:48
阅读次数:
189
rabbitmq--路由模式 想象之前的订阅发布模式: 一个生产者,多个消费者,每一个消费者都有自己的一个队列,生产者没有将消息直接发送到队列,而是发送到了交换机,每个队列绑定交换机,生产者发送的消息经过交换机,到达队列,实现一个消息被多个消费者获取的目的。 需要注意的是,如果将消息发送到一个没有队 ...
分类:
其他好文 时间:
2018-11-28 20:29:59
阅读次数:
180
概述 1.大多数应用中,可以通过消息服务中间件来提升系统异步能力和拓展解耦能力。 2.消息服务中的两个重要概念:消息代理(Message broker)和目的地(destination) 当消息发送者发送消息后,将由消息代理接管,消息代理保证消息传递到指定目的地。 3.消息队列主要有两种形式的目的地 ...
分类:
编程语言 时间:
2018-11-26 16:13:06
阅读次数:
278
通过测试号,可以使用微信平台的全面功能. 而微信官方文档中也具体地描述了各种对接端口的参数调用和规则:https://mp.weixin.qq.com/wiki 今天小试牛刀将用户关注微信平台的事件Event以及发送信息以及通过Java后台程序返回消息大概做了个初版: 首先对接微信平台 首先你得通过 ...
分类:
微信 时间:
2018-11-24 23:49:34
阅读次数:
323
从第一次了解到TCP的连接方式到现在有一年半了,但好像一直没有把三次握手的由来弄透彻,解释上总有一些瑕疵在,现在来说说昨晚的思考。 对于一个通信链路,由于种种原因发送方发送的消息未必能传达到接收方,所以一条消息发送出去了,但没人回,有两种情况:一是数据没有传送成功,二是传送成功但对方没有立即回应。当 ...
分类:
其他好文 时间:
2018-11-24 14:05:07
阅读次数:
182
activemq 与 spring boot 整合 1、添加依赖 2、配置文件 3、消息发送服务 4、发送消息 5、添加监听 ...
分类:
编程语言 时间:
2018-11-24 11:25:30
阅读次数:
179
好记性不如烂笔头,今天来分析一下Handler的源码实现 Handler机制是Android系统的基础,是多线程之间切换的基础。下面我们分析一下Handler的源码实现。 Handler消息机制有4个类合作完成,分别是 Handler : 获取消息,发送消息,以及处理消息的类 MessageQueu ...
分类:
移动开发 时间:
2018-11-23 23:26:37
阅读次数:
240