最近在调试RocketMQ消息发送与消费的Demo时,发现一个问题:只要重启程序,RocketMQ消息就会重复消费。 那么这是什么原因导致的,又该如何解决呢? 经过一番排查,发现程序使用的RocketMQ客户端版本是3.6.2,而测试环境安装的RocketMQ环境的版本是4.1.0。原来是客户端和服 ...
分类:
其他好文 时间:
2018-07-25 22:43:12
阅读次数:
412
Netty作为一个Java生态中的网络组件有着举足轻重的位置,各种开源中间件都使用Netty进行网络通信,比如Dubbo、RocketMQ。可以说Netty是对Java NIO的封装,比如ByteBuf、channel等的封装让网络编程更简单。 在介绍Netty服务器启动之前需要简单了解两件事: 1 ...
分类:
Web程序 时间:
2018-07-22 15:11:17
阅读次数:
241
参考地址:https://blog.csdn.net/win7system/article/details/54377471 使用场景:在自动解析封装配置文件中的配置完成自动注入spring的时候 例如rocketMQ相关配置 例如Druid相关配置 ...
分类:
编程语言 时间:
2018-07-20 14:35:56
阅读次数:
150
这个ip是我云主机的内网Ip,我本地连接boker是肯定连接不上的 ...
分类:
其他好文 时间:
2018-07-19 19:14:12
阅读次数:
113
先来一篇解释比较多的实例 https://www.cnblogs.com/super-d2/p/4154541.html No route info of this topic, PushTopic 这个问题 是因为没有fastjson的包.. 网上也有其他的解释 https://blog.csdn ...
分类:
其他好文 时间:
2018-07-18 13:55:12
阅读次数:
112
最近想要学习MOM(消息中间件:Message Oriented Middleware),就从比较基础的activeMQ学起,rabbitMQ、zeroMQ、rocketMQ、Kafka等后续再去学习。 上面说activeMQ是一种消息中间件,可是为什么要使用activeMQ? 在没有使用JMS的时 ...
分类:
编程语言 时间:
2018-07-18 10:51:08
阅读次数:
158
消息队列 已经逐渐成为企业应用系统 内部通信 的核心手段。它具有 低耦合、可靠投递、广播、流量控制、最终一致性 等一系列功能。 当前使用较多的 消息队列 有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ 等,而部分 数据库 如 Redis、MySQL ...
分类:
其他好文 时间:
2018-07-13 16:21:49
阅读次数:
230
我们知道,在早期的RocketMQ版本中,是有依赖ZK的。而现在的版本中,是去掉了对ZK的依赖,转而使用自己开发的NameSrv。 并且这个NameSrv是无状态的,你可以随意的部署多台,其代码也非常简单,非常轻量。 那不禁要问了:ZooKeeper是业界用来管理集群的一个非常常用的中间件,比如Ka ...
分类:
其他好文 时间:
2018-07-06 17:56:59
阅读次数:
315
消息中间件通常需要解决哪些问题,在解决这些问题当中会遇到什么困难,ApacheRocketMQ作为阿里开源的一款高性能、高吞吐量的分布式消息中间件否可以解决,规范中如何定义这些问题。然后本文将介绍RocketMQ的架构设计,以期让读者快速了解RocketMQ。消息中间件需要解决哪些问题?Publish/Subscribe发布订阅是消息中间件的最基本功能,也是相对于传统RPC通信而言。在此不再详述。
分类:
其他好文 时间:
2018-07-06 16:36:07
阅读次数:
153
xmind 源文件下载 https://pan.baidu.com/s/1793o8APhVO0BNGA3C9mBgw ...
分类:
其他好文 时间:
2018-06-29 23:36:17
阅读次数:
235