将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/controller/TestController.java

@@ -33,6 +33,7 @@
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.db.MongoDBManager;
import com.yeshi.fanli.util.email.MailSenderUtil;
import com.yeshi.fanli.util.push.OPPOPushUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.goods.facade.entity.taobao.TaoBaoCouponCache;
@@ -46,6 +47,11 @@
import org.quartz.JobExecutionContext;
import org.quartz.Scheduler;
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;
@@ -62,6 +68,7 @@
import javax.servlet.http.HttpServletRequest;
import java.io.*;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.util.*;

@Controller
@@ -108,6 +115,9 @@

    @Resource
    private TaoBaoCouponCacheService taoBaoCouponCacheService;

    @Resource
    private RabbitTemplate rabbitTemplate;

    @RequestMapping(value = "kefu")
    public void kefu(HttpServletRequest request, PrintWriter out) {
@@ -368,7 +378,7 @@
        }

        try {
            OPPOPushUtil.pushGoods(registerIds, "测试商品网页推送", "测试商品推送内容", 1, 577628549116L, androidBaseActivity);
            OPPOPushUtil.pushGoods(registerIds, "测试商品网页推送", "测试商品推送内容", 1, 577628549116L+"", androidBaseActivity);
        } catch (PushException e) {
            e.printStackTrace();
        }
@@ -408,7 +418,7 @@
    }

    @RequestMapping("getTBGoodsCate")
    public void getTaoBaoGoodsCat(Long id, PrintWriter out) {
    public void getTaoBaoGoodsCat(String id, PrintWriter out) {
        TaoBaoGoodsBrief goods = null;
        try {
            goods = TaoKeApiUtil.getSimpleGoodsInfo(id);
@@ -432,9 +442,14 @@
        out.print(data.toString());
    }

    @RequestMapping("log")
    public void log(PrintWriter out) {
    Logger testLogger= LoggerFactory.getLogger("testLog");

    @RequestMapping("wx")
    public void log(HttpServletRequest request, PrintWriter out) {
        LogManager.getLogger(LogType.taobaoAuth).info("123123123");
        String content = WXUtil.getContent(request);
        testLogger.info("wx: "+content);

    }


@@ -443,8 +458,39 @@
        TaoBaoCouponCache cache = new TaoBaoCouponCache();
        cache.setActivityId("123123123");
        cache.setPid("mm_12_12_12");
        cache.setAuctionId(123123L);
        cache.setAuctionId(123123L+"");
        taoBaoCouponCacheService.save(cache);
    }

    @RequestMapping("email")
    public void testEmail(PrintWriter out) {
        MailSenderUtil.sendEmail("1101184511@qq.com", "kuaisheng110@163.com", "CMZASWUPTJSFXCNP", "测试", "测试内容:" + System.currentTimeMillis());
        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);
    // 向exchange发送消息
//        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") + " 发送一条消息");
    }




}