1、什么是RabbitMQ MQ（Message Queue）：消息队列，是服务端设计的一个可以存储大量消息的队列，并提供客户端操作队列的方法：生产队列（向队列中添加数据）、消费队列（从队列中取数据）。RabbitMQ就是基于消息队列的一个典型应用。RabbitMQ除了普通的生产消费功能，还有一些高 ...
分类：
编程语言 时间：
2018-09-09 12:02:42
阅读次数：
176
1、什么是RabbitMQ工作队列 我们在应用程序使用消息系统时，一般情况下生产者往队列里插入数据时速度是比较快的，但是消费者消费数据往往涉及到一些业务逻辑处理导致速度跟不上生产者生产数据。因此如果一个生产者对应一个消费者的话，很容易导致很多消息堆积在队列里。这时，就得使用工作队列了。一个队列有多个 ...
分类：
其他好文 时间：
2018-09-09 11:47:39
阅读次数：
187
一、简单概念 消息：指在应用之间传递的数据。 消息队列：指应用传递消息的一种通信方式，数据过渡。 消费者订阅某个队列，然后生产者产生消息到队列当中，最后将消息发送到监听的消费者。 二、安装过程 环境：centos 7.x 1、erlang安装 rabbitmq是由erlang语言开发的，并且依赖于它 ...
分类：
其他好文 时间：
2018-09-09 00:46:49
阅读次数：
157
属性名 默认值 描述 message.send.max.retries 3 设置当生产者向代理发信息时，若代理由于各种原因导致接 受失败，生产者在丢弃该消息前进行重试的次数。 retry.backoff.ms 100 在生产者每次重试之前，生产者会更新主题的 MetaData 信息， 以此来检测新的 ...
分类：
其他好文 时间：
2018-09-08 18:56:35
阅读次数：
189
1.消息发送 1.异步发送 消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称 ...
分类：
其他好文 时间：
2018-09-08 16:52:10
阅读次数：
167
1，首先引入配置文件org.springframework.amqp，如下： 2，准备工作：安装好rabbitmq,并在项目中增加配置文件 rabbit.properties 内容如下： 3，配置spring-rabbitmq.xml，内容如下： 4，生产者（发送端）代码： 5，消费端代码：Test ...
分类：
编程语言 时间：
2018-09-08 12:24:20
阅读次数：
1890
参考来自Kafka入门实战pdf 1.kafka的基本概念 1.主题： Kafka 将一组消息抽象归纳为一个主题（Topic），也就是说，一个主题就是对消息的一个 分类。生产者将消息发送到特定主题，消费者订阅主题或主题的某些分区进行消费。 2.消息： 消息是 Kafka 通信的基本单位，由一个固定长 ...
分类：
其他好文 时间：
2018-09-07 16:00:46
阅读次数：
149
生产者消费者模式 在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题， 该模式通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度 生产者和消费者模式来源 在线程世界里, 生产者就是生产数据的线程，消费者就是消费数据的线程。 在多线程开发当中，如果生产者处理速度很快，而消费者处 ...
分类：
编程语言 时间：
2018-09-06 22:57:55
阅读次数：
216
关于Condition接口 在并发编程中，每个Java对象都存在一组监视器方法，如wait()、notify()以及notifyAll()方法，通过这些方法，我们可以实现线程间通信与协作（也称为等待唤醒机制），如生产者-消费者模式，而且这些方法必须配合着synchronized关键字使用，关于这点， ...
分类：
其他好文 时间：
2018-09-05 17:54:04
阅读次数：
173
1 在resources目录下创建config目录，新建文件rocketmq.properties文件 2 新建properties文件读取类 3.加载properties文件 4 创建生产者 5.创建监听对象 6.监听消息进行消费 访问/sendMessage的url生产消息，控制台打印如下： ...
分类：
其他好文 时间：
2018-09-04 23:29:59
阅读次数：
308
