From 38d775fa2ccd433c727a5b7cec8bed02493df1ec Mon Sep 17 00:00:00 2001
From: zhongrj <123456>
Date: Thu, 18 Aug 2022 09:00:40 +0800
Subject: [PATCH] mq 相关配置去除，启动配置修改
---
src/main/java/org/springblade/modules/rabbitmq/controller/SendMessageController.java | 162 +++++++++++++++++++++++++++---------------------------
1 files changed, 81 insertions(+), 81 deletions(-)
diff --git a/src/main/java/org/springblade/modules/rabbitmq/controller/SendMessageController.java b/src/main/java/org/springblade/modules/rabbitmq/controller/SendMessageController.java
index bcebf74..fadee40 100644
--- a/src/main/java/org/springblade/modules/rabbitmq/controller/SendMessageController.java
+++ b/src/main/java/org/springblade/modules/rabbitmq/controller/SendMessageController.java
@@ -1,81 +1,81 @@
-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";
- }
-}
+//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";
+// }
+//}
--
Gitblit v1.9.3