一.kafka简介 1. ApacheKafka®是一个分布式流媒体平台，是消息中间件的一种。 栗子：生产者消费者，生产者生产鸡蛋，消费者消费鸡蛋，生产者生产一个鸡蛋，消费者就消费一个鸡蛋，假设消费者消费鸡蛋的时候噎住了（系统宕机了），生产者还在生产鸡蛋，那新生产的鸡蛋就丢失了。再比如生产者很强劲（ ...
分类：
其他好文 时间：
2019-06-25 18:35:57
阅读次数：
138
介绍： Celery 是一个简单、灵活且可靠的，处理大量消息的分布式系统，并且提供维护这样一个系统的必需工具。 它是一个专注于实时处理的任务队列，同时也支持任务调度。 worker:是一个独立的进程，任务执行单元，它持续监视队列中的任务 broder:消息传输中间件，任务调度队列，接收生产者发出的消 ...
分类：
其他好文 时间：
2019-06-25 17:12:38
阅读次数：
160
模型结构 JMS编程模型由以下几个组成： ConnectionFactory：连接工厂（创建连接） Connection：连接（创建会话） Session：会话（创建目的地、生产者、消费者、消息） Destination：目的地（消息发送目标） MessageProducer：消息生产者（发送消息） ...
分类：
其他好文 时间：
2019-06-25 00:07:15
阅读次数：
115
// strUri = "amqp://guest:guest@192.168.30.11:8820/test" // strUri = "amqp://[帐户名]:[密码]@[服务主机以及端口]/[虚拟机目录] bool PublishExchangeTopic(const std::string... ...
分类：
其他好文 时间：
2019-06-24 18:18:35
阅读次数：
96
https://www.cnblogs.com/wangzhongqiu/p/7815529.html https://blog.csdn.net/u012129558/article/details/82425276 原生的实现方式 https://blog.csdn.net/cj33708317 ...
分类：
其他好文 时间：
2019-06-23 14:07:58
阅读次数：
685
一、RabbitMQ解决分布式事务思路： 案例： 经典案例，以目前流行点外卖的案例，用户下单后，调用订单服务，让后订单服务调用派单系统通知送外卖人员送单，这时候订单系统与派单系统采用MQ异步通讯。 二、RabbitMQ解决分布式事务原理：采用最终一致性原理。 需要保证以下三要素 1、确认生产者一定要 ...
分类：
其他好文 时间：
2019-06-23 11:37:46
阅读次数：
137
'192.168.23.130', 'port' => 5672, 'login' => 'rabuser', 'password' => '123456' ]); $connection->connect() or die('连接失败'); try{ $exchange_name = 'trade... ...
分类：
其他好文 时间：
2019-06-23 01:13:41
阅读次数：
90
数据发生器产生的数据被被单个的运行在数据发生器所在服务器上的agent所收集，之后数据收容器从各个agent上汇集数据并将采集到的数据存入到HDFS或者HBase中。 一个数据单元，消息头和消息体组成。（Events可以是日志记录、 avro 对象等。） Flume 运行的核心是 Agent。Flu ...
分类：
其他好文 时间：
2019-06-21 12:42:20
阅读次数：
107
1.插入队列（生产者） private static RedisClient client = new RedisClient("127.0.0.1", 6379, null);client.EnqueueItemOnList(listId, valuestr); 2.读取队列（消费者） priva ...
分类：
其他好文 时间：
2019-06-20 09:17:16
阅读次数：
95
问题起源 事情得从一个多线程编程里面臭名昭著的问题"Lost wake-up problem"说起。 这个问题并不是说只在Java语言中会出现，而是会在所有的多线程环境下出现。 假如我们有两个线程，一个消费者线程，一个生产者线程。生产者线程的任务可以简化成将count加一，而后唤醒消费者；消费者则是 ...
分类：
编程语言 时间：
2019-06-19 23:30:51
阅读次数：
307
