点对点（P2P） 结构 创建生产者和消费者两个springboot工程 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId ...
分类：
编程语言 时间：
2020-02-14 20:21:17
阅读次数：
72
生产者消费者模型 [目的] 解决并发编程中的绝大部分并发问题 【组成要素】 生产者：负责生产数据或任务 消费者：负责消费数据或者任务 容器：生产者和消费者进行通讯的媒介（阻塞队列）来达到解耦目的 [主要方法] 容器：q=queue.Queue() 生产者：q.put(product/tack) q. ...
分类：
其他好文 时间：
2020-01-23 14:10:40
阅读次数：
82
阻塞队列BlockingQueue是一个接口，基于ReentrantLock ,依据它的基本原理，我们可以实现Web中二段长连接聊天功能，当然其最常用的还是用于实现生产者和消费者模式： BlockingQueue接口提供了以下方法： package java.util.concurrent; imp ...
分类：
其他好文 时间：
2020-01-18 18:03:07
阅读次数：
113
队列解决的问题:(1)有序,好管理 .(2)生产者和消费者快慢的问题，现实就是这样,快慢的问题。应用在事件驱动软件架构中. ...
分类：
其他好文 时间：
2020-01-14 12:55:24
阅读次数：
66
Kafka是一款由linkedln（领英）公司开发，并由Apache基金会开源的中间件。
Kafka由Scala和Java写成，主要负责分布式消息订阅，它可以处理生产者和消费者之间的动作流，作为消息队列为业界所使用。 ...
分类：
其他好文 时间：
2019-12-30 09:34:45
阅读次数：
103
本篇会给出如何使用python来读写kafka, 包含生产者和消费者. 以下使用 "kafka python" 客户端 生产者 爬虫大多时候作为消息的发送端, 在消息发出去后最好能记录消息被发送到了哪个分区, offset是多少, 这些记录在很多情况下可以帮助快速定位问题, 所以需要在 方法后加入c ...
分类：
编程语言 时间：
2019-12-30 00:24:53
阅读次数：
107
一、简介： RabbitMq 是实现了高级消息队列协议（AMQP）的开源消息代理中间件。消息队列是一种应用程序对应用程序的通行方式，应用程序通过写消息，将消息传递于队列，由另一应用程序读取 完成通信。而作为中间件的 RabbitMq 无疑是目前最流行的消息队列之一。 AMQP，即Advanced M ...
分类：
其他好文 时间：
2019-12-26 21:39:09
阅读次数：
95
RabbitMQ 1.什么是rabbitmq 在生产者和消费者之间加了一个中间件——消息队列，用它可以来干嘛呢？ 它是来做消息转发的，当请求过来之后，不是直接发给服务器，而是发给消息队列，然后消息队列把消息中转一下再发给服务器 2.作用 存储消息、数据 保证消息的顺序 保证数据的正确交付 3.rab ...
分类：
其他好文 时间：
2019-12-26 12:49:35
阅读次数：
92
生产者和消费者必须使用同步代码块包裹起来，保证等待和唤醒只能有一个执行，同步使用的锁对象必须保证唯一 ...
分类：
编程语言 时间：
2019-12-25 14:34:55
阅读次数：
87
上一篇文章中我们已经介绍过rocketmq的集群环境搭建，然而在源码的学习中我们还需要进行本地的调试和问题的定位查找，毕竟还是在本地方便些，今天就说一说如何进行源码的本地调试 ...
分类：
其他好文 时间：
2019-12-22 20:26:44
阅读次数：
142
