① rocketMQ如何设置消费线程数
能选择的有三种：1. ActiveMQ/ApolloMQ优点：老牌的消息队列，使用java语言编写。对JMS支持最好，采用多线程并发，资源消耗比较大。如果你的主语言是Java，可以重点考虑。缺点：由于历史悠久，历史包袱较多，版本更新很缓慢。集群模式需要依赖Zookeeper实现。最新架构的产品被命名为Apollo，号称下一代ActiveMQ，目前案例较少。2. RocketMQ/Kafka优点：专为海量消息传递打造，主张使用拉模式，天然的集群、HA、负载均衡支持。话说还是那句话，适合不适合看你有没有那么大的量。缺点：所谓鱼和熊掌不可兼得，放弃了一些消息中间件的灵活性，使用的场景较窄，需关注你的业务模式是否契合，否则山寨变相使用很别扭。除此之外，RocketMQ没有.NET下的客户端可用。RocketMQ身出名门，但使用者不多，生态较小，毕竟消息量能达到这种体量的公司不多，你也可以直接去购买阿里云的消息服务。Kafka生态完善，其代码是用Scala语言写成，可靠性比RocketMQ低一些。3. RabbitMQ
② rocketmq 发送失败一般怎么处理
一：RocketMQ简介RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点：1.能够保证严格的消息顺序2.提供丰富的消息拉取模式3.高效的订阅者水平扩展能力4.实时的消息订阅机制5.亿级消息堆积能力二：安装RocketMQ下载源码首先我们从githup上获取RocketMQ的源码，目前最新的版本为3.5.8，下载地址为： 或者 wget /alibaba/RocketMQ/archive/v3.5.8.tar.gz。请注意：此时我们下载的是源码，直接解压时不能用的，所以我们需要编译之后才能使用。编译源码在进行编译源码之前我们需要安装JDK。如果你已经安装过了，请跳过这里。如果你还没有安装过JDK，请参考这篇文章（linux环境下安装JDK）。然后我们还需要安装一下Maven。Maven的安装还是比较简单，只需要去官方上下载的安装吧，然后直接解压，再配置一下环境变量就OK。接下来我们把刚才下载来的RockeMQ的源码解压到/usr/local/rockemq-source文件夹中。在源码中有一个Install.sh。如图所示：。运行sh install.sh。在编译完成之后，我们只要target目录下的alibaba-rocketmq这个文件夹中内容，把alibaba-rocketmq文件夹中的内容移动到/usr/local/rocketmq中。如果你不想编译的话，可以从这里下载编译之后的rocketmq。(rocketmq3.5.8)。配置环境变量接下来我们需要配置一下环境变量。在终端中输入以下命令：vi /etc/profile ，在文件的末尾中添加如下两句话：export rocketmq=/usr/local/rocketmq export PATH=$PATH:$rocketmq/bin。接下来我们使配置的换将变量生效：source /etc/profile.三：启动RocketMQ接下来我们启动一下刚才编译的RocketMQ.在启动之前我们需要修改一下RocketMQ启动的内存大小（如果你的系统内存比较大的话，请忽略）。我们进入到/usr/local/rocketmq/bin中，在终端中输入以下命令修改mqnamesrv的内存大小：vi runserver.sh.修改为如图的内容：，接下来修改broker的内存大小：vi runbroker.sh：启动mqnameserver进入到/usr/local/rocketmq/bin中输入以下命令：nohup sh mqnamesrv > ~/logs/rocketmqlogs/namesrv.log 2>&1 &。注意最后的这个 & 不要少。启动mqbroker进入到/usr/local/rocketmq/bin中输入以下命令：nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > ~/logs/rocketmqlogs/broker.log 2>&1 &。注意：localhost可以换成你刚才启动mqnamesrv的IP。autoCreateTopicEnable=true 这句话不要少了。最后的 & 也不要少了。我们可以通过 ps aux | grep java命令来查看启动的情况。到此，rocketmq的安装完毕。四：RocketMQ的小例子procer：[java] view plain package com.zkn.newlearn.rocketmq; import com.alibaba.rocketmq.client.exception.MQBrokerException; import com.alibaba.rocketmq.client.exception.MQClientException; import com.alibaba.rocketmq.client.procer.DefaultMQProcer; import com.alibaba.rocketmq.client.procer.SendResult; import com.alibaba.rocketmq.common.message.Message; import com.alibaba.rocketmq.remoting.exception.RemotingException; import java.util.concurrent.TimeUnit; /** * Created by zkn on 2016/10/27. */ public class ProcerTest01 { public static void main(String[] args) { /** * 一个应用创建一个Procer，由应用来维护此对象，可以设置为全局对象或者单例<br> * 注意：ProcerGroupName需要由应用来保证唯一<br> * ProcerGroup这个概念发送普通的消息时，作用不大，但是发送分布式事务消息时，比较关键， * 因为服务器会回查这个Group下的任意一个Procer */ DefaultMQProcer procer = new DefaultMQProcer("ProcerGroupName"); //procer.setNamesrvAddr("192.168.180.1:9876"); procer.setNamesrvAddr("192.168.180.133:9876"); procer.setInstanceName("Procer"); /** * Procer对象在使用之前必须要调用start初始化，初始化一次即可<br> * 注意：切记不可以在每次发送消息时，都调用start方法 */ try { procer.start(); } catch (MQClientException e) { e.printStackTrace(); } for (int i = 0; i < 100; i++) { try { /** * 下面这段代码表明一个Procer对象可以发送多个topic，多个tag的消息。 * 注意：send方法是同步调用，只要不抛异常就标识成功。但是发送成功也可会有多种状态，<br> * 例如消息写入Master成功，但是Slave不成功，这种情况消息属于成功，但是对于个别应用如果对消息可靠性要求极高，<br> * 需要对这种情况做处理。另外，消息可能会存在发送失败的情况，失败重试由应用来处理。 */ { Message msg = new Message("TopicTest1",// topic "TagA",// tag "OrderID001",// key ("Hello MetaQ").getBytes());// body SendResult sendResult = procer.send(msg); System.out.println(sendResult); } { Message msg = new Message("TopicTest2", "TagB", "OrderID001", ("Hello MetaQ TagB".getBytes())); SendResult sendResult = procer.send(msg); System.out.println(sendResult); } { Message msg = new Message("TopicTest3", "TagC", "OrderID001", ("Hello MetaQ TagC").getBytes()); SendResult sendResult = procer.send(msg); System.out.println(sendResult); } TimeUnit.MILLISECONDS.sleep(1000); } catch (MQClientException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } catch (RemotingException e) { e.printStackTrace(); } catch (MQBrokerException e) { e.printStackTrace(); } } /** * 应用退出时，要调用shutdown来清理资源，关闭网络连接，从MetaQ服务器上注销自己 * 注意：我们建议应用在JBOSS、Tomcat等容器的退出销毁方法里调用shutdown方法 */ procer.shutdown(); } }
③ rocketmq 10911端口的ip怎么修改
在你启动的broker时，使用的配置文件中加listenPort=10911，将10911修改为你想要的端口号就好了。
④ RocketMQ怎么安装，需要git，Java，Maven环境
安装 Maven 之前要求先确定你的 JDK 已经安装配置完成。Maven是 Apache 下的一个项目，目前最新版本是 3.1.0，我用的也是这个。首先去官网下载 Maven下载完成之后将其解压，我将解压后的文件夹重命名成 maven，并将它放在 D:\Server 目录下，即 maven 最终的路径是：D:\Server\maven配置 maven 环境变量：系统变量：MAVEN_HOME = D:\Server\maven用户变量：path = %MAVEN_HOME%\bin相信大家都有配过环境变量的，详细步骤就不说了，对着把属性名和属性值配上的OK了。
⑤ rocketmq的9876端口可以改吗
⑥ rocketmq默认使用哪个配置文件
// 指定配置文件 if (commandLine.hasOption(‘c‘)) { String file = commandLine.getOptionValue(‘c‘); if (file != null) { configFile = file; InputStream in = new BufferedInputStream(new FileInputStream(file)); properties = new Properties(); properties.load(in); MixAll.properties2Object(properties, brokerConfig); MixAll.properties2Object(properties, nettyServerConfig); MixAll.properties2Object(properties, nettyClientConfig);
⑦ 如何配置rockmq占用内存的大小
典型JVM参数设置： java -Xmx3550m -Xms3550m -Xmn2g -Xss128k -Xmx3550m：设置JVM用内存3550M -Xms3550m：设置JVM促使内存3550m值设置与-Xmx相同避免每垃圾收完JVM重新配内存 -Xmn2g：设置轻代2G整堆=轻代 + 代 + 持久代持久代般固定64m所增轻代减代值系统性能影响较Sun官推荐配置整堆3/8 -Xss128k：设置每线程堆栈JDK5.0每线程堆栈1M前每线程堆栈256K更具应用线程所需内存进行调整相同物理内存减值能更线程操作系统进程内线程数限制能限经验值3000~5000左右java -Xmx3550m -Xms3550m -Xss128k -XX:NewRatio=4 -XX:SurvivorRatio=4 -XX:MaxPermSize=16m -XX:MaxTenuringThreshold=0 -XX:NewRatio=4:设置轻代（包括Eden两Survivor区）与代比值（除持久代）设置4则轻代与代所占比值1：4轻代占整堆栈1/5 -XX:SurvivorRatio=4：设置轻代Eden区与Survivor区比值设置4则两Survivor区与Eden区比值2:4Survivor区占整轻代1/6 -XX:MaxPermSize=16m:设置持久代16m
⑧ rocketmqbroker默认accesskey
本来这个错误是很简单的错误，本意是mq上边开启了acl验证机制，而客户端没有配置accessKey。配置mq的broker和plain_acl两个配置文件，客户端加入acl相关代码，主要是加入了AclRPCHook，在发送消息之前插入accessKey和签名供mq进行校验。之后用测试工程引用本地maven库上安装的rocket工具库进行测试，结果之前能用的代码在用了acl之后一直报错：提示accessKey没配置。
⑨ 怎么指定rocketmq的jdk
一：RocketMQ简介RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点：1.能够保证严格的消息顺序2.提供丰富的消息拉取模式3.高效的订阅者水平扩展能力4.实时的消息订阅机制5.亿级消息堆积能力二：安装RocketMQ下载源码首先我们从githup上获取RocketMQ的源码，目前最新的版本为3.5.8，下载地址为：或者wget/alibaba/RocketMQ/archive/v3.5.8.tar.gz。请注意：此时我们下载的是源码，直接解压时不能用的，所以我们需要编译之后才能使用。编译源码在进行编译源码之前我们需要安装JDK。如果你已经安装过了，请跳过这里。如果你还没有安装过JDK，请参考这篇文章（Linux环境下安装JDK）。然后我们还需要安装一下Maven。Maven的安装还是比较简单，只需要去官方上下载的安装吧，然后直接解压，再配置一下环境变量就OK。接下来我们把刚才下载来的RockeMQ的源码解压到/usr/local/rockemq-source文件夹中。在源码中有一个Install.sh。如图所示：。运行shinstall.sh。在编译完成之后，我们只要target目录下的alibaba-rocketmq这个文件夹中内容，把alibaba-rocketmq文件夹中的内容移动到/usr/local/rocketmq中。如果你不想编译的话，可以从这里下载编译之后的rocketmq。(rocketmq3.5.8)。配置环境变量接下来我们需要配置一下环境变量。在终端中输入以下命令：vi/etc/profile，在文件的末尾中添加如下两句话：exportrocketmq=/usr/local/rocketmqexportPATH=$PATH:$rocketmq/bin。接下来我们使配置的换将变量生效：source/etc/profile.三：启动RocketMQ接下来我们启动一下刚才编译的RocketMQ.在启动之前我们需要修改一下RocketMQ启动的内存大小（如果你的系统内存比较大的话，请忽略）。我们进入到/usr/local/rocketmq/bin中，在终端中输入以下命令修改mqnamesrv的内存大小：virunserver.sh.修改为如图的内容：，接下来修改broker的内存大小：virunbroker.sh：启动mqnameserver进入到/usr/local/rocketmq/bin中输入以下命令：nohupshmqnamesrv>~/logs/rocketmqlogs/namesrv.log2>&1&。注意最后的这个&不要少。启动mqbroker进入到/usr/local/rocketmq/bin中输入以下命令：nohupshmqbroker-nlocalhost:9876autoCreateTopicEnable=true>~/logs/rocketmqlogs/broker.log2>&1&。注意：localhost可以换成你刚才启动mqnamesrv的IP。autoCreateTopicEnable=true这句话不要少了。最后的&也不要少了。我们可以通过psaux|grepjava命令来查看启动的情况。到此，rocketmq的安装完毕。四：RocketMQ的小例子procer：[java]viewplainpackagecom.zkn.newlearn.rocketmq;importcom.alibaba.rocketmq.client.exception.MQBrokerException;importcom.alibaba.rocketmq.client.exception.MQClientException;importcom.alibaba.rocketmq.client.procer.DefaultMQProcer;importcom.alibaba.rocketmq.client.procer.SendResult;importcom.alibaba.rocketmq.common.message.Message;importcom.alibaba.rocketmq.remoting.exception.RemotingException;importjava.util.concurrent.TimeUnit;/***Createdbyzknon2016/10/27.*/publicclassProcerTest01{publicstaticvoidmain(String[]args){/***一个应用创建一个Procer，由应用来维护此对象，可以设置为全局对象或者单例*注意：ProcerGroupName需要由应用来保证唯一*ProcerGroup这个概念发送普通的消息时，作用不大，但是发送分布式事务消息时，比较关键，*因为服务器会回查这个Group下的任意一个Procer*/DefaultMQProcerprocer=newDefaultMQProcer("ProcerGroupName");//procer.setNamesrvAddr("192.168.180.1:9876");procer.setNamesrvAddr("192.168.180.133:9876");procer.setInstanceName("Procer");/***Procer对象在使用之前必须要调用start初始化，初始化一次即可*注意：切记不可以在每次发送消息时，都调用start方法*/try{procer.start();}catch(MQClientExceptione){e.printStackTrace();}for(inti=0;i<100;i++){try{/***下面这段代码表明一个Procer对象可以发送多个topic，多个tag的消息。*注意：send方法是同步调用，只要不抛异常就标识成功。但是发送成功也可会有多种状态，*例如消息写入Master成功，但是Slave不成功，这种情况消息属于成功，但是对于个别应用如果对消息可靠性要求极高，*需要对这种情况做处理。另外，消息可能会存在发送失败的情况，失败重试由应用来处理。*/{Messagemsg=newMessage("TopicTest1",//topic"TagA",//tag"OrderID001",//key("HelloMetaQ").getBytes());//bodySendResultsendResult=procer.send(msg);System.out.println(sendResult);}{Messagemsg=newMessage("TopicTest2","TagB","OrderID001",("HelloMetaQTagB".getBytes()));SendResultsendResult=procer.send(msg);System.out.println(sendResult);}{Messagemsg=newMessage("TopicTest3","TagC","OrderID001",("HelloMetaQTagC").getBytes());SendResultsendResult=procer.send(msg);System.out.println(sendResult);}TimeUnit.MILLISECONDS.sleep(1000);}catch(MQClientExceptione){e.printStackTrace();}catch(InterruptedExceptione){e.printStackTrace();}catch(RemotingExceptione){e.printStackTrace();}catch(MQBrokerExceptione){e.printStackTrace();}}/***应用退出时，要调用shutdown来清理资源，关闭网络连接，从MetaQ服务器上注销自己*注意：我们建议应用在JBOSS、Tomcat等容器的退出销毁方法里调用shutdown方法*/procer.shutdown();}}
⑩ rocketmq单个机器怎么搭建集群在linux
linux服务器集群平台的搭建比较简单，有专门的均衡软件，比如lvs，lvs是一个集群系统，由很多服务器组成，可以根据需要，把它门分为三层，一层是前端机，用于均衡，相当于公平为系统分配工作，二层是服务器群，比如web服务器群，DNS，mail群等，这些就是接待员，把均衡器分配的工作进行处理，第三层是存储设备，用于存储数据，相当于档案库。知道这些后，要搭建就非常容易，有现成的软件，比如我有四台web服务器，2台数据库，1台前置机 ，安装linux系统，安装lvs软件，比如heartbeat-2.1.4-9.el5.i386.rpmheartbeat-ldirectord-2.1.4-9.el5.i386.rpmlibnet-1.1.4-3.el5.i386.rpmheartbeat-devel-2.1.4-9.el5.i386.rpmheartbeat-pils-2.1.4-10.el5.i386.rpmperl-MailTools-1.77-1.el5.noarch.rpmheartbeat-gui-2.1.4-9.el5.i386.rpmheartbeat-stonith-2.1.4-10.el5.i386.rpm当然还需要配置，你可以自己网络有关lvs集群的详细安装说明。希望能帮助你。
