roketmq单机版本

小咪咪 2022-06-13 07:09 149阅读 0赞

#     #

# Clone & Build  （个人打包资源：[http://download.csdn.net/detail/luckyzsion/9885361][http_download.csdn.net_detail_luckyzsion_9885361]） #

> git clone -b develop https://github.com/apache/incubator-rocketmq.git
      > cd incubator-rocketmq
      > mvn -Prelease-all -DskipTests clean install -U
      > cd distribution/target/apache-rocketmq

# Start Name Server #

> nohup sh bin/mqnamesrv &
      > tail -f ~/logs/rocketmqlogs/namesrv.log
      The Name Server boot success...

# Start Broker #

> nohup sh bin/mqbroker -n localhost:9876 &
      > tail -f ~/logs/rocketmqlogs/broker.log 
      The broker[%s, 172.30.30.233:10911] boot success...

# Send & Receive Messages #

Before sending/receiving messages, we need to tell clients the location of name servers. RocketMQ provides multiple ways to achieve this. For simplicity, we use environment variable `NAMESRV_ADDR`

> 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...

# Shutdown Servers #

> 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

遇到问题：

1、在mac上运行，JAVA\_HOME未设置

$ vim ~/.bash\_profile

export JAVA\_HOME=$(/usr/libexec/java\_home)

$ source .bash\_profile

2、运行后电脑卡住了，请先设置

vim /usr/local/rocketmq/bin/runbroker.sh
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx512m -Xmn256m"
    
    vim /usr/local/rocketmq/bin/runserver.sh
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx512m -Xmn256m -XX:PermSize=256m -XX:MaxPermSize=512m"

vim /usr/local/rocketmq/bin/tools.sh

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx512m -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m"

3、cent7 提示java heap无法初始化，提示设置的值太小，不支持128m、256m。可以不用管（个人重新安装jdk、设置了虚拟机内存，将2中值写1g，结果运行后虚拟机卡住了，后面有设置成上面，一切正常），但是注意2中的设置要正确，不要写错。

参考资料：

http://rocketmq.apache.org/docs/quick-start/

[http_download.csdn.net_detail_luckyzsion_9885361]: http://download.csdn.net/detail/luckyzsion/9885361