package org.springblade.modules.rabbitmq.controller;
|
|
import lombok.AllArgsConstructor;
|
import org.springblade.modules.rabbitmq.config.MQsender;
|
import org.springblade.modules.rabbitmq.redis.TaskKey;
|
import org.springblade.modules.rabbitmq.redis.RedisService;
|
import org.springblade.modules.rabbitmq.vo.Man;
|
import org.springblade.modules.rabbitmq.vo.Task;
|
import org.springblade.modules.rabbitmq.vo.TaskMessage;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Random;
|
|
/**
|
* 消息发送
|
* @author zhongrj
|
*/
|
@RestController
|
@AllArgsConstructor
|
@RequestMapping("/rabbitmq")
|
public class SendMessageController {
|
|
private static int count = 0;
|
|
private final MQsender mQsender;
|
|
private final RedisService redisService;
|
|
|
@GetMapping("/sendDirectMessage")
|
public String sendDirectMessage() {
|
String messageData = "test message, hello!";
|
mQsender.send(messageData);
|
return "ok";
|
}
|
|
/**
|
* 模拟抢单
|
* @return
|
*/
|
@GetMapping("/createTask")
|
public String createTask(Long id ,Integer num) {
|
//创建任务
|
Task task = new Task();
|
task.setId(id);
|
task.setNum(num);
|
task.setTaskName("测试");
|
//将任务数量和对应的id 存入redis
|
redisService.set(TaskKey.getTaskStock,""+task.getId(),task.getNum());
|
//返回
|
return "ok";
|
}
|
|
|
/**
|
* 模拟抢单（不同人员同时抢）
|
* @return
|
*/
|
@GetMapping("/testSend")
|
public String testSend(Long id) {
|
//模拟创建人员
|
Man man = new Man();
|
man.setId(System.currentTimeMillis() + new Random().nextInt(1000000));
|
man.setUsername("task"+ count);
|
// 预减库存
|
long stack = redisService.decr(TaskKey.getTaskStock,""+id);
|
if (stack<0){
|
return "已结束";
|
}
|
//入队列
|
TaskMessage taskMessage = new TaskMessage();
|
taskMessage.setTaskId(id);
|
taskMessage.setManId(man.getId());
|
//发送消息
|
mQsender.sendTaskMessage(taskMessage);
|
//返回
|
return "ok";
|
}
|
}
|
