（二）RabbitMQ安装和基本操作

女爷i 2022-05-27 06:41 300阅读 0赞

RabbitMQ安装和基本操作

RabbitMQ介绍：https://blog.csdn.net/ycj_xiyang/article/details/79854379

RabbitMQ集群：https://blog.csdn.net/ycj_xiyang/article/details/79956516

概要

  1. RabbitMQ是一款开源的消息代理服务器，用来进行信息路由。
  3. MQ可以是架构变得松耦合，从而更有弹性，跟灵活，是SOA架构不可或缺的组成部分，担当服务总线或信息总线的角色。

安装

  1. RabbitMQ是由Erlang语言构建的，所以要先安装Erlang，安装Erlang最方便的是使用epel库。

Epel仓库

安装epel仓库

  1. 在CentOS6和CentOS7都可以执行下面的命令安装epel仓库
  3. yum -y install epel-release  
  6. 这条命令的好处是可以自动安装不同版本的epel，比如在CentOS6上面安装的是epel6，在CentOS7上面安装的epel7。  
  9. 可以在etc/yum.repos.d中手动配置阿里的epel源。  
  12. 注意：如果出现   
  14. Could not retrieve mirrorlist http://mirrorlist.centos.org/?release=6&arch=x86\_64&repo=os error was  
  15. 14: PYCURL ERROR 6 - "Couldn't resolve host 'mirrorlist.centos.org'"  
  16. Error: Cannot find a valid baseurl for repo: base  
  19. 这种错误，是因为没有配置/etc/resolv.conf。
  21. 解决方法：编辑resolv.conf文件，添加：

nameserver 8.8.8.8

移除epel仓库

  1. yum -y remove epel-release

查看仓库信息

  1. yum repolist

安装erlang

  1. yum -y install erlang
  3. [root@192 yum.repos.d]# yum -y install erlang
  4. Loaded plugins: fastestmirror
  5. Loading mirror speeds from cached hostfile
  6.  * base: mirrors.sohu.com
  7.  * epel: mirrors.sohu.com
  8.  * extras: mirrors.sohu.com
  9.  * updates: mirrors.sohu.com
  10. Setting up Install Process
  11. Resolving Dependencies
  12. --> Running transaction check
  13. ---> Package erlang.i686 0:R14B-04.3.el6 will be installed
  14.  erlang-R14B-04.3.el6.i686
  15. --> Processing Dependency: erlang-wx(x86-32) = R14B-04.3.el6 for package: erlang-R14B-04.3.el6.i686
  16. --> Running transaction check
  17. ---> Package erlang-appmon.i686 0:R14B-04.3.el6 will be installed
  18. R14B-04.3.el6 will be installed
  19. ---> Package erlang-gs.i686 0:R14B-04.3.el6 will be installed
  20. --> Finished Dependency Resolution
  21. Dependencies Resolved
  23. ================================================================================
  24.  Package                   Arch      Version                   Repository  Size
  25. ================================================================================
  26. Installing:
  27.  erlang                    i686      R14B-04.3.el6             epel        26 k
  28. Installing for dependencies:
  29.  SDL                       i686      1.2.14-7.el6_7.1          base       200 k
  30.  atk                       i686      1.30.0-1.el6              base       194 k
  31.  avahi-libs                i686      0.6.25-17.el6             base        55 k
  32.  cairo                     i686      1.8.8-6.el6_6             base       319 k
  33.  cups-libs                 i686      1:1.4.2-78.el6_9          updates    332 k
  34.  erlang-appmon             i686      R14B-04.3.el6             epel       145 k
  35.  erlang-asn1               i686      R14B-04.3.el6             epel       991 k
  36.  erlang-common_test        i686      R14B-04.3.el6             epel       514 k   
  37. (103/107): tk-8.5.7-5.el6.i686.rpm                       | 1.4 MB     00:00     
  38. (104/107): unixODBC-2.2.14-14.el6.i686.rpm               | 382 kB     00:00     
  39. (105/107): wxBase-2.8.12-1.el6.centos.i686.rpm           | 591 kB     00:00     
  40. (106/107): wxGTK-2.8.12-1.el6.centos.i686.rpm            | 3.0 MB     00:00     
  41. (107/107): wxGTK-gl-2.8.12-1.el6.centos.i686.rpm         |  31 kB     00:00     
  42. --------------------------------------------------------------------------------
  43. Total                                           3.2 MB/s |  65 MB     00:20     
  44. warning: rpmts_HdrFromFdno: Header V3 RSA/SHA256 Signature, key ID 0608b895: NOKEY
  45. Retrieving key from file:///etc/pki/rpm-gpg/RPM-GPG-KEY-EPEL-6
  46. Importing GPG key 0x0608B895:
  47.  Userid : EPEL (6) <epel@fedoraproject.org>
  48.  Package: epel-release-6-8.noarch (@extras)
  49.  From   : /etc/pki/rpm-gpg/RPM-GPG-KEY-EPEL-6
  50. Running rpm_check_debug
  51. Running Transaction Test
  52. Transaction Test Succeeded
  53. Running Transaction                                               
  54.   wxBase.i686 0:2.8.12-1.el6.centos                                             
  55.   wxGTK.i686 0:2.8.12-1.el6.centos                                              
  56.   wxGTK-gl.i686 0:2.8.12-1.el6.centos                                           
  58. Dependency Updated:
  59.   glib2.i686 0:2.28.8-9.el6              libdrm.i686 0:2.4.65-2.el6             
  61. Complete!

安装RabbitMQ

  1. wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm  
  4. [root@192 opt]# wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm
  5. --2018-03-22 16:29:54--  http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm
  6. 正在解析主机 www.rabbitmq.com... 104.20.63.197, 104.20.62.197, 2400:cb00:2048:1::6814:3ec5, ...
  7. 正在连接 www.rabbitmq.com|104.20.63.197|:80... 已连接。
  8. 已发出 HTTP 请求，正在等待回应... 200 OK
  9. 长度：4239866 (4.0M) [application/x-redhat-package-manager]
  10. 正在保存至: “rabbitmq-server-3.5.6-1.noarch.rpm”
  12. 100%[======================================>] 4,239,866   1.66M/s   in 2.4s    
  14. 2018-03-22 16:29:56 (1.66 MB/s) - 已保存 “rabbitmq-server-3.5.6-1.noarch.rpm” [4239866/4239866])

安装RabbitMQ Server

  1. rpm -ivh rabbitmq-server-3.5.6-1.noarch.rpm
  3. [root@192 opt]# rpm -ivh rabbitmq-server-3.5.6-1.noarch.rpm
  4. warning: rabbitmq-server-3.5.6-1.noarch.rpm: Header V4 DSA/SHA1 Signature, key ID 056e8e56: NOKEY
  5. Preparing...                ########################################### [100%]
  6.    1:rabbitmq-server        ########################################### [100%]

基本操作

启动RabbitMQ Server

service rabbitmq-server start 启动服务
service rabbitmq-server status 查看服务状态
service rabbitmq-server stop 停止服务
如果启动失败
ERROR: epmd error for host “192”:badarg (unknown POSIX error)
解决办法：
# vi /etc/rabbitmq/rabbitmq-env.conf
在文件里面添加这一行：NODENAME=rabbit@localhost，保存
(注意：rabbitmq-env.conf这个文件没有，打开之后自动创建) 

  1. [root@192 init.d]# rabbitmq-server start
  2. ERROR: epmd error for host 192: badarg (unknown POSIX error)
  3. [root@192 init.d]# cd /etc/rabbitmq 
  4. [root@192 rabbitmq]# ll
  5. 总用量 0
  6. [root@192 rabbitmq]# vim rabbitmq-env.conf
  7. NODENAME=rabbit@localhost
  8. ~                                                                                                                                                                                                                                         
  9. "rabbitmq-env.conf" [新] 1L, 26C 已写入                       
  10. [root@192 rabbitmq]# service rabbitmq-server start
  11. Starting rabbitmq-server: SUCCESS
  12. rabbitmq-server.
  13. [root@192 rabbitmq]# service rabbitmq-server status
  14. Status of node rabbit@localhost ...
  15. [{pid,17791},
  16.  {running_applications,[{rabbit,"RabbitMQ","3.5.6"},
  17.                         {mnesia,"MNESIA  CXC 138 12","4.5"},
  18.                         {os_mon,"CPO  CXC 138 46","2.2.7"},
  19.                         {xmerl,"XML parser","1.2.10"},
  20.                         {sasl,"SASL  CXC 138 11","2.1.10"},
  21.                         {stdlib,"ERTS  CXC 138 10","1.17.5"},
  22.                         {kernel,"ERTS  CXC 138 10","2.14.5"}]},
  23.  {os,{unix,linux}},
  24.  {erlang_version,"Erlang R14B04 (erts-5.8.5) [source] [rq:1] [async-threads:64] [kernel-poll:true]\n"},
  25.  {memory,[{total,14546488},
  26.           {connection_readers,0},
  27.           {connection_writers,0},
  28.           {connection_channels,0},
  29.           {connection_other,1364},
  30.           {queue_procs,1364},
  31.           {queue_slave_procs,0},
  32.           {plugins,0},
  33.           {other_proc,4710424},
  34.           {mnesia,28928},
  35.           {mgmt_db,0},
  36.           {msg_index,16892},
  37.           {other_ets,386428},
  38.           {binary,8840},
  39.           {code,7793778},
  40.           {atom,910449},
  41.           {other_system,688021}]},
  42.  {alarms,[]},
  43.  {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]},
  44.  {vm_memory_high_watermark,0.4},
  45.  {vm_memory_limit,793391923},
  46.  {disk_free_limit,50000000},
  47.  {disk_free,15668953088},
  48.  {file_descriptors,[{total_limit,924},
  49.                     {total_used,3},
  50.                     {sockets_limit,829},
  51.                     {sockets_used,1}]},
  52.  {processes,[{limit,1048576},{used,123}]},
  53.  {run_queue,0},
  54.  {uptime,26}]

停止服务

  1. service rabbitmq-server stop
  3. [root@192 ~]# service rabbitmq-server stop
  4. Stopping rabbitmq-server: rabbitmq-server.
  5. [root@192 ~]# service rabbitmq-server status
  6. Status of node rabbit@localhost ...
  7. Error: unable to connect to node rabbit@localhost: nodedown
  9. DIAGNOSTICS
  10. ===========
  12. attempted to contact: [rabbit@localhost]
  14. rabbit@localhost:
  15.   * connected to epmd (port 4369) on localhost
  16.   * epmd reports: node 'rabbit' not running at all
  17.                   other nodes on localhost: ['rabbitmq-cli-20859']
  18.   * suggestion: start the node
  20. current node details:
  21. - node name: 'rabbitmq-cli-20859@192'
  22. - home dir: /var/lib/rabbitmq
  23. - cookie hash: Rm4uPqqS7Q4s4lmw2/IcqA==
  25. [root@192 ~]#

查看限制

  1. cat /proc/（PID）/limits
  3. [root@192 ~]# ps faux | grep rabbit        
  4. root     21172  0.0  0.0   5980   776 pts/2    S+   18:19   0:00          \_ grep rabbit
  5. rabbitmq 17530  0.0  0.0   2268   464 ?        S    16:34   0:00 /usr/lib/erlang/erts-5.8.5/bin/epmd -daemon
  6. root     20975  0.0  0.0   6964   944 pts/2    S    18:19   0:00 /bin/sh /etc/init.d/rabbitmq-server start
  7. root     20978  0.0  0.0   6732  1268 pts/2    S    18:19   0:00  \_ /bin/bash -c ulimit -S -c 0 >/dev/null 2>&1 ; /usr/sbin/rabbitmq-server
  8. root     20980  0.0  0.0   6732  1336 pts/2    S    18:19   0:00      \_ /bin/sh /usr/sbin/rabbitmq-server
  9. root     20998  0.0  0.0   7120  1460 pts/2    S    18:19   0:00          \_ su rabbitmq -s /bin/sh -c /usr/lib/rabbitmq/bin/rabbitmq-server 
  10. rabbitmq 21001  0.0  0.0   6680  1328 ?        Ss   18:19   0:00              \_ /bin/sh -e /usr/lib/rabbitmq/bin/rabbitmq-server
  11. rabbitmq 21088  5.3  0.9  28728 18268 ?        Sl   18:19   0:00                  \_ /usr/lib/erlang/erts-5.8.5/bin/beam -W w -A 64 -P 1048576 -K true -B i -- -root /usr/lib/erlang -progname erl -- -home /var/lib/rabbitmq -- -pa /usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/sbin/../ebin -noshell -noinput -s rabbit boot -sname rabbit@localhost -boot start_sasl -kernel inet_default_connect_options [{nodelay,true}] -sasl errlog_type error -sasl sasl_error_logger false -rabbit error_logger {file,"/var/log/rabbitmq/rabbit@localhost.log"} -rabbit sasl_error_logger {file,"/var/log/rabbitmq/rabbit@localhost-sasl.log"} -rabbit enabled_plugins_file "/etc/rabbitmq/enabled_plugins" -rabbit plugins_dir "/usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/sbin/../plugins" -rabbit plugins_expand_dir "/var/lib/rabbitmq/mnesia/rabbit@localhost-plugins-expand" -os_mon start_cpu_sup false -os_mon start_disksup false -os_mon start_memsup false -mnesia dir "/var/lib/rabbitmq/mnesia/rabbit@localhost" -kernel inet_dist_listen_min 25672 -kernel inet_dist_listen_max 25672
  12. rabbitmq 21167  0.0  0.0   2240   460 ?        Ss   18:19   0:00                      \_ inet_gethost 4
  13. rabbitmq 21168  0.0  0.0   2296   564 ?        S    18:19   0:00                          \_ inet_gethost 4
  14. [root@192 ~]# cat /proc/17530/limits
  15. Limit                     Soft Limit           Hard Limit           Units     
  16. Max cpu time              unlimited            unlimited            seconds   
  17. Max file size             unlimited            unlimited            bytes     
  18. Max data size             unlimited            unlimited            bytes     
  19. Max stack size            10485760             unlimited            bytes     
  20. Max core file size        0                    unlimited            bytes     
  21. Max resident set          unlimited            unlimited            bytes     
  22. Max processes             1024                 15021                processes 
  23. Max open files            1024                 4096                 files     
  24. Max locked memory         65536                65536                bytes     
  25. Max address space         unlimited            unlimited            bytes     
  26. Max file locks            unlimited            unlimited            locks     
  27. Max pending signals       15021                15021                signals   
  28. Max msgqueue size         819200               819200               bytes     
  29. Max nice priority         0                    0                    
  30. Max realtime priority     0                    0                    
  31. Max realtime timeout      unlimited            unlimited            us        
  32. [root@192 ~]#
  34. 查看端口运行情况
  36. netstat -an | grep -E "(4369)"  括号里不填查看所有  
  39. [root@192 ~]# netstat -an | grep -E "(4369|6379|3306)"
  40. tcp        0      0 0.0.0.0:3306                0.0.0.0:*                   LISTEN      
  41. tcp        0      0 0.0.0.0:6379                0.0.0.0:*                   LISTEN      
  42. tcp        0      0 0.0.0.0:4369                0.0.0.0:*                   LISTEN      
  43. tcp        0      0 192.168.31.66:6379          192.168.31.66:35333         ESTABLISHED 
  44. tcp        0      0 192.168.31.66:6379          192.168.31.66:35334         ESTABLISHED 
  45. tcp        0      0 192.168.31.66:6379          192.168.31.66:35341         ESTABLISHED 
  46. tcp        0      0 127.0.0.1:4369              127.0.0.1:53821             ESTABLISHED 
  47. tcp        0      0 192.168.31.66:6379          192.168.31.66:35338         ESTABLISHED 
  48. tcp        0      0 192.168.31.66:6379          192.168.31.66:35336         ESTABLISHED 
  49. tcp        0      0 192.168.31.66:6379          192.168.31.66:35344         ESTABLISHED 
  50. tcp        0      0 192.168.31.66:6379          192.168.31.66:35330         ESTABLISHED 
  51. tcp        0      0 192.168.31.66:6379          192.168.31.66:35340         ESTABLISHED 
  52. tcp        0      0 192.168.31.66:6379          192.168.31.66:35331         ESTABLISHED 
  53. tcp        0      0 192.168.31.66:6379          192.168.31.66:35339         ESTABLISHED 
  54. tcp        0      0 192.168.31.66:6379          192.168.31.66:35332         ESTABLISHED 
  55. tcp        0      0 192.168.31.66:6379          192.168.31.66:35335         ESTABLISHED 
  56. tcp        0      0 127.0.0.1:53821             127.0.0.1:4369              ESTABLISHED 
  57. tcp        0      0 192.168.31.66:6379          192.168.31.66:35342         ESTABLISHED 
  58. tcp        0      0 192.168.31.66:6379          192.168.31.66:35337         ESTABLISHED 
  59. tcp        0      0 192.168.31.66:6379          192.168.31.66:35343         ESTABLISHED 
  60. tcp        0      0 192.168.31.66:6379          192.168.31.66:35329         ESTABLISHED 
  61. tcp        0      0 127.0.0.1:4369              127.0.0.1:49768             TIME_WAIT   
  62. tcp        0      0 ::ffff:192.168.31.66:35331  ::ffff:192.168.31.66:6379   ESTABLISHED 
  63. tcp        0      0 ::ffff:192.168.31.66:35329  ::ffff:192.168.31.66:6379   ESTABLISHED 
  64. tcp        0      0 ::ffff:192.168.31.66:35337  ::ffff:192.168.31.66:6379   ESTABLISHED 
  65. tcp        0      0 ::ffff:192.168.31.66:35330  ::ffff:192.168.31.66:6379   ESTABLISHED 
  66. tcp        0      0 ::ffff:192.168.31.66:35334  ::ffff:192.168.31.66:6379   ESTABLISHED 
  67. tcp        0      0 ::ffff:192.168.31.66:35336  ::ffff:192.168.31.66:6379   ESTABLISHED 
  68. tcp        0      0 ::ffff:192.168.31.66:35335  ::ffff:192.168.31.66:6379   ESTABLISHED 
  69. tcp        0      0 ::ffff:192.168.31.66:35332  ::ffff:192.168.31.66:6379   ESTABLISHED 
  70. tcp        0      0 ::ffff:192.168.31.66:35333  ::ffff:192.168.31.66:6379   ESTABLISHED 
  71. tcp        0      0 ::ffff:192.168.31.66:35338  ::ffff:192.168.31.66:6379   ESTABLISHED 
  72. tcp        0      0 ::ffff:192.168.31.66:35339  ::ffff:192.168.31.66:6379   ESTABLISHED 
  73. tcp        0      0 ::ffff:192.168.31.66:35341  ::ffff:192.168.31.66:6379   ESTABLISHED 
  74. tcp        0      0 ::ffff:192.168.31.66:35344  ::ffff:192.168.31.66:6379   ESTABLISHED 
  75. tcp        0      0 ::ffff:192.168.31.66:35343  ::ffff:192.168.31.66:6379   ESTABLISHED 
  76. tcp        0      0 ::ffff:192.168.31.66:35340  ::ffff:192.168.31.66:6379   ESTABLISHED 
  77. tcp        0      0 ::ffff:192.168.31.66:35342  ::ffff:192.168.31.66:6379   ESTABLISHED 
  78. [root@192 ~]#

rabbitmqctl基础操作

日常管理主要使用rabbitmqctl

关闭node

  1. rabbitmqctl stop
  3. [root@192 ~]# rabbitmqctl stop
  4. Stopping and halting node rabbit@localhost ...
  5. [root@192 ~]# rabbitmqctl status
  6. Status of node rabbit@localhost ...
  7. Error: unable to connect to node rabbit@localhost: nodedown
  9. DIAGNOSTICS
  10. ===========
  12. attempted to contact: [rabbit@localhost]
  14. rabbit@localhost:
  15.   * connected to epmd (port 4369) on localhost
  16.   * epmd reports: node 'rabbit' not running at all
  17.                   other nodes on localhost: ['rabbitmq-cli-21585']
  18.   * suggestion: start the node
  20. current node details:
  21. - node name: 'rabbitmq-cli-21585@192'
  22. - home dir: /var/lib/rabbitmq
  23. - cookie hash: Rm4uPqqS7Q4s4lmw2/IcqA==
  25. [root@192 ~]#

关闭RabbitMQ应用

  1. rabbitmqctl stop\_app
  3. [root@192 ~]# service rabbitmq-server start
  4. Starting rabbitmq-server: SUCCESS
  5. rabbitmq-server.
  6. [root@192 ~]# rabbitmqctl stop_app         
  7. Stopping node rabbit@localhost ...
  8. [root@192 ~]# ps faux | grep -i mq            
  9. root     22161  0.0  0.0   5980   800 pts/2    S+   18:37   0:00          \_ grep -i mq
  10. rabbitmq 17530  0.0  0.0   2268   472 ?        S    16:34   0:00 /usr/lib/erlang/erts-5.8.5/bin/epmd -daemon
  11. root     21890  0.0  0.0   6964   944 pts/2    S    18:35   0:00 /bin/sh /etc/init.d/rabbitmq-server start
  12. root     21893  0.0  0.0   6732  1272 pts/2    S    18:35   0:00  \_ /bin/bash -c ulimit -S -c 0 >/dev/null 2>&1 ; /usr/sbin/rabbitmq-server
  13. root     21895  0.0  0.0   6732  1336 pts/2    S    18:35   0:00      \_ /bin/sh /usr/sbin/rabbitmq-server
  14. root     21913  0.0  0.0   7120  1468 pts/2    S    18:35   0:00          \_ su rabbitmq -s /bin/sh -c /usr/lib/rabbitmq/bin/rabbitmq-server 
  15. rabbitmq 21916  0.0  0.0   6680  1328 ?        Ss   18:35   0:00              \_ /bin/sh -e /usr/lib/rabbitmq/bin/rabbitmq-server
  16. rabbitmq 22014  0.4  0.9  27704 17760 ?        Sl   18:35   0:00                  \_ /usr/lib/erlang/erts-5.8.5/bin/beam -W w -A 64 -P 1048576 -K true -B i -- -root /usr/lib/erlang -progname erl -- -home /var/lib/rabbitmq -- -pa /usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/sbin/../ebin -noshell -noinput -s rabbit boot -sname rabbit@localhost -boot start_sasl -kernel inet_default_connect_options [{nodelay,true}] -sasl errlog_type error -sasl sasl_error_logger false -rabbit error_logger {file,"/var/log/rabbitmq/rabbit@localhost.log"} -rabbit sasl_error_logger {file,"/var/log/rabbitmq/rabbit@localhost-sasl.log"} -rabbit enabled_plugins_file "/etc/rabbitmq/enabled_plugins" -rabbit plugins_dir "/usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/sbin/../plugins" -rabbit plugins_expand_dir "/var/lib/rabbitmq/mnesia/rabbit@localhost-plugins-expand" -os_mon start_cpu_sup false -os_mon start_disksup false -os_mon start_memsup false -mnesia dir "/var/lib/rabbitmq/mnesia/rabbit@localhost" -kernel inet_dist_listen_min 25672 -kernel inet_dist_listen_max 25672
  17. rabbitmq 22092  0.0  0.0   2240   460 ?        Ss   18:35   0:00                      \_ inet_gethost 4
  18. rabbitmq 22093  0.0  0.0   2296   564 ?        S    18:35   0:00                          \_ inet_gethost 4
  19. [root@192 ~]# rabbitmqctl status           
  20. Status of node rabbit@localhost ...
  21. [{pid,22014},
  22.  {running_applications,[{xmerl,"XML parser","1.2.10"},
  23.                         {sasl,"SASL  CXC 138 11","2.1.10"},
  24.                         {stdlib,"ERTS  CXC 138 10","1.17.5"},
  25.                         {kernel,"ERTS  CXC 138 10","2.14.5"}]},
  26.  {os,{unix,linux}},
  27.  {erlang_version,"Erlang R14B04 (erts-5.8.5) [source] [rq:1] [async-threads:64] [kernel-poll:true]\n"},
  28.  {memory,[{total,14246240},
  29.           {connection_readers,0},
  30.           {connection_writers,0},
  31.           {connection_channels,0},
  32.           {connection_other,0},
  33.           {queue_procs,0},
  34.           {queue_slave_procs,0},
  35.           {plugins,0},
  36.           {other_proc,4540636},
  37.           {mnesia,0},
  38.           {mgmt_db,0},
  39.           {msg_index,0},
  40.           {other_ets,312268},
  41.           {binary,2376},
  42.           {code,7793778},
  43.           {atom,910449},
  44.           {other_system,686733}]},
  45.  {alarms,[]},
  46.  {listeners,[]},
  47.  {processes,[{limit,1048576},{used,46}]},
  48.  {run_queue,0},
  49.  {uptime,88}]
  50. [root@192 ~]#
  52. 注意：上面关闭节点后 rabbitmq server 也会关闭，但是关闭应用后不会关闭，节点也在运行，\{listeners,\[\{clustering,25672,”::”\},\{amqp,5672,”::”\}\]\} 变成了 \{listeners,\[\]\} , 内存磁盘还有文件句柄部分也消失了

查看日志

  1. tail -f /var/log/rabbitmq/rabbit@localhost.log
  3. [root@192 rabbitmq]# tail -f /var/log/rabbitmq/rabbit@localhost.log
  4. Server startup complete; 0 plugins started.
  6. =INFO REPORT==== 22-Mar-2018::18:36:02 ===
  7. Stopping RabbitMQ
  9. =INFO REPORT==== 22-Mar-2018::18:36:02 ===
  10. stopped TCP Listener on [::]:5672
  12. =INFO REPORT==== 22-Mar-2018::18:36:02 ===
  13. Stopped RabbitMQ application     
  14. [root@192 rabbitmq]# netstat  -ant | grep 5672
  15. tcp        0      0 0.0.0.0:25672               0.0.0.0:*                   LISTEN      
  16. [root@192 rabbitmq]#

开启rabbitmq应用

  1. rabbitmqctl start\_app
  3. [root@192 rabbitmq]# rabbitmqctl start_app
  4. Starting node rabbit@localhost ...
  5. [root@192 rabbitmq]# rabbitmqctl status
  6. Status of node rabbit@localhost ...
  7. [{pid,22014},
  8.  {running_applications,[{rabbit,"RabbitMQ","3.5.6"},
  9.                         {os_mon,"CPO  CXC 138 46","2.2.7"},
  10.                         {mnesia,"MNESIA  CXC 138 12","4.5"},
  11.                         {xmerl,"XML parser","1.2.10"},
  12.                         {sasl,"SASL  CXC 138 11","2.1.10"},
  13.                         {stdlib,"ERTS  CXC 138 10","1.17.5"},
  14.                         {kernel,"ERTS  CXC 138 10","2.14.5"}]},
  15.  {os,{unix,linux}},
  16.  {erlang_version,"Erlang R14B04 (erts-5.8.5) [source] [rq:1] [async-threads:64] [kernel-poll:true]\n"},
  17.  {memory,[{total,14519912},
  18.           {connection_readers,0},
  19.           {connection_writers,0},
  20.           {connection_channels,0},
  21.           {connection_other,1364},
  22.           {queue_procs,1364},
  23.           {queue_slave_procs,0},
  24.           {plugins,0},
  25.           {other_proc,4685584},
  26.           {mnesia,28664},
  27.           {mgmt_db,0},
  28.           {msg_index,16908},
  29.           {other_ets,384340},
  30.           {binary,9304},
  31.           {code,7793778},
  32.           {atom,910933},
  33.           {other_system,687673}]},
  34.  {alarms,[]},
  35.  {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]},
  36.  {vm_memory_high_watermark,0.4},
  37.  {vm_memory_limit,793391923},
  38.  {disk_free_limit,50000000},
  39.  {disk_free,15668776960},
  40.  {file_descriptors,[{total_limit,924},
  41.                     {total_used,3},
  42.                     {sockets_limit,829},
  43.                     {sockets_used,1}]},
  44.  {processes,[{limit,1048576},{used,123}]},
  45.  {run_queue,0},
  46.  {uptime,816}]
  47. [root@192 rabbitmq]#

重置node

  1. rabbitmqctl reset（让节点回到初始状态）
  3. [root@192 rabbitmq]# rabbitmqctl reset
  4. Resetting node rabbit@localhost ...
  5. Error: mnesia_unexpectedly_running
  6. [root@192 rabbitmq]# rabbitmqctl stop_app
  7. Stopping node rabbit@localhost ...
  8. [root@192 rabbitmq]# rabbitmqctl reset   
  9. Resetting node rabbit@localhost ...
  10. [root@192 rabbitmq]#
  12. 注意：必须要先关闭RabbitMQ应用才能重置node
  14. =INFO REPORT==== 22-Mar-2018::18:52:58 ===
  15. Stopped RabbitMQ application
  17. =INFO REPORT==== 22-Mar-2018::18:53:01 ===
  18. Resetting Rabbit

强制重置node

  1. 注意：还是要先关闭RabbitMQ应用
  3. [root@192 rabbitmq]# rabbitmqctl force_reset
  4. Forcefully resetting node rabbit@localhost ...
  5. Error: mnesia_unexpectedly_running
  6. [root@192 rabbitmq]# rabbitmqctl stop_app                          
  7. Stopping node rabbit@localhost ...
  8. [root@192 rabbitmq]# rabbitmqctl force_reset
  9. Forcefully resetting node rabbit@localhost ...
  10. [root@192 rabbitmq]# tail -f /var/log/rabbitmq/rabbit@localhost.log
  11. Stopping RabbitMQ
  13. =INFO REPORT==== 22-Mar-2018::18:57:01 ===
  14. stopped TCP Listener on [::]:5672
  16. =INFO REPORT==== 22-Mar-2018::18:57:01 ===
  17. Stopped RabbitMQ application
  19. =INFO REPORT==== 22-Mar-2018::18:57:03 ===
  20. Resetting Rabbit forcefully

轮转日志

  1. 当前状态    ll /var/log/rabbitmq/
  3. [root@192 ~]# ll /var/log/rabbitmq/
  4. 总用量 24
  5. -rw-r--r--. 1 rabbitmq rabbitmq 16256 3月  22 18:57 rabbit@localhost.log
  6. -rw-r--r--. 1 rabbitmq rabbitmq     0 3月  22 16:39 rabbit@localhost-sasl.log
  7. -rw-r--r--. 1 root     root         0 3月  22 18:16 shutdown_err
  8. -rw-r--r--. 1 root     root        47 3月  22 18:16 shutdown_log
  9. -rw-r--r--. 1 root     root         0 3月  22 18:35 startup_err
  10. -rw-r--r--. 1 root     root      1050 3月  22 18:56 startup_log
  11. [root@192 ~]#
  13. 轮转日志    rabbitmqctl rotate\_logs .1(注意：.1前面有个空格)
  15. [root@192 ~]# rabbitmqctl rotate_logs .1
  16. Rotating logs to files with suffix ".1" ...
  17. [root@192 ~]#
  19. 当前日志
  21. [root@192 rabbitmq]# tail -f /var/log/rabbitmq/rabbit@localhost.log
  22. =INFO REPORT==== 22-Mar-2018::18:57:03 ===
  23. Rotating logs wtih suffix ".1"
  25. 之后的状态  
  28. [root@192 ~]# ll /var/log/rabbitmq/                         
  29. 总用量 24
  30. -rw-r--r--. 1 rabbitmq rabbitmq     0 3月  22 19:01 rabbit@localhost.log
  31. -rw-r--r--. 1 rabbitmq rabbitmq 16331 3月  22 19:01 rabbit@localhost.log.1
  32. -rw-r--r--. 1 rabbitmq rabbitmq     0 3月  22 19:01 rabbit@localhost-sasl.log
  33. -rw-r--r--. 1 rabbitmq rabbitmq     0 3月  22 19:01 rabbit@localhost-sasl.log.1
  34. -rw-r--r--. 1 root     root         0 3月  22 18:16 shutdown_err
  35. -rw-r--r--. 1 root     root        47 3月  22 18:16 shutdown_log
  36. -rw-r--r--. 1 root     root         0 3月  22 18:35 startup_err
  37. -rw-r--r--. 1 root     root      1050 3月  22 18:56 startup_log
  38. [root@192 ~]#
  40. 最后发现都复制了一份原来的日志且都加上了.1的后缀

当前页面使用到的命令汇总

  1. 安装epel库
  3. yum -y install epel-release   
  6. 安装Erlang    
  8. yum -y install erlang   
  11. 安装RabbitMQ  
  14. wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm  
  17. 安装RabbitMQ Server    
  20. rpm -ivh rabbitmq-server-3.5.6-1.noarch.rpm  
  23. 启动RabbitMQ Server  
  26. service rabbitmq-server start  
  29. 查看服务状态  
  32. service rabbitmq-server status  
  35. 停止服务  
  38. service rabbitmq-server stop  
  41. 查看日志  
  44. tail -f /var/log/rabbitmq/rabbit@localhost.log  
  47. 查看日志文件  
  50. ll /var/log/rabbitmq

发表评论

表情：
评论列表 （有 0 条评论，300人围观）

还没有评论，来说两句吧...

相关阅读