一、生产者配置 二、消费者配置 三、其它重要配置 ...
分类：
编程语言 时间：
2019-07-15 10:43:48
阅读次数：
277
Python并发编程之多进程 一、什么是进程 进程：正在进行的一个过程或者说一个任务。而负责执行任务则是cpu。 进程是资源分配的基本单位 进程有：代码段，数据段，进程控制块（PCB）组成 二、进程与程序的区别 程序仅仅只是一堆代码而已，而进程指的是程序的运行过程。 举例： 想象一位有一手好厨艺的计 ...
分类：
编程语言 时间：
2019-07-15 01:38:59
阅读次数：
113
一、什么是Exchange 首先我们要了解到，RabbitMQ 是 AMQP（高级消息队列协议）的标准实现： 从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体 ...
分类：
其他好文 时间：
2019-07-14 21:23:31
阅读次数：
405
创建一个2个分区，3个副本的topic，名字叫first kafka-topics.sh --create --zookeeper datanode1:2181 --partitions 2 --replication-factor 3 --topic first 生产者发送消息顺序发送： 消费者接 ...
分类：
其他好文 时间：
2019-07-14 15:06:31
阅读次数：
274
什么是消息队列 消息队列，即MQ，Message Queue。 消息队列是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。 结合前面所说的问题： ...
分类：
其他好文 时间：
2019-07-13 20:05:30
阅读次数：
134
生产者消费者模型 模型就是要解决某个问题的固定方法或套路 要解决的问题 生产者:泛指生产数据的一方 消费者:泛指处理数据的一方 双方的处理速度不一致,导致总有一方会在等待 解决问题的方法 1. 先将双方解开耦合,让不同的进程负责不同的任务 2. 提供一个共享的容器如队列,用来平衡双方的能力,用队列是 ...
分类：
编程语言 时间：
2019-07-13 17:28:25
阅读次数：
145
队列消息持久化之JDBC 1、 配置activemq.xml文件，修改持久化方式为jdbc 2、在broker外配置数据库连接bean 3、启动服务，可以看到数据库中多了3张表，表明配置成功 4、运行Producer，模拟生产者发送消息 控制台输出： Activemq管理控制台： 数据库表中: 5、 ...
分类：
其他好文 时间：
2019-07-11 12:20:40
阅读次数：
70
发布与订阅模式和观察者模式有以下不同： 观察者模式中，观察者和主题都知道对方的存在；而在发布与订阅模式中，生产者与消费者不知道对方的存在，它们之间通过频道进行通信。 观察者模式是同步的，当事件触发时，主题会调用观察者的方法，然后等待方法返回；而发布与订阅模式是异步的，生产者向频道发送一个消息之后，就 ...
分类：
其他好文 时间：
2019-07-10 12:21:50
阅读次数：
117
1 package com.benq; 2 3 import java.util.*; 4 import java.util.concurrent.TimeUnit; 5 6 public class HH { 7 public static void main(String[] args){ 8 ... ...
分类：
编程语言 时间：
2019-07-10 01:18:29
阅读次数：
116
多线程访问同一个资源进行读写操作，就很容易出一些问题（比如我们常见的读者写者，生产者消费者模型）所以我们会选择对他们设置信号量或者加锁，来限制同一个时刻只有一个线程对某个对象进行操作。 多线程是一个蛮复杂的工作，锁加多了就算是看伪代码有的时候脑子都转不过来，所以不要随便加锁（如果对自己的脑子没太多自 ...
分类：
编程语言 时间：
2019-07-09 15:16:59
阅读次数：
150
