一、模式介绍 路由模式，与发布-订阅模式一样，消息发送到exchange中，消费者把队列绑定到exchange上。 这种模式在exchange上添加添加了一个路由键（routing-key），生产者发布消息的时候添加路由键（routing-key），消费者绑定队列到交换机时添加键值（routing- ...
分类：
编程语言 时间：
2019-01-13 02:00:08
阅读次数：
232
上一篇文章介绍了：创建县城的两种方式、Event对象判断线程是否启动、利用信号量控制线程并发。 博客链接：线程、进程、协程和GIL（二） 这一篇来说说线程间通信的那些事儿： 一个线程向另一个线程发送数据最安全的方式就是使用queue库中的队列了，通过创建一个供多个线程共享的Queue对象，这些线程使 ...
分类：
编程语言 时间：
2019-01-13 01:56:03
阅读次数：
197
<! TOC "kafka" "安装" "修改配置文件" "java操作kafka" <! /TOC kafka kafka的操作相对来说简单很多 安装 修改配置文件 1. server.properties 2. 运行 java操作kafka 1. 依赖 2. 生产者 3. 消费者 ...
分类：
编程语言 时间：
2019-01-12 21:52:01
阅读次数：
294
是 对于java学习的前期，大约学了三周左右，我们在老师的带领下写了这个商品系统，功能比较简单，运用的都是java学习前期比较基础的知识 这是我对这个系统的名字与包和class文件的命名。 主要创建的是商品和生产者之间，Commodity和producer。 创建商品的基本属性（成员变量），以及一个 ...
分类：
编程语言 时间：
2019-01-12 21:48:18
阅读次数：
224
先说下这个参数的作用: 绑定好之后就可以测试这个参数了,使用我们指定的交换器和key! 程序启动之后会自动创建,这里如果需要捕获匹配失败的消息需要添加一个监听器 测试:当参数设置为true时,写个错误的key: 由于key不对,匹配队列失败,参数为true,所以消息会返回给生产者: 如果写上正确ke ...
分类：
编程语言 时间：
2019-01-12 12:15:25
阅读次数：
258
有了我们的消费者和生产者代码，我们需要来验证一下它们的正确性，照常理来说我们直接创建一些消费者和生产者的线程让它们执行就可以了啊，但是为了“加分”考虑呢，我们还是使用线程池吧..也不是特别复杂：
分类：
其他好文 时间：
2019-01-10 12:05:03
阅读次数：
174
上一篇博客 Android-Java多线程通讯(生产者 消费者)&等待唤醒机制 是两条线程（Thread-0 / Thread-1） 在被CPU随机切换执行； 而今天这篇博客是，在上一篇博客Android-Java多线程通讯(生产者 消费者)&等待唤醒机制 的基础上，扩大规模增加10条线程去执行 生 ...
分类：
移动开发 时间：
2019-01-09 15:45:29
阅读次数：
199
BlockingQueue 实现之 SynchronousQueue SynchronousQueue是一个没有数据缓冲的BlockingQueue，生产者线程对其的插入操作put必须等待消费者的移除操作take，反过来也一样。 不像ArrayBlockingQueue或LinkedListBloc ...
分类：
编程语言 时间：
2019-01-09 11:18:43
阅读次数：
244
1.topic类型的Exchange 我们之前说过Topic类型的Exchange是direct类型的模糊查询模式，可以通过routkey来实现模糊消费message，topic的模糊匹配有两种模式： 1. 使用*来匹配一个单词 2.使用#来匹配0个或多个单词 我们来看代码 消费端 生产者代码 我们 ...
分类：
Web程序 时间：
2019-01-09 11:14:10
阅读次数：
128
一、future模式 在网上购物时，提交订单后，在收货的这段时间里无需一直在家里等候，可以先干别的事情。类推到程序设计中时，当提交请求时，期望得到答复时，如果这个答复可能很慢。传统的是一直等待到这个答复收到时再去做别的事情，但如果利用Future设计模式就无需等待答复的到来，在等待答复的过程中可以干 ...
分类：
其他好文 时间：
2019-01-08 21:57:29
阅读次数：
178
