一、簡(jiǎn)介

創(chuàng)新互聯(lián)是一家專注于網(wǎng)站設(shè)計(jì)制作、成都網(wǎng)站建設(shè)與策劃設(shè)計(jì),饒平網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:饒平等地區(qū)。饒平做網(wǎng)站價(jià)格咨詢:18982081108

METAQ(全稱Metamorphosis)是一款完全的隊(duì)列模型消息中間件，服務(wù)器使用Jave語(yǔ)言編寫(xiě)，可在多種軟硬件平臺(tái)上部署；客戶端支持Java、C++編程語(yǔ)言；單臺(tái)服務(wù)器可支持1萬(wàn)以上個(gè)消息隊(duì)列，通過(guò)擴(kuò)容服務(wù)器，隊(duì)列數(shù)幾乎可以任意橫向擴(kuò)展；每個(gè)隊(duì)列都是持久化、長(zhǎng)度無(wú)限(取決于磁盤(pán)空間大小)、并可從隊(duì)列任意位置開(kāi)始消費(fèi)；

MetaQ是一款分布式、隊(duì)列模型的消息中間件，MetaQ具有消息存儲(chǔ)順序?qū)?、吞吐量大和支持本地和XA事務(wù)等特性，適用于大吞吐量、順序消息、廣播和日志數(shù)據(jù)傳輸?shù)葓?chǎng)景?；诎l(fā)布訂閱模式，有Push和Pull兩種消費(fèi)方式，支持嚴(yán)格的消息順序，億級(jí)別的堆積能力，支持消息回溯和多個(gè)維度的消息查詢

相關(guān)名稱解釋：

1、Topic---消息的主題：由用戶定義并在服務(wù)端配置；producer發(fā)送消息到某個(gè)topic下，consumer從某個(gè)topic下消費(fèi)信息；

2、Offset---消息在broker上的每個(gè)分區(qū)都是組織成一個(gè)文件列表，消費(fèi)者拉取數(shù)據(jù)需要知道數(shù)據(jù)在文件中偏移量(offset)，Offset是絕對(duì)偏移量，服務(wù)器會(huì)將offset轉(zhuǎn)化為具體文件的相對(duì)偏移量；

3、Broker---就是meta的服務(wù)端或服務(wù)器，在消息中間件也通稱為broker;

4、分區(qū)(partition)---同一個(gè)topic下面分為多個(gè)分區(qū)；

配置文件相關(guān)參數(shù)：

zk.zkEnable=true ?---是否注冊(cè)到zk,默認(rèn)true

zk.zkConnect=localhost:2180 ? ---zk的服務(wù)器列表

zk.zkSessionTimeoutMs=30000 ? ---zk心跳超時(shí)，單位毫秒，默認(rèn)30秒

zk.zkConnectionTimeoutMs=30000 ?---zk連接超時(shí)時(shí)間，單位毫秒，默認(rèn)30秒

brokerId ? ---服務(wù)器ID,必須是集群內(nèi)唯一，必須為整數(shù)0-1024之間

serverPort ? ---服務(wù)器端口

hostName ? ---默認(rèn)將取本機(jī)IP,多機(jī)網(wǎng)卡需要指明

dataLogPath ? ----日志數(shù)據(jù)文件路徑，默認(rèn)跟dataPath一樣

dataPath ? ?---于指定默認(rèn)的數(shù)據(jù)存儲(chǔ)路徑

deletePolicy=delete，168 ? ---數(shù)據(jù)刪除策略，默認(rèn)超過(guò)7天刪除，默認(rèn)單位小時(shí)

deleteWhen: ? ?---何時(shí)執(zhí)行刪除策略的cron表達(dá)式，默認(rèn)0 0 6，18 * *？

flushTxLogAtCommit=1 ? ---事務(wù)日志的同步設(shè)置

unflushThreshold ? ? ---每個(gè)多少條消息做一次磁盤(pán)sync,強(qiáng)制將更改的數(shù)據(jù)刷入磁盤(pán)；

unflushInterval ? ?---間隔多少毫秒定期做一次磁盤(pán)sync，默認(rèn)10秒

二、搭建過(guò)程

系統(tǒng)環(huán)境：CentOS Linux release 7.6.1810 (Core)

1、jdk環(huán)境

2、搭建zookeeper(偽集群)

1)解壓

tar -zxvf zookeeper-3.4.14.tar.gz -C /usr/local/

2）創(chuàng)建三個(gè)節(jié)點(diǎn)，復(fù)制文件（文件夾）

# mkdir -p zk1 zk2 zk3

cp -r zookeeper-3.4.14 zk1/

3）配置文件（其他兩個(gè)節(jié)點(diǎn)類似）

cd zk1/zookeeper-3.4.14/

# mkdir dataDir dataLogDir

#創(chuàng)建標(biāo)識(shí)(三個(gè)節(jié)點(diǎn)分別1，2，3)

# cd dataDir

vim myid

1

##修改配置文件

# mv conf/zoo_sample.cfg conf/zoo.cfg

# vim conf/zoo.cfg

其他兩個(gè)節(jié)點(diǎn)拷貝過(guò)去即可(注意修改標(biāo)識(shí))##修改相關(guān)配置文件

# cp -rf zk1/zookeeper-3.4.14 zk2/

# cp -rf zk1/zookeeper-3.4.14 zk3/

4）啟動(dòng)服務(wù)

# zk1/zookeeper-3.4.14/bin/zkServer.sh start

# zk2/zookeeper-3.4.14/bin/zkServer.sh start

# zk3/zookeeper-3.4.14/bin/zkServer.sh start

# netstat -tnlp | grep -E '2181|2182|2183'

測(cè)試連接登錄即可：

# zk1/zookeeper-3.4.14/bin/zkCli.sh -server 127.0.0.1:2181

3、搭建metaq環(huán)境

1）解壓文件

# tar -zxvf metaq-server-1.4.6.2.tar.gz -C /usr/local/

2）配置文件

# cd /usr/local/taobao/metamorphosis-server-wrapper/

# vim conf/server.ini

3）啟動(dòng)服務(wù)

./bin/metaServer.sh start &

##停止命令

./bin/metaServer.sh stop

##重啟命令

./bin/metaServer.sh restart &

##重新加載topic配置

./bin/metaServer.sh reload &

##查看server狀態(tài)

./bin/metaServer.sh stats

4、檢查部分

1）查看metaq注冊(cè)到zookper上

# zk1/zookeeper-3.4.14/bin/zkCli.sh ?-server 127.0.0.1:2181

###已注冊(cè)，查看meatq的隊(duì)列

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

新聞名稱：搭建METAQ消息中間件-創(chuàng)新互聯(lián)
網(wǎng)頁(yè)URL：http://chinadenli.net/article30/jghso.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)頁(yè)設(shè)計(jì)公司、App設(shè)計(jì)、網(wǎng)站內(nèi)鏈、小程序開(kāi)發(fā)、動(dòng)態(tài)網(wǎng)站、標(biāo)簽優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)