From b9b263043cbb2e028017b9a5626c664b54513749 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 14 十月 2024 17:46:11 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
index 225e877..935194a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
@@ -49,6 +49,9 @@
import org.quartz.SchedulerException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageProperties;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.cache.ehcache.EhCacheCacheManager;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -65,6 +68,7 @@
import javax.servlet.http.HttpServletRequest;
import java.io.*;
import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
import java.util.*;
@Controller
@@ -111,6 +115,9 @@
@Resource
private TaoBaoCouponCacheService taoBaoCouponCacheService;
+
+ @Resource
+ private RabbitTemplate rabbitTemplate;
@RequestMapping(value = "kefu")
public void kefu(HttpServletRequest request, PrintWriter out) {
@@ -461,4 +468,29 @@
out.print("success");
}
+ @RequestMapping("testRabbit")
+ public void testRabbit(){
+ String msg = "浣犲ソ:"+TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyy-MM-dd HH:mm:ss");
+ // 鍚戦槦鍒楀彂閫佹秷鎭�
+// rabbitTemplate.convertAndSend("order-all-fanli",msg);
+ // 鍚慹xchange鍙戦�佹秷鎭�
+// rabbitTemplate.convertAndSend("topic_place_order", "*", msg);
+
+// Message message = MessageBuilder.withBody(msg.getBytes()).setDeliveryMode(MessageDeliveryMode.PERSISTENT).setExpiration("10000").build();
+ rabbitTemplate.convertAndSend("test_queue",msg);
+ }
+ @RequestMapping("testRabbitDelay")
+ public void testRabbitDelay(){
+ String msg = "杩欐槸娴嬭瘯鐨勪竴鏉″欢鏃舵秷鎭�";
+ int time = 5;
+ MessageProperties messageProperties = new MessageProperties();
+ messageProperties.setHeader("x-delay", 1000 * time);//寤惰繜5绉掕鍒犻櫎
+ Message message = new Message(msg.getBytes(StandardCharsets.UTF_8), messageProperties);
+ rabbitTemplate.convertAndSend("delay_exchange", "delay", message);//浜ゆ崲鏈哄拰璺敱閿繀椤诲拰閰嶇疆鏂囦欢绫讳腑淇濇寔涓�鑷�
+ System.out.println(TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyy-MM-dd HH:mm:ss") + " 鍙戦�佷竴鏉℃秷鎭�");
+ }
+
+
+
+
}
--
Gitblit v1.8.0