//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";
|
// }
|
//}
|
