mq

启动rabbitmq

启动、停止、重启、状态rabbitMq命令


sudo rabbitmq-server start

sudo rabbitmq-server stop

sudo rabbitmq-server restart

sudo rabbitmqctl status

```

进入/etc/rabbitmq

`sudo rabbitmq-plugins enable rabbitmq_management`

# 操作

## 关于应用

```yaml

rabbitmqctl start_app:

启动应用

rabbitmqctl stop_app:

关闭应用

rabbitmqctl status:

节点状态

rabbitmqctl reset:

移除所有数据,要在rabbitmqctl stop_app之后使用

rabbitmqctl join_cluster <clusternode> [--ram]:

组成集群命令

rabbitmqctl cluster_status:

查看集群状态

rabbitmqctl change_cluster_node_type disc|ram:

修改集群节点的存储形式

rabbitmqctl forget_cluster_node [--offline]:

忘记节点(摘除节点)

rabbitmqctl rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2]:

修改节点名称

```

## 关于用户

```yaml

rabbitmqctl add_user username password:

添加用户

rabbitmqctl list_users:

列出所有用户

rabbitmqctl dekete_user username:

删除用户

rabbitmqctl clear_permissions -p vhostpath username:

清除用户权限

rabbitmqctl list_user_permissions username:

列出用户权限

rabbitmqctl change_password username newpassword:

修改密码

rabbitmqctl set_permissions -p vhostpath username ".*" ".*" ".*":

设置用户权限

```

## 关于虚拟主机

```yaml

rabbitmqctl add_vhost vhostpath:

创建虚拟主机

rabbitmqctl list_vhosts:

列出所有虚拟主机

rabbitmqctl list_permissions -p vhostpath:

列出虚拟主机上所有权限

rabbitmqctl delete_vhost vhostpath:

删除虚拟主机

```

## 关于队列

```yaml

rabbitmqctl list_queues:

查看所有队列信息

rabbitmqctl -p vhostpath purge_queue blue:

清除队列里的消息

```

# exchange交换机

## 交换机属性

```yaml

name:

交换机名称

type:

direct,topic,fanout,headers

durability:

是否需要持久化,true为持久化

auto delete:

当最后一个绑定到exchange删的队列删除后,自动删除该exchange

internal:

当前exchange是否用于rabbitmq内部使用,默认为false

arguments:

扩展参数,用于扩展amqp协议自制定化使用

```

## 交换机类型

### direct exchange

所有发送到direct exchange的消息被转发到RouteKey中指定的queue

注意:direct模式可以使用rabbitmq自带的exchange:default exchange,所以不需要将exchange进行任何绑定(binding)操作,消息传递时,RouteKey必须完全匹配才会被队列接受,否则该消息会被抛弃

### topic exchange

所有发送到topic exchange的消息被转发到所有关心RouteKey中指定topic的queue上

exchange将routekey和某topic进行模糊匹配,此时队列需要绑定一个topic

### fanout exchange

不处理路由键,只需要见得将队列绑定到交换机上。

发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。

fanout交换机转发消息是最快的

# Binding绑定

## 概述

exchange和exchange、queue之间的连接关系

Binding中可以包含routekey或者参数

# Queue消息队列

## 概述

消息队列,实际存储消息数据

durability:是否持久化,durable:是,transient:否

auto delete:如选yes,代表当最后一个监听被移除之后,该queue会自动被删除

# Message消息

## 概述

服务器应用程序之间传送的数据

本质上就是一段数据,由properties和payload(body)组成

常用属性:delivery mode、headers(自定义属性)

其他属性:

​   content_type, content_encoding, priority

​   correlation_id,reply_to,expiration,message_id

​   timestamp,type,user_id,cluster_id
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容