使用RabbitMQ进行消息发布和订阅，生产者将消息发送给转发器（exchange），转发器根据路由键匹配已绑定的消息队列并转发消息，主题模式支持路由键的通配。 生产者代码： 消费者代码： ...
分类：
编程语言 时间：
2018-09-14 16:18:23
阅读次数：
503
本片文章简单介绍Pulsar的Producer，包含以下内容：Producer的设计、消息发送的实现 ...
分类：
其他好文 时间：
2018-09-10 11:16:57
阅读次数：
208
一、简单概念 消息：指在应用之间传递的数据。 消息队列：指应用传递消息的一种通信方式，数据过渡。 消费者订阅某个队列，然后生产者产生消息到队列当中，最后将消息发送到监听的消费者。 二、安装过程 环境：centos 7.x 1、erlang安装 rabbitmq是由erlang语言开发的，并且依赖于它 ...
分类：
其他好文 时间：
2018-09-09 00:46:49
阅读次数：
157
1.消息发送 1.异步发送 消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称 ...
分类：
其他好文 时间：
2018-09-08 16:52:10
阅读次数：
167
参考来自Kafka入门实战pdf 1.kafka的基本概念 1.主题： Kafka 将一组消息抽象归纳为一个主题（Topic），也就是说，一个主题就是对消息的一个 分类。生产者将消息发送到特定主题，消费者订阅主题或主题的某些分区进行消费。 2.消息： 消息是 Kafka 通信的基本单位，由一个固定长 ...
分类：
其他好文 时间：
2018-09-07 16:00:46
阅读次数：
149
1、异步消息 当一个消息发送时候，消息会被交给消息代理，消息代理可以确保消息被发送到指定的目的地，同时解放发送者，使其能够继续进行其它业务。消息代理通常有ActiveMQ、RabbitMQ...，目的地通常有队列和主题，队列采用点对点的模型，主题采用发布订阅模型 点对点模型：消息队列可以有多个接受者 ...
分类：
编程语言 时间：
2018-09-02 23:41:18
阅读次数：
198
1.大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力 1.1异步通信 1.2解耦 1.3削峰 2.消息服务中两个重要概念： 消息代理（message broker）和目的地（destination）当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目的地。 消息队 ...
分类：
编程语言 时间：
2018-09-02 01:53:52
阅读次数：
304
在使用RabbitMQ的时候，我们可以通过消息持久化操作来解决因为服务器的异常奔溃导致的消息丢失，除此之外我们还会遇到一个问题，当消息的发布者在将消息发送出去之后，消息到底有没有正确到达broker代理服务器呢？ ...
分类：
其他好文 时间：
2018-09-01 17:34:56
阅读次数：
158
RocketMq 例子： 业务系统：提供者，如群发短信 RocketMq-Console-Ng：消息管理平台/消息队列 消息发送系统：消费者，执行发送 实现不同服务之间的异步通信 Dubbo 例子： 业务系统：提供者：如微信菜单生成接口 Dubbo：服务管理平台，可以查看到注册的提供者和消费者状态 ...
分类：
其他好文 时间：
2018-08-31 17:17:48
阅读次数：
515
所需要的jar 点对点消息发送端 package com.lm.acticemq; import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jm ...
分类：
其他好文 时间：
2018-08-28 15:24:50
阅读次数：
131
