死信测试

pom.xml

@@ -25,6 +25,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
@@ -54,11 +58,20 @@
             <artifactId>hutool-all</artifactId>
             <version>4.1.1</version>
         </dependency>
-<!--        <dependency>-->
-<!--            <groupId></groupId>-->
-<!--            <artifactId></artifactId>-->
-<!--        </dependency>-->
-
+        <dependency>
+            <groupId>com.sun.mail</groupId>
+            <artifactId>javax.mail</artifactId>
+            <version>1.6.2</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.72</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/example/springbootdemo/SpringbootdemoApplication.java

@@ -6,7 +6,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.annotation.ComponentScan;
 @SpringBootApplication(scanBasePackages = {"com.example"})
-@ComponentScan({"com.example.demo","com.example.springbootdemo"})
+@ComponentScan({"com.example"})
 public class SpringbootdemoApplication {
     public static void main(String[] args) {
         ConfigurableApplicationContext run  = SpringApplication.run(SpringbootdemoApplication.class, args);

src/main/java/com/example/springbootdemo/config/AsyncConfiguration.java

@@ -0,0 +1,31 @@
+package com.example.springbootdemo.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfiguration {
+    @Bean("doSomethingExecutor")
+    public Executor doExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);
+        // 最大线程数：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程
+        executor.setMaxPoolSize(20);
+        // 缓冲队列：用来缓冲执行任务的队列
+        executor.setQueueCapacity(500);
+        // 允许线程的空闲时间60秒：当超过了核心线程之外的线程在空闲时间到达之后会被销毁
+        executor.setKeepAliveSeconds(60);
+        // 线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
+        executor.setThreadNamePrefix("do-something-");
+        // 缓冲队列满了之后的拒绝策略：由调用线程处理（一般是主线程）
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/example/springbootdemo/config/CustomRabbitListener.java

@@ -0,0 +1,25 @@
+package com.example.springbootdemo.config;
+
+import com.rabbitmq.client.Channel;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.messaging.handler.annotation.Headers;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component
+public class CustomRabbitListener {
+//    @org.springframework.amqp.rabbit.annotation.RabbitListener(queues = "crm_foot_info_14049")
+//    public void a(Message message) {
+//        System.out.println(message);
+//    }
+//    @org.springframework.amqp.rabbit.annotation.RabbitListener(
+//            queues = RabbitMQConfiguration.dealQueueOrder
+//    )
+//    public void process(String order, Message message, @Headers Map<String, Object> headers, Channel channel) {
+//        System.out.println(order);
+//    }
+}

src/main/java/com/example/springbootdemo/config/MyBeanConfig.java

@@ -0,0 +1,12 @@
+package com.example.springbootdemo.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MyBeanConfig {
+    @Bean
+    public String getName() {
+        return "nimadeo";
+    }
+}

src/main/java/com/example/springbootdemo/config/RabbitMQConfiguration.java

@@ -0,0 +1,87 @@
+package com.example.springbootdemo.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class RabbitMQConfiguration {
+    //队列名称
+    public   final static String orderQueue = "order_queue";
+
+    //交换机名称
+    public  final static String orderExchange = "order_exchange";
+
+    // routingKey
+    public  final static String routingKeyOrder = "routing_key_order";
+
+    //死信消息队列名称
+    public  final static String dealQueueOrder = "deal_queue_order";
+
+    //死信交换机名称
+    public  final static String dealExchangeOrder = "deal_exchange_order";
+
+    //死信 routingKey
+    public final static String deadRoutingKeyOrder = "dead_routing_key_order";
+
+    //死信队列 交换机标识符
+    public static final String DEAD_LETTER_QUEUE_KEY = "x-dead-letter-exchange";
+
+    //死信队列交换机绑定键标识符
+    public static final String DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
+
+    @Autowired
+    private CachingConnectionFactory connectionFactory;
+
+    @Bean
+    public Queue orderQueue() {
+        // 将普通队列绑定到死信队列交换机上
+        Map<String, Object> args = new HashMap<>(2);
+        //args.put("x-message-ttl", 5 * 1000);//直接设置 Queue 延迟时间 但如果直接给队列设置过期时间,这种做法不是很灵活
+        //这里采用发送消息动态设置延迟时间,这样我们可以灵活控制
+        args.put(DEAD_LETTER_QUEUE_KEY, dealExchangeOrder);
+        args.put(DEAD_LETTER_ROUTING_KEY, deadRoutingKeyOrder);
+        return new Queue(RabbitMQConfiguration.orderQueue, true, false, false, args);
+    }
+
+    //声明一个direct类型的交换机
+    @Bean
+    DirectExchange orderExchange() {
+        return new DirectExchange(RabbitMQConfiguration.orderExchange);
+    }
+    @Bean
+    FanoutExchange fanoutT1Exchange() {
+        return new FanoutExchange("TT1");
+    }
+
+    //绑定Queue队列到交换机,并且指定routingKey
+    @Bean
+    Binding bindingDirectExchangeDemo5(   ) {
+        return BindingBuilder.bind(orderQueue()).to(orderExchange()).with(routingKeyOrder);
+    }
+
+    //创建配置死信队列
+    @Bean
+    public Queue deadQueueOrder() {
+        Queue queue = new Queue(dealQueueOrder, true);
+        return queue;
+    }
+
+    //创建死信交换机
+    @Bean
+    public DirectExchange deadExchangeOrder() {
+        return new DirectExchange(dealExchangeOrder);
+    }
+
+    //死信队列与死信交换机绑定
+    @Bean
+    public Binding bindingDeadExchange() {
+        return BindingBuilder.bind(deadQueueOrder()).to(deadExchangeOrder()).with(deadRoutingKeyOrder);
+    }
+
+}

src/main/java/com/example/springbootdemo/controller/HelloController.java

@@ -4,19 +4,30 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.example.springbootdemo.entity.FootScanEntity;
 import com.example.springbootdemo.entity.FootScanGroup;
+import com.example.springbootdemo.form.PostForm;
 import com.example.springbootdemo.mapper.FootScanMapper;
+import com.example.springbootdemo.query.DateQuery;
 import com.example.springbootdemo.service.FootScanGroupService;
 import com.example.springbootdemo.service.FootScanService;
 import com.example.springbootdemo.zxyTeST.sql.dao.ArmGrabRepository;
 import com.example.springbootdemo.zxyTeST.sql.dao.ColorRepository;
 import com.example.springbootdemo.zxyTeST.sql.entity.ArmGrabEntity;
 import com.example.springbootdemo.zxyTeST.sql.entity.Color;
+import com.example.util.MailUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.web.bind.annotation.*;
 
+import javax.mail.Address;
+import javax.mail.Session;
+import javax.mail.Transport;
+import javax.mail.internet.MimeMessage;
+import java.text.SimpleDateFormat;
 import java.util.List;
+import java.util.Properties;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.logging.SimpleFormatter;
 
 @RestController
 public class HelloController {
@@ -32,7 +43,8 @@ public class HelloController {
     FootScanGroupService footScanGroupService;
     @Autowired
     FootScanMapper footScanMapper;
-
+    @Autowired
+    MailUtil mailUtil;
 
     @RequestMapping("/hello")
     public void hello() {
@@ -81,6 +93,40 @@ public class HelloController {
 //        footScanService.page(footScanEntityPage,null);
 //        return  footScanEntityPage.getRecords();
 //    }
+    @RequestMapping("testDate")
+    public String testDate(DateQuery dateQuery) {
+        SimpleDateFormat simpleFormatter = new SimpleDateFormat("今天是 yyyy 年 MM 月 dd 日 E HH 点 mm 分 ss 秒");
+        return simpleFormatter.format(dateQuery.getDate());
+    }
+    @PostMapping("postTest")
+    public void testPost(@RequestBody PostForm postForm) {
+        ConcurrentHashMap<String, String> stringStringConcurrentHashMap = new ConcurrentHashMap<>();
+        stringStringConcurrentHashMap.put("1","123");
+        System.out.println(postForm.getName());
+    }
+
+    @RequestMapping("testMail")
+    public void testMail() {
+        Properties properties = new Properties();
+        properties.setProperty("mail.transport.protocol", "smtp");   // 使用的协议（JavaMail规范要求）
+        properties.setProperty("mail.smtp.host", "smtp.exmail.qq.com");   // 发件人的邮箱的 SMTP 服务器地址
+        properties.setProperty("mail.smtp.auth", "true");
+        Session session = Session.getDefaultInstance(properties);
+        session.setDebug(true);                                 // 设置为debug模式, 可以查看详细的发送 log
+        try {
+            MimeMessage message = mailUtil.createMimeMessage(session, "software@semsx.com",
+                    "771799477@qq.com,1152047207@qq.com");
+            Transport transport = session.getTransport();
+            transport.connect("software@semsx.com","RNDmdjNarRkqg4ge");
+            Address[] allRecipients = message.getAllRecipients();
+        //    transport.sendMessage(message,message.getAllRecipients());
+            transport.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+
 
 }
 

src/main/java/com/example/springbootdemo/controller/MybatisPlusController.java

@@ -7,6 +7,7 @@ import com.example.springbootdemo.entity.FootScanEntity;
 import com.example.springbootdemo.mapper.DeviceMapper;
 import com.example.springbootdemo.service.FootScanService;
 import com.example.springbootdemo.service.GoodsBindsShoesLastService;
+import org.apache.tomcat.util.codec.binary.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;

src/main/java/com/example/springbootdemo/controller/TestBeanController.java

@@ -0,0 +1,16 @@
+package com.example.springbootdemo.controller;
+
+import com.example.springbootdemo.config.MyBeanConfig;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class TestBeanController {
+    @Autowired
+    MyBeanConfig myBeanConfig;
+    @RequestMapping("/mybean")
+    public void myBean() {
+        System.out.println(myBeanConfig.getName());
+    }
+}

src/main/java/com/example/springbootdemo/controller/TrainJavaController.java

@@ -1,13 +1,18 @@
 package com.example.springbootdemo.controller;
 
+import com.example.springbootdemo.config.RabbitMQConfiguration;
 import com.example.springbootdemo.zxyTeST.sql.dao.FootScanCommonRepository;
 import com.example.springbootdemo.zxyTeST.sql.entity.FootScanCommonEntity;
 import com.example.springbootdemo.zxyTeST.ymlConfig.SemsxUser;
+import com.rabbitmq.client.Channel;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 
 @RestController
 public class TrainJavaController {
@@ -15,6 +20,8 @@ public class TrainJavaController {
     FootScanCommonRepository footScanCommonRepository;
     @Autowired
     SemsxUser semsxUser;
+    @Autowired
+    RabbitTemplate rabbitTemplate;
     @RequestMapping("/footScan")
     public String getFootScanInfo() {
         FootScanCommonEntity  footScanCommonInfo = footScanCommonRepository.findByFootScanId(14815);
@@ -33,4 +40,21 @@ public class TrainJavaController {
         return  semsxUser;
     }
 
+    @RequestMapping("/dtl")
+    public String dtl(Message message1, Channel channel) {
+        String orderId = UUID.randomUUID().toString();
+        rabbitTemplate.convertAndSend(
+                RabbitMQConfiguration.orderExchange, //发送至订单交换机
+                RabbitMQConfiguration.routingKeyOrder, //订单定routingKey
+                orderId //订单号   这里可以传对象 比如直接传订单对象
+                , message -> {
+                    // 如果配置了 params.put("x-message-ttl", 5 * 1000);
+                    // 那么这一句也可以省略,具体根据业务需要是声明 Queue 的时候就指定好延迟时间还是在发送自己控制时间
+                    message.getMessageProperties().setExpiration(5 * 10 + "");
+                    String msg = new String(message.getBody());
+                    return message;
+                });
+
+        return "{'orderId':'"+orderId+"'}";
+    }
 }

src/main/java/com/example/springbootdemo/entity/Person.java

@@ -0,0 +1,17 @@
+package com.example.springbootdemo.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+@Data
+public class Person {
+    @JSONField(name = "aage")
+    private int age;
+    @JSONField(name = "nname")
+    private String name;
+
+    public Person(int age, String name) {
+        this.age = age;
+        this.name = name;
+    }
+}

src/main/java/com/example/springbootdemo/form/PostForm.java

@@ -0,0 +1,8 @@
+package com.example.springbootdemo.form;
+
+import lombok.Data;
+
+@Data
+public class PostForm {
+    private String name;
+}

src/main/java/com/example/springbootdemo/query/DateQuery.java

@@ -0,0 +1,12 @@
+package com.example.springbootdemo.query;
+
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+@Data
+public class DateQuery {
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date date;
+}

src/main/java/com/example/util/MailUtil.java

@@ -0,0 +1,34 @@
+package com.example.util;
+
+import com.example.springbootdemo.config.MailConfig;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.mail.Session;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+import java.util.Date;
+@Component
+public class MailUtil {
+    @Autowired
+    MailConfig mailConfig;
+    public MimeMessage createMimeMessage(Session session, String sendMail, String users) throws Exception {
+        // 1. 创建一封邮件
+        MimeMessage message = new MimeMessage(session);
+        // 2. From: 发件人
+        message.setFrom(new InternetAddress(sendMail, "【semsx】", "UTF-8"));
+        // 3. To: 收件人（可以增加多个收件人、抄送、密送）
+//        Address[] internetAddresses = new InternetAddress().parse(users);
+        message.setRecipients(MimeMessage.RecipientType.TO, users);
+        // 4. Subject: 邮件主题
+        message.setSubject("打折钜惠", "UTF-8");
+        // 5. Content: 邮件正文（可以使用html标签）
+        message.setContent("XX用户你好 <br/> 今天全场5折,<br/> 快来抢购, 错过今天再等一年。。。", "text/html;charset=UTF-8");
+        // 6. 设置发件时间
+        message.setSentDate(new Date());
+        // 7. 保存设置
+        message.saveChanges();
+        return message;
+    }
+
+}

src/main/resources/application-dev.yml

@@ -8,7 +8,7 @@ semsx :
     - 5
     - 6
 server:
-  port: 8082
+  port: 7041
 spring:
   datasource:
     druid:
@@ -20,7 +20,7 @@ spring:
       driver-class-name: com.mysql.cj.jdbc.Driver
       url: jdbc:mysql://192.168.0.201:3306/ceshi?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
       username: root
-      password:
+      password: 123456
   jpa:
     database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
     open-in-view: false

src/main/resources/application.yml

@@ -11,13 +11,20 @@ server:
   port: 8081
 spring:
   datasource:
-    url: jdbc:mysql://192.168.2.130:3306/ceshi?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
+    url: jdbc:mysql://192.168.0.201:3306/ceshi?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
     username: root
     password: 123456
     driver-class-name: com.mysql.cj.jdbc.Driver
   jpa:
     database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
     open-in-view: false
+  rabbitmq:
+    host: 192.168.0.100
+    port: 5672
+    username: guest
+    password: guest
+    publisher-returns: true
+    virtual-host: /scanmq
 mybatis-plus:
   configuration:
     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl