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

ReliableSite:美国服务器租用,洛杉矶/纽约/迈阿密等机房;E3-1240V6/64GB/1TSSD,$95/月

reliablesite怎么样?reliablesite是一家于2006年成立的老牌美国主机商,主要提供独服,数据中心有迈阿密、纽约、洛杉矶等,均免费提供20Gbps DDoS防护,150TB月流量,1Gbps带宽。月付19美金可升级为10Gbps带宽。洛杉矶/纽约/迈阿密等机房,E3-1240V6/64GB内存/1TB SSD硬盘/DDOS/150TB流量/1Gbps带宽/DDOS,$95/月,...

Stablehost 美国主机商黑五虚拟主机四折

如今我们网友可能较多的会选择云服务器、VPS主机,对于虚拟主机的话可能很多人不会选择。但是我们有些外贸业务用途的建站项目还是会有选择虚拟主机的。今天看到的Stablehost 商家虚拟主机在黑五期间也有四折优惠,对于这个服务商而言不是特别的喜欢,虽然他们商家和我们熟悉的老鹰主机商有些类似,且在后来老鹰主机改版和方案后,Stablehost 商家也会跟随改版,但是性价比认为不如老鹰主机。这次黑色星期...

华为云(69元)828促销活动 2G1M云服务器

华为云818上云活动活动截止到8月31日。1、秒杀限时区优惠仅限一单!云服务器秒杀价低至0.59折,每日9点开抢秒杀抢购活动仅限早上9点开始,有限量库存的。2G1M云服务器低至首年69元。2、新用户折扣区优惠仅限一单!购云服务器享3折起加购主机安全及数据库。企业和个人的优惠力度和方案是不同的。比如还有.CN域名首年8元。华为云服务器CPU资源正常没有扣量。3、抽奖活动在8.4-8.31日期间注册并...

rocketmq为你推荐
波浪号用手机怎么打出波浪号hd4600现在英特尔hd4600显卡价格是多少微信红包图片怎么在微信上发发红包才能看的照片blastpblast是什么意思wizardryHogwarts for pikeys是什么意思???wizardry哈利波特里的蛇院,狮院,獾院,鹰院. 分别指什么微店是什么微店和微商有什么区别呢visa信用卡卡号信用卡卡号是多少位数地好用的手机杀毒软件好用的手机杀毒软件程序员段子20、老婆给当程序员的老公打电话:“下班顺路买一斤包子带回来,如果看到卖西瓜的,买一个。”当晚,程序
重庆网站空间 香港服务器租用 vps优惠码cnyvps enzu 搬瓦工官网 外国空间 godaddy 韩国网名大全 hostker isp服务商 免费的asp空间 广州虚拟主机 深圳域名 徐州电信 国外网页代理 买空间网 杭州电信 广东服务器托管 tracker服务器 magento主机 更多