rocketmq如何利用rocketmq做日志记录

rocketmq 同步双写 什么意思

rocket league 4-pack的中文翻译　　rocket league 4-pack　　火箭联赛4包　　-------------------------------如有疑问，可继续追问，如果满意，请采纳，谢谢。

windows怎么监控rocketmq内的消息

有专门开发Windows service的模块。

一旦你部署好了可以安装到windows服务中，那里你能选是否开机启动等。

多查查msdn，学新东西要安下心来，你先掌握了如何开发windows服务

linux怎样知道配置的rocketmq的环境变量是否生效

一：RocketMQ简介 RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点： 1.能够保证严格的消息顺序 2.提供丰富的消息拉取模式 3.高效的订阅者水平扩展能力 4.实时的消息订阅机制 5.亿级消息堆积能力 二：安装RocketMQ 下载源码 首先我们从githup上获取RocketMQ的源码，目前最新的版本为3.5.8，下载地址为：/alibaba/RocketMQ/releases 或者 wget /alibaba/RocketMQ/releases/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的小例子 producer： [java] view plain copy .zkn.newlearn.rocketmq; .alibaba.rocketmq.client.exception.MQBrokerException; .alibaba.rocketmq.client.exception.MQClientException; .alibaba.rocketmq.client.producer.DefaultMQProducer; .alibaba.rocketmq.client.producer.SendResult; mon.message.Message; .alibaba.rocketmq.remoting.exception.RemotingException; import java.util.concurrent.TimeUnit; /** * Created by zkn on 2016/10/27. */ public class ProducerTest01 { public static void main(String[] args) { /** * 一个应用创建一个Producer，由应用来维护此对象，可以设置为全局对象或者单例 * 注意：ProducerGroupName需要由应用来保证唯一 * ProducerGroup这个概念发送普通的消息时，作用不大，但是发送分布式事务消息时，比较关键， * 因为服务器会回查这个Group下的任意一个Producer */ DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName"); //producer.setNamesrvAddr("192.168.180.1:9876"); producer.setNamesrvAddr("192.168.180.133:9876"); producer.setInstanceName("Producer"); /** * Producer对象在使用之前必须要调用start初始化，初始化一次即可 * 注意：切记不可以在每次发送消息时，都调用start方法 */ try { producer.start(); } catch (MQClientException e) { e.printStackTrace(); } for (int i = 0; i < 100; i++) { try { /** * 下面这段代码表明一个Producer对象可以发送多ic，多个tag的消息。

* 注意：send方法是同步调用，只要不抛异常就标识成功。

但是发送成功也可会有多种状态， * 例如消息写入Master成功，但是Slave不成功，这种情况消息属于成功，但是对于个别应用如果对消息可靠性要求极高， * 需要对这种情况做处理。

另外，消息可能会存在发送失败的情况，失败重试由应用来处理。

*/ { Message msg = new Message("TopicTest1",//ic "TagA",// tag "OrderID001",// key ("Hello MetaQ").getBytes());// body SendResult sendResult = producer.send(msg); System.out.println(sendResult); } { Message msg = new Message("TopicTest2", "TagB", "OrderID001", ("Hello MetaQ TagB".getBytes())); SendResult sendResult = producer.send(msg); System.out.println(sendResult); } { Message msg = new Message("TopicTest3", "TagC", "OrderID001", ("Hello MetaQ TagC").getBytes()); SendResult sendResult = producer.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方法 */ producer.shutdown(); } }

activemq消息队列和kafka有什么区别

能选择三种： 　　1. ActiveMQ/ApolloMQ 　　优点：牌消息队列使用Java语言编写JMS支持采用线程并发资源消耗比较主语言Java重点考虑 　　缺点：由于历史悠久历史包袱较版本更新缓慢集群模式需要依赖Zookeeper实现新架构产品命名Apollo号称代ActiveMQ目前案例较少 　　2. RocketMQ/Kafka 　　优点：专海量消息传递打造主张使用拉模式集群、HA、负载均衡支持说句适合适合看没量 　　缺点：所谓鱼熊掌兼放弃些消息间件灵性使用场景较窄需关注业务模式否契合否则山寨变相使用别扭除外RocketMQ没.NET客户端用RocketMQ身名门使用者态较毕竟消息量能达种体量公司直接购买阿云消息服务Kafka态完善其代码用Scala语言写靠性比RocketMQ低些 　　3. RabbitMQ 　　优点：态丰富使用者众前面踩坑AMQP协议领导实现支持种场景淘宝MySQL集群内部使用进行通讯OpenStack源云平台通信组件先金融行业运用 　　缺点：Erlang代码Hold住? 虽Erlang集群化RabbitMQ高用面做起特别应手别相信广告

如何利用rocketmq做日志记录

所有日志名定义 public class LoggerName { public static final String FILTERSRV_LOGGER_NAME = "RocketmqFiltersrv"; public static final String NAMESRV_LOGGER_NAME = "RocketmqNamesrv"; public static final String BROKER_LOGGER_NAME = "RocketmqBroker"; public static final String CLIENT_LOGGER_NAME = "RocketmqClient"; public static final String TOOLS_LOGGER_NAME = "RocketmqTools"; public static final String COMMON_LOGGER_NAME = "RocketmqCommon"; public static final String STORE_LOGGER_NAME = "RocketmqStore"; public static final String STORE_ERROR_LOGGER_NAME = "RocketmqStoreError"; public static final String TRANSACTION_LOGGER_NAME = "RocketmqTransaction"; public static final String REBALANCE_LOCK_LOGGER_NAME = "RocketmqRebalanceLock"; public static final String ROCKETMQ_STATS_LOGGER_NAME = "RocketmqStats"; public static final String COMMERCIAL_LOGGER_NAME = "RocketmqCommercial"; public static final String FLOW_CONTROL_LOGGER_NAME = "RocketmqFlowControl"; public static final String ROCKETMQ_AUTHORIZE_LOGGER_NAME = "RocketmqAuthorize"; public static final String DUPLICATION_LOGGER_NAME = "RocketmqDuplication"; public static final String PROTECTION_LOGGER_NAME = "RocketmqProtection"; public static final String WATER_MARK_LOGGER_NAME = "RocketmqWaterMark"; } 配置 rocketmq.client.log.loadconfig rocketmq.client.log.configFile 日志级别 <Logger name="RocketmqClient" level="WARN"/>