实际上，RabbitMQ的生产者并不会直接把消息发送给队列，甚至生产者都不知道消息是否会被发送给一个队列。对于生产者而言，它们只能把消息发送到Exchange，一个Exchange所完成的工作相当简单，一方面，它从生产者那里接收消息；另一方面它将消息存入队列中。一个Exchange需要准确的知道它要 ...
分类：
Web程序 时间：
2019-05-19 14:26:08
阅读次数：
148
只做下工作记录，比较重要的几个属性： concurrency：一个生产者可以同时由多少个消费者消费，这个一般根据你的机器性能来进行配置 prefetch：允许为每个consumer指定最大的unacked messages数目。要是对实时性要求很高的话，prefetch应该设置成1，concurre ...
分类：
其他好文 时间：
2019-05-19 13:43:21
阅读次数：
130
1.添加 maven 项目依赖 2.添加 spring-rabbitmq.xml 配置 3.在 applicationContext.xml 文件中引入 spring-rabbitmq.xml 4.Gson配置 5.生产者接口及接口调用 6.消费者接口 7.测试验证 1.添加 maven 项目依赖 ...
分类：
编程语言 时间：
2019-05-18 21:01:31
阅读次数：
123
1.Java 通过阻塞队列实现生产者消费者模式 阻塞队列 Blocking Queue 当队列空时，获取元素的线程会等待 当队列满时，存储元素的线程会等待 提供的方法： 插入元素： add(e)：抛出异常 offer(e)：返回特殊值 put(e)：一直阻塞 offer(e,time,unit)：超 ...
分类：
其他好文 时间：
2019-05-17 12:07:13
阅读次数：
144
复习 学习内容 见代码区 代码区 1.子进程中不能有input操作 2.进程同步控制——信号量 （多个锁） 3.事件——一个信号控制多个进程同时执行或阻塞 红绿灯 4.队列 5.消费者，生产者模型——joinablequeue ...
分类：
编程语言 时间：
2019-05-17 10:53:37
阅读次数：
153
延时队列顾名思义，即放置在该队列里面的消息是不需要立即消费的，而是等待一段时间之后取出消费。那么，为什么需要延迟消费呢？我们来看以下的场景 订单业务： 在电商/点餐中，都有下单后 30 分钟内没有付款，就自动取消订单。短信通知： 下单成功后 60s 之后给用户发送短信通知。失败重试： 业务操作失败后 ...
分类：
编程语言 时间：
2019-05-16 19:09:04
阅读次数：
185
概览 - kafka解决的问题- 主题 - 分区 - 消息- 生产者- broker - broker集群- 消费者 - 消费者组群 - 生产者分区和消费者群组- 消息可靠性- 消息系统 - 队列和广播 - 消息保序- 存储系统- 流处理- 整合- 应用场景- api分类kafka解决的问题 生产者 ...
分类：
其他好文 时间：
2019-05-16 15:16:21
阅读次数：
152
一、简单认识 Celery是由Python开发、简单、灵活、可靠的分布式任务队列，其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任务。Celery侧重于实时操作，但对调度支持也很好，其每天可以处理数以百万计的任务。 它的特点有： 简单：熟悉了它的流程后，配置使用简单； 高可用：任 ...
分类：
其他好文 时间：
2019-05-15 11:15:06
阅读次数：
118
适用场景 阻塞队列主要用在生产者/消费者的场景，下面这幅图展示了一个线程生产、一个线程消费的场景： 负责生产的线程不断的制造新对象并插入到阻塞队列中，直到达到这个队列的上限值。队列达到上限值之后生产线程将会被阻塞，直到消费的线程对这个队列进行消费。同理，负责消费的线程不断的从队列中消费对象，直到这个 ...
分类：
其他好文 时间：
2019-05-15 11:08:36
阅读次数：
96
