webflux update

Author: Janloong-Doo

jdk-study/src/main/java/com/janloong/javabase/therad/base/Countdownlatch.java

@@ -0,0 +1,13 @@
+package com.janloong.javabase.therad.base;
+
+
+/**
+ * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+ * @date 2020-04-01 00:34
+ */
+public class Countdownlatch {
+ 
+ public static void main(String[] args) {
+
+ }
+}

spring-demo/spring-security/src/main/java/com/janloong/springsecurity/rabbitmq/config/MqConfig.java

@@ -0,0 +1,20 @@
+package com.janloong.springsecurity.rabbitmq.config;
+
+
+import org.springframework.amqp.core.AnonymousQueue;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+ * @date 2020-04-01 00:15
+ */
+@Component
+public class MqConfig {
+
+ @Bean
+ public Queue doo1() {
+ return new AnonymousQueue(() -> "doo-queue-1");
+ }
+}

spring-demo/spring-security/src/main/java/com/janloong/springsecurity/rabbitmq/controller/HomeController.java

@@ -6,11 +6,15 @@
 import org.springframework.amqp.core.AmqpTemplate;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.core.MessagePropertiesBuilder;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
 /**
  * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
  * @date 2020-03-30 22:48
@@ -22,18 +26,20 @@ public class SendController {
  @Autowired
  private AmqpAdmin amqpAdmin;
  @Autowired
- private AmqpTemplate amqpTemplate;
+ private RabbitTemplate rabbitTemplate;
+
+ private volatile CountDownLatch latch = new CountDownLatch(2);
 
  /**
  * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
  * @date 2020/3/30 0030 22:48
  **/
  @RequestMapping("/msg")
- public ResponseResult msg(@RequestParam String name) {
+ public ResponseResult msg() throws InterruptedException {
  String s = "hello,Janloong! This is default msg!";
  Message message = new Message(s.getBytes(), MessagePropertiesBuilder.newInstance().build());
- amqpTemplate.send(message);
- amqpTemplate.send("doo-exchange","doo-key",message);
+ rabbitTemplate.send("doo-queue-1", message);
+ latch.await(10, TimeUnit.SECONDS);
  return ResponseResult.success("发送成功");
  }
 }

spring-demo/spring-security/src/main/java/com/janloong/springsecurity/rabbitmq/controller/SendController.java

@@ -11,8 +11,8 @@
 @Component
 public class MsgListener {
 
- @RabbitListener()
+ @RabbitListener(queues = "doo-queue-1")
  public void listen(String content) {
- System.out.println(content);
+ System.out.println("收到消息： " + content);
  }
 }