public/RuoYi-Cloud-Plus
1
0
Fork 0
mirror of https://gitee.com/dromara/RuoYi-Cloud-Plus.git synced 2026-04-26 16:59:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 修改包名为org.dromara

Browse Source
This commit is contained in:
Yjoioooo
2023-04-24 11:29:08 +08:00
parent 0944318dc6
commit fbe8aa4f5f
719 changed files with 2412 additions and 2412 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/RuoYiStreamMqApplication.java Normal file
View File

@@ -0,0 +1,22 @@
package org.dromara.stream;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.metrics.buffering.BufferingApplicationStartup;
/**
* SpringCloud-Stream-MQ 案例项目
*
* @author Lion Li
*/
@SpringBootApplication
public class RuoYiStreamMqApplication {
public static void main(String[] args) {
SpringApplication application = new SpringApplication(RuoYiStreamMqApplication.class);
application.setApplicationStartup(new BufferingApplicationStartup(2048));
application.run(args);
System.out.println("(♥◠‿◠)ﾉﾞ MQ案例模块启动成功 ლ(´ڡ`ლ)ﾞ ");
}
}

60
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/controller/TestMqController.java Normal file
View File

@@ -0,0 +1,60 @@
package org.dromara.stream.controller;
import org.dromara.common.core.domain.R;
import org.dromara.stream.mq.producer.DelayProducer;
import org.dromara.stream.mq.producer.LogStreamProducer;
import org.dromara.stream.mq.producer.TestStreamProducer;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* 测试mq
*/
@Slf4j
@RestController
@AllArgsConstructor
@RequestMapping("/test-mq")
public class TestMqController {
private final DelayProducer delayProducer;
private final TestStreamProducer testStreamProducer;
private final LogStreamProducer logStreamProducer;
/**
* 发送消息Rabbitmq
*
* @param msg 消息内容
* @param delay 延时时间
*/
@GetMapping("/sendRabbitmq")
public R<Void> sendRabbitmq(String msg, Long delay) {
delayProducer.sendMsg(msg, delay);
return R.ok();
}
/**
* 发送消息Rocketmq
*
* @param msg 消息内容
*/
@GetMapping("/sendRocketmq")
public R<Void> sendRocketmq(String msg) {
testStreamProducer.streamTestMsg(msg);
return R.ok();
}
/**
* 发送消息Kafka
*
* @param msg 消息内容
*/
@GetMapping("/sendKafka")
public R<Void> sendKafka(String msg) {
logStreamProducer.streamLogMsg(msg);
return R.ok();
}
}

20
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/TestMessaging.java Normal file
View File

@@ -0,0 +1,20 @@
package org.dromara.stream.mq;
import lombok.Data;
import lombok.experimental.Accessors;
/**
* @author Lion Li
*/
@Data
@Accessors(chain = true)
public class TestMessaging {
/**
* 消息id
*/
private String msgId;
/**
* 消息内容
*/
private String msgText;
}

22
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/consumer/DelayConsumer.java Normal file
View File

@@ -0,0 +1,22 @@
package org.dromara.stream.mq.consumer;
import org.dromara.stream.mq.TestMessaging;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.util.function.Consumer;
@Slf4j
@Component
public class DelayConsumer {
@Bean
Consumer<TestMessaging> delay() {
log.info("初始化订阅");
return obj -> {
log.info("消息接收成功：" + obj);
};
}
}

22
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/consumer/LogStreamConsumer.java Normal file
View File

@@ -0,0 +1,22 @@
package org.dromara.stream.mq.consumer;
import org.dromara.stream.mq.TestMessaging;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.util.function.Consumer;
@Slf4j
@Component
public class LogStreamConsumer {
@Bean
Consumer<TestMessaging> log() {
log.info("初始化订阅");
return msg -> {
log.info("通过stream消费到消息 => {}", msg.toString());
};
}
}

22
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/consumer/TestStreamConsumer.java Normal file
View File

@@ -0,0 +1,22 @@
package org.dromara.stream.mq.consumer;
import org.dromara.stream.mq.TestMessaging;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.util.function.Consumer;
@Slf4j
@Component
public class TestStreamConsumer {
@Bean
Consumer<TestMessaging> demo() {
log.info("初始化订阅");
return msg -> {
log.info("通过stream消费到消息 => {}", msg.toString());
};
}
}

27
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/producer/DelayProducer.java Normal file
View File

@@ -0,0 +1,27 @@
package org.dromara.stream.mq.producer;
import org.dromara.stream.mq.TestMessaging;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;
import java.util.UUID;
@Component
public class DelayProducer {
@Autowired
private StreamBridge streamBridge;
public void sendMsg(String msg, Long delay) {
// 构建消息对象
TestMessaging testMessaging = new TestMessaging()
.setMsgId(UUID.randomUUID().toString())
.setMsgText(msg);
Message<TestMessaging> message = MessageBuilder.withPayload(testMessaging)
.setHeader("x-delay", delay).build();
streamBridge.send("delay-out-0", message);
}
}

24
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/producer/LogStreamProducer.java Normal file
View File

@@ -0,0 +1,24 @@
package org.dromara.stream.mq.producer;
import org.dromara.stream.mq.TestMessaging;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;
import java.util.UUID;
@Component
public class LogStreamProducer {
@Autowired
private StreamBridge streamBridge;
public void streamLogMsg(String msg) {
// 构建消息对象
TestMessaging testMessaging = new TestMessaging()
.setMsgId(UUID.randomUUID().toString())
.setMsgText(msg);
streamBridge.send("log-out-0", MessageBuilder.withPayload(testMessaging).build());
}
}

24
ruoyi-example/ruoyi-stream-mq/src/main/java/org/dromara/stream/mq/producer/TestStreamProducer.java Normal file
View File

@@ -0,0 +1,24 @@
package org.dromara.stream.mq.producer;
import org.dromara.stream.mq.TestMessaging;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;
import java.util.UUID;
@Component
public class TestStreamProducer {
@Autowired
private StreamBridge streamBridge;
public void streamTestMsg(String msg) {
// 构建消息对象
TestMessaging testMessaging = new TestMessaging()
.setMsgId(UUID.randomUUID().toString())
.setMsgText(msg);
streamBridge.send("demo-out-0", MessageBuilder.withPayload(testMessaging).build());
}
}