1-生产者消费者问题 1. 使用栈来存放数据 1.1 把栈改造为支持线程安全 1.2 把栈的边界操作进行处理，当栈里的数据是0的时候，访问pull的线程就会等待。 当栈里的数据是200的时候，访问push的线程就会等待2. 提供一个生产者（Producer）线程类，生产随机大写字符压入到堆栈3. 提 ...
分类：
编程语言 时间：
2020-01-27 19:22:24
阅读次数：
68
目录 简介 Kafka架构 Kafka存储策略 Kafka删除策略 Kafka broker Kafka Design The Producer The Consumer 复制（Replication） 日志压缩（Log Compaction） Distribution Zookeeper协调控制 ...
分类：
其他好文 时间：
2020-01-26 19:24:21
阅读次数：
67
什么是消息中间件 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信。对于消息中间件，常见的角色大致也就有Producer（生产者）、Consumer（消费者） 常见的消息中间件产品: ...
分类：
其他好文 时间：
2020-01-21 16:36:33
阅读次数：
89
回忆一下,在上一篇文章中,我们使用eureka作为注册中心,将producer注册到eureka,并且在consumer中通过eureka发现producer服务进行调用,让我们来分析一下,这样是否已经足够完美,还有没有什么问题? 1.首先,eureka没有任何安全验证,任何应用都可以访问,这显然不 ...
分类：
编程语言 时间：
2020-01-20 09:30:08
阅读次数：
60
回忆一下,在上一篇文章中,我们创建了两个springboot项目,并且在consumer项目中通过restTemplate进行HTTP通信,成功访问到了producer提供的接口,思考一下这样的实现方式有什么问题? 1.consumer必须知道prod ...
分类：
编程语言 时间：
2020-01-19 09:26:33
阅读次数：
173
这节介绍RocketMQ客户端的启动流程，即Consumer和Producer的启动流程。 1. 客户端demo 首先先看下客户端的demo Producer: Producer和Consumer的启动类似，在初始化然后进行必要设置（主要是客户端所属的Group和NameSe ...
分类：
其他好文 时间：
2020-01-18 01:14:30
阅读次数：
73
Publish/Subscribe发布/订阅What This Tutorial Focuses OnIn the previous tutorial we created a work queue. The assumption behind a work queue is that each t... ...
分类：
其他好文 时间：
2020-01-18 01:05:54
阅读次数：
80
MQ产品常用的三种协议： 1:JMS rocketMQ，activeMQ 2.AMQP RabbitMq 3.MQTT activeMQ RabbitMQ是AMQP的一种实现。 AMQP是什么？ 基本概念 broker：消息代理 producer: 消息的生产者 consumer: 消息的消费者 e ...
分类：
其他好文 时间：
2020-01-16 22:25:32
阅读次数：
93
生产者端消费者端运行效果补充RocketMQ提供了3种模式的Producer：NormalProducer（普通）、OrderProducer（顺序）、TransactionProducer（事务），对应的分别是普通消息、顺序消息和事务消息。在前面的博客当中，涉及的都是NormalProducer， ...
分类：
其他好文 时间：
2020-01-16 12:44:51
阅读次数：
97
文章目录 一、 Producer端重试 二、 Consumer端重试 1. Exception 2. Timeout总结 对于MQ，可能存在各种异常情况，导致消息无法最终被Consumer消费掉，因此就有了消息失败重试机制。很显示，消息重试分为2种：Producer端重试和Consumer端重试。 ...
分类：
其他好文 时间：
2020-01-15 19:11:14
阅读次数：
95
