消息中间件 - 文集

消息中间件

32篇文章 · 52324字 · 6人关注

为Kafka的每条消息加上MessageID
由于一些因素限制（无法粘帖代码，都是我手敲的），代码里没有异常处理，自己实现时请注意异常处理简介之前提过我在公司内部做的是一个消息平台，为各...

0.4 7172 0 5
为ActiveMQ增强JMX指标
前端时间学习了一下JMX的写法，相关的学习资料可以百度一下JMX学习。日常最常用到JMX的地方是监控采集，往往开源项目也都会内置JMX的接口，供...

1399 0 1

ActiveMQ SSL连接泄露问题记录
现象前几日在生产环境上出现了SSL连接泄露的问题，具体现象是客户端使用SSL协议不停尝试重连MQ，客户端上使用netstat查看，同时存在的...

0.1 1749 0 2
RocketMQ开发者沙龙-20180901
待询问的问题：安全插件 CHAS 备机接管暖场目前正在考虑多语言的支持，后续新增C++, PYTHON, NODE.JS等客户端. Op...

1306 0 2
Kafka安全机制解析及重构（四）| ACL权限控制
在前三篇文章中我们介绍了Kafka的安全机制，并自己重构了一个名为ABC的SASL机制Kafka安全机制解析及重构（一）Kafka安全机制解析及...

3748 0 0
Kafka安全机制解析及重构（三）| 重构示例及脑洞
2018.12.01注：详细代码由于在内网无法直接奉上，所以这篇介绍的只是基本的代码结构，可能还需要再调试一下才能通。调试过程中需要注意的是：s...

2866 5 3 1
Kafka安全机制解析及重构（二）| PLAIN机制解读
上一篇Kafka安全机制解析及重构（一）中介绍了Kafka的安全认证的流程。其实Kafka官方也是推荐用户自己写一个安全认证模块的。官方在介绍S...

4092 0 2

Kafka安全机制解析及重构（一）| 概述
2018年12月1日更新：之前写错了，后根据读者的修正重新修正了一下逻辑，感谢！许久不写文章，主要是心情不佳，而且恰逢项目方向变动，学习和研究...

6679 2 3
设计一个消息中间件的前置（三）| 数据结构及高可用设计
前两篇讲到了基本思路和netty+protobuf框架，今天这篇介绍一下前置的基本数据结构及用户校验，熔断的流程。数据源及高可用前置的数据源...

0.1 810 0 2