2018年(273)
分类: Java
2018-08-13 11:24:04
最近在看消息队列框架 ,alibaba的RocketMQ单机支持1万以上的持久化队列,支持诸多特性,
目前RocketMQ在阿里集团被广泛应用在订单,交易,充值,流计算,消息推送,日志流式处理,binglog分发等场景
比kafka还是有过之无不及,其实kafka文档很丰富
但RocketMQ网上的文章太少,找不到相关的操作教程
于是研究了下源码 做个单机操作的教程,如果你也对此有兴趣不妨共同研究
下载源码的地址
首选通过在java项目里面Maven依赖方式引用RocketMQ Java SDK
<dependency> <groupId>com.alibaba.rocketmqgroupId> <artifactId>rocketmq-clientartifactId> <version>3.2.6version> dependency>
在linux 下用wget 下载源码然后解压出来
在runserver.sh里面可以配置 jvm启动的参数 JAVA_OPT_1="-server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m"