本篇会给出如何使用python来读写kafka, 包含生产者和消费者. 以下使用 "kafka python" 客户端 生产者 爬虫大多时候作为消息的发送端, 在消息发出去后最好能记录消息被发送到了哪个分区, offset是多少, 这些记录在很多情况下可以帮助快速定位问题, 所以需要在 方法后加入c ...
分类：
编程语言 时间：
2019-12-30 00:24:53
阅读次数：
107
1. 同步概念 2. 线程同步 3. 进程同步4. 生产者消费者模型5. 哲学家问题 ...
分类：
编程语言 时间：
2019-12-29 23:45:04
阅读次数：
116
一、简介： 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
参考代码： package aaa; public class Goods { private String name; private String brand; boolean isFlag; public String getName() { return name; } public voi ...
分类：
编程语言 时间：
2019-12-25 16:02:22
阅读次数：
74
生产者和消费者必须使用同步代码块包裹起来，保证等待和唤醒只能有一个执行，同步使用的锁对象必须保证唯一 ...
分类：
编程语言 时间：
2019-12-25 14:34:55
阅读次数：
87
# 特性(features) 1 订阅与发布 消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。 2 消息顺序 消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订单产生了三条消息分别是订单 ...
分类：
其他好文 时间：
2019-12-24 13:45:00
阅读次数：
95
最佳实践 1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags("T ...
分类：
其他好文 时间：
2019-12-24 13:31:38
阅读次数：
76
分析线程经典案例生产者消费者 运行结果： 结果分析： 那么怎么再判断flag呢？while 代码如下： 结果出现死锁： 结果分析： 通过分析，那能不能每次唤醒只唤醒对方线程（如生产者线程只唤醒消费者线程，消费者线程只唤醒生产者线程），查看Object对象方法中没有，但是有一个notifyAll()方 ...
分类：
编程语言 时间：
2019-12-23 13:43:16
阅读次数：
93
目标 1、交换机 2、RabbitMQ整合springCloud 交换机 蓝色区域 生产者 红色区域 Server：又称Broker，接受客户端的连接，实现AMQP实体服务 绿色区域 消费者 黄色区域 就是我们的交换机以及队列 由生产者投递信息到RabbitMQ Server里面某一个交换机对应的队 ...
分类：
编程语言 时间：
2019-12-23 00:55:32
阅读次数：
134
