本月博客排行
-
第1名
龙儿筝 -
第2名
johnsmith9th -
第3名
wy_19921005 - zysnba
- sgqt
- lemonhandsome
年度博客排行
-
第1名
宏天软件 -
第2名
青否云后端云 -
第3名
龙儿筝 - gashero
- wallimn
- vipbooks
- benladeng5225
- wy_19921005
- fantaxy025025
- qepwqnp
- e_e
- 解宜然
- zysnba
- ssydxa219
- sam123456gz
- javashop
- arpenker
- tanling8334
- kaizi1992
- xpenxpen
- gaojingsong
- wiseboyloves
- xiangjie88
- ranbuijj
- ganxueyun
- sichunli_030
- xyuma
- wangchen.ily
- jh108020
- lemonhandsome
- zxq_2017
- jbosscn
- Xeden
- luxurioust
- lzyfn123
- zhanjia
- forestqqqq
- johnsmith9th
- nychen2000
- ajinn
- wjianwei666
- hanbaohong
- daizj
- 喧嚣求静
- mwhgJava
- silverend
- kingwell.leng
- lchb139128
- lich0079
- kristy_yy
最新文章列表
Spring Cloud(11)——基于RocketMQ的Stream实现
基于RocketMQ的Stream实现
Spring Cloud Stream是一个消息收发的框架,它提供了一套标准,应用程序只需要按照它的标准进行消息的收发,而不用关注具体的实现机制。具体的实现可以基于不同的消息中间件进行不同的实现,比如Kafka的实现、RabbitMQ的实现、RocketMQ的实现等。官方已经提供了Kafka和RabbitMQ的实现,RocketMQ的实现由Alibaba负 ...
项目中使用消息队列的原因
为什么要使用消息队列
做过互联网企业级应用开发的同学们,不管是在大厂的还是在小厂的,都会知道或熟悉消息队列。那么,在做企业级应用开发的过程中,为啥需要用消息队列呢?下面是小弟在日常工作中整理出来的心得,希望能帮助有需要的同学。
在正常的项目中使用消息队列,主要是为了以下三种场景:解耦,异步,削峰。下面分别针对这三种场景,做下简单的描述。
1 ...
RocketMQ与Kafka对比
淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件,使用Mysql作为消息存储媒介,可完全水平扩容,为了进一步降低成本,我们认为存储部分可以进一步优化,2011年初,Linkin开源了Kafka这个优秀的消息中间件,淘宝中间件团队在对Kafka做过充分Review之后,Kafka无限消息堆积,高效的持久化速度吸引了我们,但是同时发现这个消息系统主要定位于日志传输,对于使用在淘 ...
IBM MQ8.0的新特性
在mq8上的变化,里面有关于API的
https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.pro.doc/q001060_.htm
mq8上的新特性如下:https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.pro.doc/q11 ...
IBM MQ官方错误对照表
https://www.ibm.com/support/knowledgecenter/SSFKSJ_7.0.1/com.ibm.mq.amqzao.doc/fm12040_.htm
Subtopics
0 (0000) (RC0): MQRC_NONE
900 (0384) (RC900): MQRC_APPL_FIRST
999 (03E7) (RC999): MQR ...
MQ客户端
public class mqSendSample {
@SuppressWarnings("rawtypes")
private static Hashtable<String, Comparable> env = new Hashtable<String, Comparable>();
// 队列管理器名
private static Str ...
RocketMQ自定义selector实现消息通道定向发送和拉取
RocketMQ的安装部署请参考官网Quick Start
RocketMQ的简单应用请参考官网github样例
本篇介绍如何通过自定义selector实现按messageQueue定向发送和接收消息
我们先看看MessageQueueSelector接口
public interface MessageQueueSelector {
MessageQueue select ...