残医悦王妃,mh370航班最新消息,必赢国际
在github上的说法来看: apache rocketmq是一个分布式消息传递和流媒体平台,具有低延迟,高性能和可靠性,万亿级容量和灵活的可扩展性。它提供了多种功能:
上面都是官方列举出来了,还有如下特点:
官方网站: http://rocketmq.apache.org/docs/motivation/ 也对rocketmq和activemq以及kafka做了一个对比.
参考: http://rocketmq.apache.org/docs/core-concept/ 本人英文阅读能力有点弱,大家请看官方文档.
1. 安装unzip命令: yum install unzip 2. 解压: unzip rocketmq-all-4.4.0-source-release.zip 3. 重命名: mv rocketmq-all-4.4.0 rocketmq 4. 进入文件夹: cd rocketmq 5. 使用maven进行源码编译: mvn -prelease-all -dskiptests clean install -u 6. 进入文件夹: cd distribution/target/apache-rocketmq 7. 启动服务: sh bin/mqnamesrv (注意如果内存小于4g可能会失败)
[root@izwz94sw188z3yfl7lpmmsz apache-rocketmq]# sh bin/mqnamesrv java hotspot(tm) 64-bit server vm warning: using the defnew young collector with the cms collector is deprecated and will likely be removed in a future release java hotspot(tm) 64-bit server vm warning: usecmscompactatfullcollection is deprecated and will likely be removed in a future release. java hotspot(tm) 64-bit server vm warning: info: os::commit_memory(0x00000006ec800000, 2147483648, 0) failed; error='cannot allocate memory' (errno=12) # # there is insufficient memory for the java runtime environment to continue. # native memory allocation (mmap) failed to map 2147483648 bytes for committing reserved memory. # an error report file with more information is saved as: # /usr/local/software/rocketmq-all- 4.4.0/distribution/target/apache-rocketmq/hs_err_pid8993.log 这种原因是内存不足导致的,默认是4g,解决办法是编辑 bin/runserver.sh: java_opt="${java_opt} -server -xms256m -xmx256m -xmn256m -xx:metaspacesize=128m -xx:maxmetaspacesize=320m"
nohup sh bin/mqnamesrv & 这个命令可能会nohup: ignoring input and appending output to ‘nohup.out’,如果出现这个,执行: tail -f nohup.out 这个时候ctrl+c就不会退出程序,仅仅是让程序后台运行
[root@wangzhi apache-rocketmq]# sh bin/mqbroker -n localhost:9876 java hotspot(tm) 64-bit server vm warning: info: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='cannot allocate memory' (errno=12) # # there is insufficient memory for the java runtime environment to continue. # native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory. # an error report file with more information is saved as: # /usr/local/software/rocketmq/distribution/target/apache-rocketmq/hs_err_pid3012.log 出现了broker内存不足的问题: vim bin/runbroker.sh 修改 java_opt="${java_opt} -server -xms8g -xmx8g -xmn4g" 的内容为: java_opt="${java_opt} -server -xms2g -xmx2g -xmn1g" 完成之后以守护进程的方式进行启动: nohup sh bin/mqbroker -n localhost:9876 & tail -f nohup.out 这个时候可以使用jps查看进程,并且可以根据进程号来kill进程
export namesrv_addr=localhost:9876 sh bin/tools.sh org.apache.rocketmq.example.quickstart.producer sh bin/tools.sh org.apache.rocketmq.example.quickstart.consumer
先修改两个bug,一个是修改pom.xml的版本号. cd rocketmq-console/ vim pom.xml : 将里面的rocketmq的版本号后面的snashop删掉,只留个4.4.0就好 在上一个console的路径下继续: cd src/main/resources/ vim application.properties : 修改nameserver地址 rocketmq.config.namesrvaddr=127.0.0.1:9876 返回到console目录,进行编译安装: mvn clean package -dmaven.test.skip
cd target java -jar rocketmq-console-ng-1.0.0.jar 使用ctrl + c关闭程序,以守护进程的方式进行启动 nohup java -jar rocketmq-console-ng-1.0.0.jar & tail -f nohup.out
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
如何在java 8 stream表达式实现if/else逻辑
Java中有界队列的饱和策略(reject policy)原理解析
网友评论