rocketmq如何利用rocketmq做日志记录

rocketmq  时间:2021-08-09  阅读:()

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"/>

火数云-618限时活动,国内云服务器大连3折,限量50台,九江7折 限量30台!

官方网站:点击访问火数云活动官网活动方案:CPU内存硬盘带宽流量架构IP机房价格购买地址4核4G50G 高效云盘20Mbps独享不限openstack1个九江287元/月立即抢购4核8G50G 高效云盘20Mbps独享不限openstack1个九江329元/月立即抢购2核2G50G 高效云盘5Mbps独享不限openstack1个大连15.9元/月立即抢购2核4G50G 高效云盘5Mbps独享不限...

UCloud 618活动:香港云服务器月付13元起;最高可购3年,AMD/Intel系列

ucloud6.18推出全球大促活动,针对新老用户(个人/企业)提供云服务器促销产品,其中最低配快杰云服务器月付5元起,中国香港快杰型云服务器月付13元起,最高可购3年,有AMD/Intel系列。当然这都是针对新用户的优惠。注意,UCloud全球有31个数据中心,29条专线,覆盖五大洲,基本上你想要的都能找到。注意:以上ucloud 618优惠都是新用户专享,老用户就随便看看!点击进入:uclou...

速云:广州移动/深圳移动/广东联通/香港HKT等VDS,9折优惠,最低月付9元;深圳独立服务器1050元/首月起

速云怎么样?速云,国人商家,提供广州移动、深圳移动、广州茂名联通、香港hkt等VDS和独立服务器。现在暑期限时特惠,力度大。广州移动/深圳移动/广东联通/香港HKT等9折优惠,最低月付9元;暑期特惠,带宽、流量翻倍,深港mplc免费试用!点击进入:速云官方网站地址速云优惠码:全场9折优惠码:summer速云优惠活动:活动期间,所有地区所有配置可享受9折优惠,深圳/广州地区流量计费VDS可选择流量翻...

rocketmq为你推荐
安卓模拟器哪个好用手机模拟器哪个好用?求推荐。最好的视频播放器目前最好的视频播放器是什么?rs485协议RS232/RS485串行通信协议的解释赵锡成上海交大有什么好玩的传奇私服教程传奇私服怎么开服教程传奇私服教程怎样开传奇SF?我要具体详细的步骤wifi快速破解器电脑版电脑版,WIFI密码破解软件哪个好?blacken“人非圣贤孰能无过”用英语怎么说asp代码求ASP的代码网页错误详细信息网页错误详细信息 消息: 'this._self.style' 为空或不是对象
网站空间购买 仿牌空间 l5520 账号泄露 日志分析软件 40g硬盘 免费网页空间 drupal安装 联通网站 重庆电信服务器托管 云营销系统 畅行云 cdn网站加速 阿里云手机官网 万网主机 江苏徐州移动 1美元 贵州电信 空间排行榜 建站技术 更多