组件_RabbitMQ之推送消息

RabbitMQ推送消息

步骤三：在无登录账号的情况下，系统提供了默认的账号：guest ，密码：guest 注：guest可能出现登录不上的情况，这里系统是默认只能在本地登录guest这个账号 ，如需使用，需要去RabbitMQ配置文件配置。 配置流程：进入/usr/lib/rabbitmq/lib/rabbitmq_server-3.7.7/ebin/rabbit.app 将：{loopback_users, [<<”guest”>>]}，改为：{loopback_users, []}，重启即可 重启命令：

systemctl restart rabbitmq-server.service

步骤四：添加一个交换机Exchanges 进入Exchanges 点击添加一个交换机 输入交换机的名字、类型、是否持久化，并点击Add exchange按钮 查看界面出现新的交换机，则成功

步骤五：添加一个队列 选择Queues下的Add a new queue 输入队列名和是否持久化，点击Add queue 查看界面上出现一个队列，则成功

步骤六：交换机和队列绑定 点击队列名，进去详情查看 选择Banding（绑定） 输入要绑定的交换机的名字和Routing key Routing key：为匹配规则，只有相对应的Exchanges和Routing key才可以访问到该队列。比如Routing key=Abc，则只有Routing key=Abc可以访问到该队列。 Routing key=Abc.*的话，那么只有Abc.xxx可以访问，Abc.xx.xx就不行 点击绑定，出现下列显示则绑定成功

步骤七：消息的推送 在java中配置rabbitmq，port一般为5672 下面${变量}形式为已经配置在了本地的环境变量中 在java代码中注入

@Autowired
private RabbitTemplate rabbitTemplate;

调用（对象被转成了json格式）：

rabbitTemplate.convertAndSend("middle_exchanges","middle.save",new ObjectMapper().writeValueAsString(要传输的对象));

步骤八：查看消息 查看消息所在的队列详情，点击Get Messages 选择查看即可