一、消息队列的演进 1、初始阶段 最初的消息队列，就是一个严格意义上的队列。队列是一种数据结构，先进先出，在消息入队出队过程中，保证这些消息严格有序。早期的消息队列就是按照“队列”的数据结构设计的。 队列模型： 生产者（Producer）发消息就是入队操作，消费者（Consumer）收消息就是出队也 ...
分类：
其他好文 时间：
2019-08-25 15:45:11
阅读次数：
101
多线程(一) 1.多进程补充(生产者消费者模型) 2.线程 2.开启线程的两种方式 3.多进程与多线程对比 4.线程的相关其他方法 5.join方法与守护线程 6.互斥锁 ...
分类：
编程语言 时间：
2019-08-23 00:17:25
阅读次数：
109
# 进程间通信与线程## 一、进程间通过队列通信```python"""队列:先进先出堆栈:先进后出"""from multiprocessing import Queueq = Queue(5) # 括号内可以传参数 表示的是这个队列的最大存储数# 往队列中添加数据q.put(1)q.put(2)... ...
分类：
编程语言 时间：
2019-08-20 00:56:31
阅读次数：
76
由于项目中要用到kafka，先在自己的虚拟机上部署试一下 1. 下载压缩包 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.0/kafka_2.12-2.3.0.tgz 2. kafka运行依赖zookeeper，如未安装，可参照 http ...
分类：
系统相关 时间：
2019-08-19 20:57:09
阅读次数：
147
通过https://www.cnblogs.com/tree1123/p/11243668.html 已经对consumer有了一定的了解。producer比consumer要简单一些。 一、旧版本producer 0.9.0.0版本以前，是由scala编写的旧版本producer。 入口类：kaf ...
分类：
其他好文 时间：
2019-08-19 17:37:10
阅读次数：
69
代理一个普通的java类 导入cglib的包 它还有一个asm的依赖。会自动加进来 创建cglib的文件夹。把proxy里面的Client和Producer复制到cglib文件夹 Producer不实现任何的接口 Client内的代码要重新写 不能受罪种类，如果是最终类就不能再创建子类了 参数1是C ...
分类：
编程语言 时间：
2019-08-14 20:04:45
阅读次数：
98
4）设置脚本开机自动执行 ··· vi /etc/rc.d/rc.local #编辑，在最后添加一行 sh /usr/local/kafka/kafkastart.sh & ＃设置开机自动在后台运行脚本 vi /etc/rc.d/rc.local #编辑，在最后添加一行 sh /usr/local/ ...
分类：
其他好文 时间：
2019-08-14 14:18:36
阅读次数：
80
生产者需要将要发送的数据转换成字节数组才能通过网络发送给kafka,对于一些简单的数据，kafka自带了一些序列化工具， 如：StringSerializer Double Long Integer Byte，它们都实现了 Serializer 接口，但是如果你要发送的数据是一个对象 Persion ...
分类：
其他好文 时间：
2019-08-13 15:12:15
阅读次数：
72
使用apache的rocketMQ Client连接服务器时一个JVM只能连接一台服务器，本文提供了一个更为简洁的解决方案。
分类：
编程语言 时间：
2019-08-13 12:08:50
阅读次数：
148
概念 Kafka 是一个快速、可扩展和高可用的基于发布 订阅模式（pub sub model）的消息系统，用作消息中间件，在系统之间传递消息。其核心概念有： Topic（话题） Producer（生产者） Consumer（消费者） Broker（经纪人） 在 Kafka 中，所有的消息都由 Top ...
分类：
其他好文 时间：
2019-08-11 12:44:35
阅读次数：
108
