kafka broker：运行kafka server的服务被称为broker,它主要用于接手topic消息，管理topic,持久化和存储topic数据，kafka审计，kafka权限管理等。 topic:消息主题，每个topic唯一，可存储和传输数据。(MQ中通常有Topic和Queue 2中消息 ...
分类：
其他好文 时间：
2020-02-22 18:31:35
阅读次数：
82
架构师必备之高性能架构学习路线：消息中间件，Nginx，Redis等！
分类：
其他好文 时间：
2020-02-21 21:58:08
阅读次数：
117
RedisQueue是一款轻量级的分布式异步任务队列调度框架，基于redis数据库作为broker，生产端将任务job存储到redis数据库中，消费端监听队列并取出任务执行。 1.基础架构 rq框架使用前需要安装rq库，使用pip安装即可：pip install rq 1.1 生产者 生产者将任务发 ...
分类：
编程语言 时间：
2020-02-21 18:40:13
阅读次数：
156
用户购买一笔订单，需要在订单的有效截止时间前一定时间，提醒用户去使用。到达有效结束时间，将订单设置为失效。这时候可以用延时队列可以很好的解决，用户下单之后，在有效期前发送一条提醒用户去使用的消息，和一条订单已经失效的消息。 入口 生产者 将消息发送出去，延时delay毫秒，同时记录下消息发送的时间。 ...
分类：
编程语言 时间：
2020-02-21 18:13:39
阅读次数：
67
RabbitMQ 消息可靠性 一、发布确认机制。 生成者发送消息，Exchange路由消息到队列，RabbitMQ就会给生产者发送确认Ack。（注意：发布确认机制不能和事务机制一起使用） 注意：多消息发布确认机制情况下，倘若要发送 100 条消息，发送 90 条后，突然网络故障，后面的消息发送失败了 ...
分类：
其他好文 时间：
2020-02-20 23:47:11
阅读次数：
72
作者：Gundy_链接：https://www.jianshu.com/p/dc94f2099277 生产者消费者模型 并发编程中最常见的例子就是生产者消费者模式，该模式主要通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度。简单地说，就是生产者生产一些数据，然后放到成果队列中，同时 ...
分类：
其他好文 时间：
2020-02-20 19:56:03
阅读次数：
98
今天遇到两位三方人员跟我反馈，某微服务的异步接口功能不正常了，由于该异步接口采用Kafka异步消息的方案，对方说没有收到Kafka给消费者的通知，根据此问题，联系了相关人员进行了分析： （一）明确环境是否一致 1、生产者和消费者链接Kafka的地址是否一致，初步发现A方消费者链接Kafka的地址不正 ...
分类：
其他好文 时间：
2020-02-20 15:14:09
阅读次数：
109
RocketMQ生产者和消费者 注：生产者在生产数据时，指定数据的key，然后消费者进行数据消费时，获取到key，与redis中保存的key做判断 如果不相同代表之前没有人进行消费，处理消费，保存到redis当中 当有第二个消费者时，如果拿到的消息与redis中相同代表之前已已经有人消费 就进行数据 ...
分类：
其他好文 时间：
2020-02-18 20:11:14
阅读次数：
60
RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列，类似于kafka中的partition producer 生产者，先去连接name server，查询到对应的broker信息，再去连接broker consumer 消费者，先去连接na ...
分类：
其他好文 时间：
2020-02-17 20:08:08
阅读次数：
85
1.生产者 1.1 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <!-- spring boot we ...
分类：
编程语言 时间：
2020-02-16 16:21:06
阅读次数：
85
