生产者端消费者端运行效果补充RocketMQ提供了3种模式的Producer：NormalProducer（普通）、OrderProducer（顺序）、TransactionProducer（事务），对应的分别是普通消息、顺序消息和事务消息。在前面的博客当中，涉及的都是NormalProducer， ...
分类：
其他好文 时间：
2020-01-16 12:44:51
阅读次数：
97
文字讲解 题目分析： __首先__ ,要知道这道拓扑排序题目的性质。 食物链中的生物 —— __节点__ 生物之间的关系 —— __有向边__ 为了方便描述，我们 将 __最左端是不会捕食其他生物的生产者__ 叫做 __最佳生产者__ 将 __最右端是不会被其他生物捕食的消费者__ 叫做 __最佳消 ...
分类：
其他好文 时间：
2020-01-15 23:23:32
阅读次数：
161
一、简单模式 原理 ：生产者将消息交给默认的交换机，交换机获取消息后交给绑定这个生产者的队列（投递规则为队列名称和routing key 相同的队列），监听当前队列的消费者获取信息并执行消费逻辑。 场景 ：有一个oa系统，用户通过接收手机验证码进行注册，页面上点击获取验证码后，将验证码放到消息队列， ...
分类：
其他好文 时间：
2020-01-15 11:46:36
阅读次数：
67
普通生产者 import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import java.io.IOExcept ...
分类：
其他好文 时间：
2020-01-14 13:03:11
阅读次数：
94
文章目录 Windows平台进程内消息总线如果没有消息总线，会产生什么问题死循环包含关系高耦合、低内聚消息总线结构图原理生产者与总线的关系总线与消费者的关系Linux进程内消息总线设计使用进程间实时信号来实现进程内消息总线参考文档整体流程主线程注册总线消息处理函数生产者线程产生并发送消息到总线接收并 ...
分类：
系统相关 时间：
2020-01-14 12:59:01
阅读次数：
95
队列解决的问题:(1)有序,好管理 .(2)生产者和消费者快慢的问题，现实就是这样,快慢的问题。应用在事件驱动软件架构中. ...
分类：
其他好文 时间：
2020-01-14 12:55:24
阅读次数：
66
kafka 相关的知识进入 /usr/local/kafka 目录下查看端口 vim zookeeper.properties #文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径，clientPort=2182代表zookeeper的端口号为：2182，消费者需要 ...
分类：
其他好文 时间：
2020-01-13 20:22:45
阅读次数：
124
FAQ Q: 如何确保消息不丢失？ Q: mq 的缺点 Q: 如何避免消息重复投递或重复消费？ 在消息 时，MQ 内部针对每条生产者发送的消息生成一个 inner msg id，作为去重的依据（消息投递失败并重传），避免重复的消息进入队列； 在消息 时，要求消息体中必须要有一个 bizId（对于同一 ...
分类：
其他好文 时间：
2020-01-13 19:40:08
阅读次数：
63
kafka的bin目录下有很多脚本，其中kafka-console-producer.sh是生产者脚本、kafka-console-consumer.sh是消费者脚本，下面用这两个脚本进行模拟发送消息和接收消息。在前面的3篇中已经介绍了kafka的配置。按照步骤启动zookeeper和kafka。 ...
分类：
其他好文 时间：
2020-01-12 22:18:30
阅读次数：
129
