package org.jeecg.modules.test.rabbitmq.controller;
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
|
import org.jeecg.common.api.vo.Result;
|
import org.jeecg.common.base.BaseMap;
|
import org.jeecg.modules.test.rabbitmq.constant.CloudConstant;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import cn.hutool.core.util.RandomUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
|
|
/**
|
* RabbitMqClient发送消息
|
* @author: zyf
|
* @date: 2022/04/21
|
*/
|
@RestController
|
@RequestMapping("/sys/test")
|
@Api(tags = "【微服务】MQ单元测试")
|
public class JeecgMqTestController {
|
|
@Autowired
|
private RabbitMqClient rabbitMqClient;
|
|
|
/**
|
* 测试方法：快速点击发送MQ消息
|
* 观察三个接受者如何分配处理消息：HelloReceiver1、HelloReceiver2、HelloReceiver3，会均衡分配
|
*
|
* @param req
|
* @return
|
*/
|
@GetMapping(value = "/rabbitmq")
|
@ApiOperation(value = "测试rabbitmq", notes = "测试rabbitmq")
|
public Result<?> rabbitMqClientTest(HttpServletRequest req) {
|
//rabbitmq消息队列测试
|
BaseMap map = new BaseMap();
|
map.put("orderId", RandomUtil.randomNumbers(10));
|
rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map);
|
rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER_TIME, map,10);
|
return Result.OK("MQ发送消息成功");
|
}
|
|
@GetMapping(value = "/rabbitmq2")
|
@ApiOperation(value = "rabbitmq消息总线测试", notes = "rabbitmq消息总线测试")
|
public Result<?> rabbitmq2(HttpServletRequest req) {
|
|
//rabbitmq消息总线测试
|
BaseMap params = new BaseMap();
|
params.put("orderId", "123456");
|
rabbitMqClient.publishEvent(CloudConstant.MQ_DEMO_BUS_EVENT, params);
|
return Result.OK("MQ发送消息成功");
|
}
|
}
|
