1. 不使用Exchange交换机（默认交换机） 工具类 a. simple简单模式：一个生产者发送消息到队列中由一个消费者接收。 b. work工作队列模式：一个生产者发送消息到队列中可由多个消费者接收；多个消费者之间消息是竞争接收。 2. 使用Exchange交换机；订阅模式（广播fanout， ...
分类：
其他好文 时间：
2019-08-31 21:25:47
阅读次数：
76
kafka知识总结 //切换到安装路径命令cd /home/kafka/kafka_2.11-0.10.2.1/bin //启动kafka服务，三台主机分别输入此指令：./kafka-server-start.sh $KAFKA_HOME/config/server.properties & //以 ...
分类：
其他好文 时间：
2019-08-31 19:35:24
阅读次数：
71
一，生产者注册EOS可以执行system合约的regproducer或者unregprod动作，实现生产者注册或者取消生产者注册。1，合约中生产者注册表定义其中：owner：生产者账号名称。total_votes：获得的投票总数量。producer_key：生产者公私钥。is_active：是否是激活状态。url：生产者的url地址。unpaid_blocks：该生产者未获取生产者奖励的生产的区块
分类：
其他好文 时间：
2019-08-31 12:27:25
阅读次数：
85
1, 生产者服务： maven: 定义队列，交换机，并且绑定队列和交换机，同时注入到spring 中 conifg 的上一层就是producer: service 发送消息服务： application.yml: 2,消费者服务： 邮件消费者： 信息消费者： application.yml ...
分类：
编程语言 时间：
2019-08-30 18:40:01
阅读次数：
72
一、消息积压的原因 消息积压的直接原因，一定是系统中某个部分出现了性能问题，来不及处理上游发送的消息，才会导致消息积压。 二、优化性能来避免消息积压 在使用消息队列的系统中，对于性能的优化，主要体现在生产者和消费者两部分的业务逻辑中。对于消息队列本身的性能，作为使用者不需要太关注。主要原因是对于绝大 ...
分类：
其他好文 时间：
2019-08-30 13:33:40
阅读次数：
104
生产者和消费者模型 1. 什么是生产者和消费者模型 生产者消费者模型具体来讲，就是在一个系统中，存在生产者和消费者两种角色，他们通过内存缓冲区进行通信，生产者生产消费者需要的资料，消费者把资料做成产品。 再具体一点： 1. 生产者生产数据到缓冲区中，消费者从缓冲区中取数据。 2. 如果缓冲区已经满了 ...
分类：
其他好文 时间：
2019-08-29 18:21:42
阅读次数：
93
RabbitMQ 是什么? 消息中间件 作用? 用于分布式项目中的模块解耦 用法? 创建队列 创建消息工厂并设置 (生产者额外步骤 : 创建消息) 创建连接,通道 声明队列 生产者 : 发送消息,先关闭通道,再关闭连接 ; 消费者 : 监听队列 交换机类型? fanout, routing互补hea ...
分类：
其他好文 时间：
2019-08-29 16:25:47
阅读次数：
124
虽然ActiveMQ以被其他MQ所替代，但仍有学习的意义，本文采用邮件发送的例子展示ActiveMQ 1. 生产者1.1 引入maven依赖1.2 application.yml配置1.3 创建配置类ConfigQueue1.4 创建生产者类Producer1.5 启动类AppProducer2. ...
分类：
编程语言 时间：
2019-08-29 12:03:34
阅读次数：
177
Kafka简介 定义 Kafka是一个分布式流式处理平台，它提供三种角色：消息系统，存储系统，流式处理平台 组成 Kafka架构体系为实现消息模块包括了若干producer，broker和consumer，还有zookeeper集群来负责元数据的管理和控制器选举等操作。 生产者 主线程创建消息Pro ...
分类：
其他好文 时间：
2019-08-29 09:56:19
阅读次数：
96
