linux 下安装部署mq,RocketMQ在linux下安装部署
本博客以當前RocketMQ最新版介紹：v4.4.0
環境要求
64位JDK 1.8+;
Maven 3.2.x; // 源碼編譯時需要用到
二進制文件安裝
> unzip rocketmq-all-4.4.0-bin-release.zip && mv rocketmq-all-4.4.0-bin-release rocketmq
啟動server
> cd /root/rocketmq
> nohup sh bin/mqnamesrv & // 第一次安裝時，可執行sh bin/mqnamesrv觀察是否能夠啟動
> tailf -f ~/logs/rocketmqlogs/namesrv.log
// 觀察到以下日志時，server已啟動成功
2019-09-07 18:06:13 INFO main - The Name Server boot success. serializeType=JSON
啟動broker
> nohup sh bin/mqbroker -n localhost:9876
> tailf -f ~/logs/rocketmqlogs/broker.log
// 觀察到以下日志時，server已啟動成功
2019-09-07 20:40:06 INFO main - The broker[0daf9bd41237, 172.17.0.2:10911] boot success. serializeType=JSON and name server is 172.17.0.2:9876
注：broker啟動如果過一會直接退出，無任何日志或報錯的話，檢查一下機子的內存是否充足。RocketMQ的broker默認內存為8g。
修改文件：/root/rocketmq/bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"
測試生產者和消費者
// 在測試之前，我們需要先設置環境變量：export NAMESRV_ADDR=localhost:9876
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...
Producer的源碼
public class Producer {
public static void main(String[] args) throws MQClientException, InterruptedException {
// 默認消費組
DefaultMQProducer producer = new DefaultMQProducer("default");
producer.start();
for (int i = 0; i < 1000; i++) {
try {
Message msg = new Message("TopicTest" /* Topic */,
"TagA" /* Tag */,
("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
);
// 消息發送
SendResult sendResult = producer.send(msg);
System.out.printf("%s%n", sendResult);
} catch (Exception e) {
e.printStackTrace();
Thread.sleep(1000);
}
}
// 關閉生產者
producer.shutdown();
}
}
Consumer的源碼
public class Consumer {
public static void main(String[] args) throws InterruptedException, MQClientException {
// 指定消費組
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("default");
// 設置消費偏移點
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
// 訂閱topic，以及tag
consumer.subscribe("TopicTest", "*");
// 注冊消息監聽器
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List msgs,
ConsumeConcurrentlyContext context) {
System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
// 收到數據后，返回ack確認
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
consumer.start();
System.out.printf("Consumer Started.%n");
}
}
關閉server和broker
> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
linux下安裝部署ansible
linux下安裝部署ansible 介紹 Ansible是一種批量部署工具,現在運維人員用的最多的三種開源集中化管理工具有:puppet,saltstack,ansible,各有各的優缺點,其中sal ...
Linux下安裝部署Samba共享盤的操作手冊
簡述 Samba是在Linux和UNIX系統上實現SMB協議的一個免費軟件,由服務器及客戶端程序構成.SMB(Server Messages Block,信息服務塊)是一種在局域網上共享文件和打印機的 ...
linux下安裝部署環境：jdk、tomcat、nginx
一.安裝jdk 一.查看Linux自帶的JDK是否已安裝 1.查看已經安裝的jdk: # rpm -qa|grep jdk??????????????? ← 查看jdk的信息或直接執行 或 # rpm ...
今日Linux下安裝部署禪道
我的linux系統是在虛擬機上安裝的Ubuntu,禪道在官網www.zentao.net下載安裝的開源版的linux64位,采用一鍵安裝包安裝.安裝前要求:系統上不能有自己安裝的mysql .下載的安 ...
Linux下安裝部署RabbitMQ
在寫正文之前先啰嗦幾句,RabbitMQ(消息隊列)的安裝讓我費了半天勁啊!足足折騰了2天,最后寫下這篇文章總結下,其實很簡單,但是你找不到錯在哪個環節就會費很多無用功,如果你也遇到了安裝erl后 怎 ...
jenkins在Linux 下安裝部署
這里介紹兩種方法,一種方法將最新版jenkins加入到yum源,另外一種是下載指定版本的rpm包 系統centos6 自帶jdk1.7 一 安裝jenkins wget -O :下載并以不同的文件 ...
Linux下安裝部署Java
Java安裝6小部(適合新手) 1.下載軟件包 # wget http://download.oracle.com/otn-pub/java/jdk/7u79-b15/jdk-7u79-linux-x ...
mysql linux下安裝部署
一.安裝簡介 用戶名:mysql安裝目錄:/usr/local/mysql-5.5數據庫目錄:/data/mysql/data源碼包:mysql-5.5.28.tar.gz 二.安裝準備 a.vi / ...
隨機推薦
SSO單點登錄實現原理與總結
一.什么是單點登錄SSO(Single Sign-On) SSO是一種統一認證和授權機制,指訪問同一服務器不同應用中的受保護資源的同一用戶,只需要登錄一次,即通過一個應用中的安全驗證后,再訪問其他應用 ...
MAC OS Finder 中快速定位指定路徑
在看一些 tip 文章的時候,時不時會有需要進到某某目錄替換文件之類的步驟.如果碰上這個目錄層次夠多,一層一層的點擊既麻煩又容易出錯,有什么快捷的辦法呢? 快捷鍵:Shift + Command + ...
MySQL語句45道練習題及答案
一.??????????? 設有一數據庫,包括四個表:學生表(Student).課程表(Course).成績表(Score)以及教師信息表(Teacher).四個表的結構分別如表1-1的表(一)~表( ...
四大機器學習降維算法：PCA、LDA、LLE、Laplacian Eigenmaps
四大機器學習降維算法:PCA.LDA.LLE.Laplacian Eigenmaps 機器學習領域中所謂的降維就是指采用某種映射方法,將原高維空間中的數據點映射到低維度的空間中.降維的本質是學習一個映 ...
js混淆工具
1\ ?http://www.jasob.com 2\?http://developer.yahoo.com/yui/compressor
廣告系統中weak-and算法原理及編碼驗證
wand(weak and)算法基本思路 一般搜索的query比較短,但如果query比較長,如是一段文本,需要搜索相似的文本,這時候一般就需要wand算法,該算法在廣告系統中有比較成熟的應 該,主要 ...
JSP出現中文亂碼問題
今天糾結了好半天,本地運行程序后沒有中文亂碼,唯獨發到服務器后運行出現了亂碼. 究其原因,皆因eclipse環境默認的JSP編碼是Iso-8859-1,需要將其改為utf-8,與JSP文件中的編碼聲明 ...
Windows10下通過anaconda安裝tensorflow
博主經歷了很多的坎坷磨難才找到一個比較好的在win10下安裝TensorFlow的方法: 首先需要說明的是如果你想通過Anaconda來安裝tensorflow的話,首先要確認你的python的版本是 ...
java 獲得當前時間前指定幾個小時的時間？
//@2016-12-13 獲取當前時間,指定前面多少小時的時間 //返回格式YYYYMMDDHHMMSS public static String getBeforeHourTime(int iho ...
R猜拳游戲解釋
R猜拳游戲解釋 作者:梁 蓉 猜拳游戲大概解釋: 搜集齊數據框,for循環在三個隨機數里抽倆個,抽出的數據放回,繼續抽取剪刀石頭布,機器人出剪刀石頭布,我出對應壓制機器人的方法來贏取勝利,我給機器人發 ...
總結
以上是生活随笔為你收集整理的linux 下安装部署mq,RocketMQ在linux下安装部署的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 程序设计基础是C语言吗,程序设计基础（C
- 下一篇： Linux总线设备驱动框架的理解（非常棒