rocketmq 定时消息如何保证此消息只能被消费一次

&&国之画&&布布分享&&&& &&&&
版权所有 京ICP备号-2
迷上了代码!&&&&消息中间件rocketmq原理解析
消息中间件rocketmq原理解析
此文档是从学习rocketmq源码过程中的笔记中整理出来的,由于时间及能力原因,理解有误之处还请谅解,希望对大家学习使用rocketmq有所帮助。
嵌到我的页面
<input type="text" readonly="true" value="">
若举报审核通过,可奖励20下载分
被举报人:
举报的资源分:
请选择类型
资源无法下载
资源无法使用
标题与实际内容不符
含有危害国家安全内容
含有反动色情等内容
含广告内容
版权问题,侵犯个人或公司的版权
*详细原因:
VIP下载&&免积分60元/年(1200次)
您可能还需要
开发技术下载排行&&国之画&&&& &&&&&&
&& &&&&&&&&&&&&&&&&&&&&
鲁ICP备号-4
打开技术之扣,分享程序人生!RocketMQ消息队列简单部署
RocketMQ 是alibaba开源的消息队列。本文使用的是开源版本v3.18
系统: CentOS 6.x最小化安装
需要用到的软件包:
jdk-7u67-linux-x64.tar.gz
alibaba-rocketmq-3.1.8.tar.gz
#tar xvf jdk-7u67-linux-x64.tar.gz -C /opt/
#tar xvf alibaba-rocketmq-3.1.8.tar.gz -C /opt/
#ln -s /opt/jdk1.7.0_67 /opt/jdk
配置环境变量
在/etc/profile最后添加
export JAVA_HOME=/opt/jdk
export PATH=$JAVA_HOME/bin:$PATH
使变量生效
source /etc/profile
# java -version
java version &1.7.0_67&
Java(TM) SE Runtime Environment (build 1.7.0_67-b01)
Java HotSpot(TM) 64-Bit Server VM (build 24.65-b04, mixed mode)
启动nameserver
#cd /opt/alibaba-rocketmq/bin/
#nohup sh mqnamesrv &
验证nameserver是否启动
# tail -f nohup.out
The Name Server boot success.
启动broker
在启动borker之前需要指点nameserver
#export NAMESRV_ADDR=Your_IP:9876
#cd /opt/alibaba-rocketmq/bin/
#nohup sh mqbroker &
验证mqbroker是否启动
# tail -f nohup.out
The broker[Your_hostname, Your_IP:10911] boot success. and name server is Your_IP:9876
最后配置防火墙
nameserver端口为9876
broker端口为10911
lokkit -p 9876:tcp -p 10911:tcp
关闭nameserver broker
#/opt/alibaba-rocketmq/bin/
#sh mqshutdown namesrv
#sh mqshutdown broker
至此 RockerMQ 安装完毕。
参考:/alibaba/RocketMQ
------分隔线----------------------------}

我要回帖

更多关于 rocketmq 消息堆积 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信