rabbitmq的启动命令和springboot整合使用rabbitmq

2024-05-19 02:12:36

环境：windows
安装erlang和rabbitmq的过程这里不多说，记得两个的版本要对应。

1.启动rabbitmq：

进入sbin目录：

其中可能报错：

则需要终止已经开始的进程（可能是之前启动过）
tasklist|find /i “erl”
erlsrv.exe 4676 Services 0 716 K
erl.exe 5916 Services 0 21,328 K
erl.exe 29252 Console 1 23,428 K

C:\Users\14172>taskkill /pid “4676” -f
SUCCESS: The process with PID 4676 has been terminated.

C:\Users\14172>taskkill /pid “29252” -f
SUCCESS: The process with PID 29252 has been terminated.

C:\Users\14172>taskkill /pid “5916” -f
SUCCESS: The process with PID 5916 has been terminated.

再次输入

rabbitmq-server.bat start

2.在springboot中使用

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

配置：

spring:rabbitmq:addresses: 127.0.0.1port: 5672username: guestpassword: guest

代码：

public interface IOrderService {ResponseVo<OrderVo> create(Integer uid, Integer shippingId);ResponseVo<PageInfo> list(Integer uid, Integer pageNum, Integer pageSize);ResponseVo<OrderVo> detail(Integer uid, Long orderNo);ResponseVo cancel(Integer uid, Long orderNo);void paid(Long orderNo);
}

@Component
@RabbitListener(queues = "payNotify")
@Slf4j
public class PayMsgListener {@Autowiredprivate IOrderService orderService;@RabbitHandlerpublic void process(String msg) {log.info("【接收到消息】=> {}", msg);PayInfo payInfo = new Gson().fromJson(msg, PayInfo.class);if (payInfo.getPlatformStatus().equals("SUCCESS")) {//修改订单里的状态orderService.paid(payInfo.getOrderNo());}}
}

rabbitmq的启动命令和springboot整合使用rabbitmq相关推荐

SpringBoot 整合实现RabbitMQ
目录 1.RabbitMQ介绍 2.RabbitMQ的工作原理 3. SpringBoot 整合实现RabbitMQ 3.1创建mq-rabbitmq-producer(生产者)发送消息 3.1.1p ...
RabbitMQ 第一天基础 6 SpringBoot 整合RabbitMQ
RabbitMQ [黑马程序员RabbitMQ全套教程,rabbitmq消息中间件到实战] 文章目录 RabbitMQ 第一天基础 6 SpringBoot 整合RabbitMQ 6.1 Sprin ...
RabbitMQ消息队列(六)：SpringBoot整合之通配符模式
RabbitMQ消息队列(六):SpringBoot整合之通配符模式 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AeZQrNHS-1660220618697)(E: ...
RabbitMq 虚拟主机 virtual-host ，Springboot 中使用 RabbitMq 虚拟主机 virtual-host
文章目录 RabbitMq 虚拟主机 virtual-host ,Springboot 中使用 RabbitMq 虚拟主机 virtual-host 1.在RabbitMQ 控制台中创建虚拟主机 2. ...
redis命令，SpringBoot整合Redis6，主从复制,哨兵模式,集群，springCache初高级应用。
目录 1. Docker安装Redis 2. Redis的基础 2.1 redis的key命令 2.2 reids的数据结构(6.0新增的数据结构) 1. String(字符串)类型 2. List( ...
RabbitMQ（八）：SpringBoot 整合 RabbitMQ（三种消息确认机制以及消费端限流）
说明本文 SpringBoot 与 RabbitMQ 进行整合的时候,包含了三种消息的确认模式,如果查询详细的确认模式设置,请阅读:RabbitMQ的三种消息确认模式同时消费端也采取了限流的措施, ...
高性能RabbitMQ消息队列介绍及 SpringBoot整合
一.高性能RabbitMQ RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现.AMQP 的出现其实也是应了广大人民群众的需求,虽然在同步消 ...
rabbitmq的启动命令
1.以应用方式启动 rabbitmq-server -detached 后台启动 Rabbitmq-server 直接启动,如果你关闭窗口或者需要在改窗口使用其他命令时应用就会停止关闭:rabbit ...
基于springboot整合的rabbitmq
技术:springboot1.5.2 + maven3.0.5 + rabbitmq3.7.13 + jdk1.8 概述 RabbitMQ是对高级消息队列协议(Advanced Message Que ...

最新文章

热门文章