activemq 是 基于 jms 协议的 消息队列 消息 流程： jsm 的 消息流程鼻尖简单 生产者发送消息到目的地，消费者 监听这个目的地，然后收到消息。 相比 amqp 的 消息流程简单很多。 producer：生产者，产生消息。 consumer：消费者 destination：目的地 j ...
分类：
其他好文 时间：
2018-08-23 22:19:30
阅读次数：
224
celery内置了kombu库，看了一下kombu的源码，从官网最简单的一个例子来分析 消息发布，源码如下： 运行之前开启redis服务。这真是简单到不能到简单的例子-.- 一步步分析画出如下类图： 大概十七八个类。流程省略几百万个字。 记一下关键步骤： 1、创建生产者 messaging.Prod ...
分类：
其他好文 时间：
2018-08-17 19:09:36
阅读次数：
225
Kafka整体结构图 Producer ：消息生产者，就是向 kafka broker 发消息的客户端。 Consumer ：消息消费者，向 kafka broker 取消息的客户端 Topic ：每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。 Consumer Group ...
分类：
其他好文 时间：
2018-08-10 23:12:32
阅读次数：
224
常用的几个命令如下： kafka-server-start.shkafka-console-consumer.shkafka-console-producer.shkafka-topics.sh在这几个命令中，第一个仅用于启动Kafka，后两个console常用于测试，用途最多的是最后一个命令，所以 ...
分类：
其他好文 时间：
2018-08-09 12:11:45
阅读次数：
361
启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html） 1.创建Topic 1）运行命令： ./bin/kafka-topics.sh --create --zo ...
分类：
其他好文 时间：
2018-08-06 00:44:08
阅读次数：
162
1.首先在resources下面写log4j.properties 主要是因为kafka.producer.KafkaLog4jAppender类的存在。 2.测试类 3.开启9092端口的消费者服务 bin/kafka-console-consumer.sh --topic beifeng --z ...
分类：
其他好文 时间：
2018-08-05 18:05:27
阅读次数：
189
1.需要启动的服务 这里启动的端口是9092。 bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibeifeng.com:2181/kafka 2.producer的程序 3.测试类 4.效果 二：使用 ...
分类：
编程语言 时间：
2018-08-05 16:53:20
阅读次数：
163
1.命令 2.启动生产者 bin/kafka-console-producer.sh --topic beifeng --broker-list linux-hadoop01.ibeifeng.com:9092,linux-hadoop01.ibeifeng.com:9093,linux-hadoo ...
分类：
其他好文 时间：
2018-08-04 17:25:17
阅读次数：
136
One of the programming paradigm in parallel processing is the producer/consumer paradigm that can be implemented using a system with a "manager" proce ...
分类：
编程语言 时间：
2018-08-03 23:15:40
阅读次数：
224
RabbitMQ是一个消息服务器，可以接收和转发消息。 RabbitMQ是一个消息代理 - 一个消息系统的媒介。它可以为你的应用提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全。 生产者（producer）发送一条消息，消费者(consumer)接收消息并打印。 Queue 队列 P ...
分类：
其他好文 时间：
2018-08-03 16:28:35
阅读次数：
149
