Producer异步发送演示在上文中介绍了AdminClientAPI的使用，现在我们已经知道如何在应用中通过API去管理Kafka了。但在大多应用开发中，我们最常面临的场景就是发送消息到Kafka，或者从Kafka中消费消息，也就是典型的生产/消费模式。而本文将要演示的就是如何使用ProducerAPI将消息发送至Kafka中，使应用成为一个生产者。ProducerAPI具有以下几种发送模式：异
一、Routing模式简介 RabbitMQ的路由模式，可以简单理解为，根据exchange绑定的key，将消息路由到不同的queue，模型图如下： 上图中几个关键点： Publisher:消息的生产者 Exchange:路由,类型为direct Queue:队列，存储消息的地方 Consumer: ...
分类：
其他好文 时间：
2020-05-15 13:31:28
阅读次数：
90
1 ActiveMq JMS --> java Message 2 ActiveMQ的消息形式 有2种类型： 2.1 一种是点对点的，一个生产者和一个消费者一一对应 多个生产者 Queue 多个消费者 2.2 另一种是发布、订阅模式，一个生产者产生消息并进行发送后，可以由多个消费者进行接收 多个生产 ...
分类：
其他好文 时间：
2020-05-15 09:35:18
阅读次数：
52
前言 消息队列：可以将原本同步执行的程序 解耦成异步执行，加上分布式的生产者和消费者架构 可以在一定程度上支撑大并发。 NSQ是go语言开发的消息队列，对nsqd进行水平扩展是它的部署、配置相对简单。 NSQ介绍 NSQ是1个分布式(distributed)、可扩展（scalable）、配置简单（O ...
分类：
其他好文 时间：
2020-05-14 19:03:34
阅读次数：
62
为何采用 TCP？ Apache Kafka 的所有通信都是基于 TCP 的 而不是基于 HTTP 或其他协议 无论是生产者、消费者，还是 Broker 之间的通信都是如此 人们能够利用 TCP 本身提供的一些高级功能，比如多路复用请求以及同时轮询多个连接的能力 所谓的多路复用请求，即 multip ...
分类：
编程语言 时间：
2020-05-14 15:58:34
阅读次数：
102
例子： 生产者，消费者问题；消费者先进入临界区，条件变量未满足条件，阻塞等待；生产者无法进入临界区，从而无法修改条件变量，也就产生死锁； 解决方法：如果遇到条件变量未满足条件，消费者先释放锁，进入阻塞，等待条件变量得到满足；然后生产者可以进入临界区，修改条件变量，修改后通知消费者进入临界区，生产者释 ...
分类：
系统相关 时间：
2020-05-14 01:36:41
阅读次数：
76
一.wait/notity的使用 wait()方法可以使线程进入等待状态，而notify()可以使等待的状态唤醒。 这样的同步机制十分适合生产者、消费者模式：消费者消费某个资源，而生产者生产该资源。 当该资源缺失时，消费者调用wait()方法进行自我阻塞，等待生产者的生产；生产者生产完毕后调用not ...
分类：
其他好文 时间：
2020-05-12 14:08:20
阅读次数：
61
个人在学习Kafka ， 这两天在看官方文档。看完了简介部分，看完做个小总结。看看官方是怎么夸Kafka的。## 三大特性- 发布-订阅- 持久化存储- 低延迟的实时处理## 特性梳理- Topic ： 逻辑概念，承载数据的实体- 数据的保存期限可以设置- 磁盘是顺序读写，IO不是瓶颈- 可以处理大... ...
分类：
其他好文 时间：
2020-05-11 21:42:33
阅读次数：
50
以下出现代码均为伪代码； 2.5.1 生产者 消费者问题（考试模型占比 60%） 分析上图：缓冲区存在互斥问题，生产者与消费者之间还 存在同步问题 1. 利用 记录型信号量 解决生产者 消费者问题(==背下来==) 假定在生产者和消费者之间的共用缓冲池中具有n个缓冲区，这时可以利用互斥信号量mute ...
分类：
系统相关 时间：
2020-05-11 00:57:40
阅读次数：
88
一。rabbitmq基本知识 exchange: 交换器，接收生产者发送的消息并路由给对应的队列。三种常用的交换器类型：1.direct(发布订阅，完全匹配) 2。广播型 3.topic（主题，规则匹配） queue: 消息队列，用来保存消息直到发送给消费者。消息一直在队列中，知道消费者链接到队列将 ...
分类：
编程语言 时间：
2020-05-10 23:03:39
阅读次数：
91
