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

Sharktech10Gbps带宽,不限制流量,自带5个IPv4,100G防御

Sharktech荷兰10G带宽的独立服务器月付319美元起,10Gbps共享带宽,不限制流量,自带5个IPv4,免费60Gbps的 DDoS防御,可加到100G防御。CPU内存HDD价格购买地址E3-1270v216G2T$319/月链接E3-1270v516G2T$329/月链接2*E5-2670v232G2T$389/月链接2*E5-2678v364G2T$409/月链接这里我们需要注意,默...

老薛主机VPS年付345元,活动进行时。

老薛主机,虽然是第一次分享这个商家的信息,但是这个商家实际上也有存在有一些年头。看到商家有在进行夏季促销,比如我们很多网友可能有需要的香港VPS主机季度及以上可以半价优惠,如果有在选择不同主机商的香港机房的可以看看老薛主机商家的香港VPS。如果没有记错的话,早年这个商家是主营个人网站虚拟主机业务的,还算不错在异常激烈的市场中生存到现在,应该算是在众多商家中早期积累到一定的用户群的,主打小众个人网站...

HostKvm香港VPS七折:$5.95/月KVM-2GB内存/40GB硬盘/500GB月流量

HostKvm是一家成立于2013年的国外主机服务商,主要提供VPS主机,基于KVM架构,可选数据中心包括日本、新加坡、韩国、美国、俄罗斯、中国香港等多个地区机房,均为国内直连或优化线路,延迟较低,适合建站或者远程办公等。商家本月针对香港国际机房提供特别7折优惠码,其他机房全场8折,优惠后2G内存香港VPS每月5.95美元起,支持使用PayPal或者支付宝付款。下面以香港国际(HKGlobal)为...

rocketmq为你推荐
初始化磁盘win10新装硬盘初始化?provisionedNIST的云计算定义订单详情淘宝购物记录具体指什么?是订单详情还是交易聊天记录???战棋类推荐几个好玩的战棋类的游戏最好的视频播放器现在最好的播放器 是什么呀赵锡成赵锡成夫人简介充值卡充值充值卡怎么充值游戏充值卡充值移动手机充值卡如何充值?没有nvidia控制面板电脑没有nvidia显卡控制面板是怎么回事网站维护收费网站一般每年的维修服务费用是多少啊?
绍兴服务器租用 西安服务器 z.com 外国服务器 美国php主机 密码泄露 seovip 免费mysql 腾讯云分析 韩国名字大全 傲盾官网 创建邮箱 免费邮件服务器 德隆中文网 群英网络 免费稳定空间 hosting24 月付空间 免费网站加速 windowsserver2012 更多