RocketMQ中的通信模式
RocketMQ中的通信模式 在RocketMQ中为producer提供了三种通讯模式分别是同步、异步、单向; 同时对于消息类型也提供了多种选择:广播消息、延迟消息、 顺序消息、事务消息等选择; 下文就主要介绍一些概念性的东西和最佳实践 producer 同步模式 public static void main(String[] args) throws MQClientException ...
RocketMQ中的通信模式 在RocketMQ中为producer提供了三种通讯模式分别是同步、异步、单向; 同时对于消息类型也提供了多种选择:广播消息、延迟消息、 顺序消息、事务消息等选择; 下文就主要介绍一些概念性的东西和最佳实践 producer 同步模式 public static void main(String[] args) throws MQClientException ...
RocketMQ入门 在工作中只是简单的使用了一下kafka进行系统间的交互,并未系统化的学习过消息队列这个中间件。基于开源MQ项目的一个活跃度,选择阿里开源出来的RocketMQ来进行学习,再来就是RocketMQ本身也是用java语言进行开发的一个项目。 安装 安装前提 需要拥有以下软件: 操作系统(推荐使用64位) jdk1.8 (推荐使用64位的) Maven 3.2x Git 4G以上...
读书列表 正在读 名称 状态 《现代操作系统-原理与实现》 ing 读过 名称 状态 《重构–改善既有代码的设计》 end 《大话设计模式》 end 《RocketMQ实战与原理解析》 end 《Spring Cloud与Docker微服务架构实战》 end 《MySQL技术内幕.InnoDB存储引擎》 end 《Effective Java中...
基本数据结构 类型 特点 string 字符串 list 列表 set 不重复列表 hash 哈希 zset 有序集合 Redis中的hash是渐进式hash,不会在扩容时暂停,而是会重新创建一个新的hash来保存 基础操作 字符串 序号 命令 功能 示例 1 SET key value [EX seconds|PX milliseconds|KE...
MyBatis的插件机制源代码解析 MyBatis插件机制主要从插件的执行流程来进行分析,分别是查找/注册阶段,包装阶段,执行阶段和扩展点来分析 查找/注册MyBatis插件阶段 org.apache.ibatis.session.Configuration#addInterceptor 是使用Configuration#addInterceptor将插件注册到InterceptorChain...
mybatis方法重载问题 在mapper接口中不能重载方法,网上解释大部分的原因是因为mybatis使用package+Mapper+method全限名作为key,在xml中去寻找唯一的sql来执行时候会发生冲突。 以上这样原因的解释是正确的,但是现在网上对这个结果的描述是在启动时会抛出异常,在mybatis-spring-boot-starter.2.1.0的版本中并未发现异常,查看源代码发现...