新增commit

blade-service/blade-rocket-mq/pom.xml

@@ -0,0 +1,84 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>blade-service</artifactId>
+        <groupId>org.springblade</groupId>
+        <version>2.8.2.RELEASE</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+
+    <artifactId>blade-rocket-mq</artifactId>
+    <name>${project.artifactId}</name>
+    <version>2.8.2.RELEASE</version>
+    <dependencies>
+    <dependency>
+        <groupId>org.springblade</groupId>
+        <artifactId>blade-core-boot</artifactId>
+    </dependency>
+    <dependency>
+        <groupId>org.springblade</groupId>
+        <artifactId>blade-starter-swagger</artifactId>
+    </dependency>
+    <dependency>
+        <groupId>org.springblade</groupId>
+        <artifactId>blade-purchase-sales-api</artifactId>
+        <version>2.8.2.RELEASE</version>
+    </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-client-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-user-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>trade-purchase-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-starter-transaction</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-mocha-item-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-deliver-goods-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-starter-excel</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>blade-stock-api</artifactId>
+            <version>2.8.2.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <!--rocketMQ -->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.1.1</version>
+        </dependency>
+
+    </dependencies>
+
+</project>

blade-service/blade-rocket-mq/src/main/java/org/springblade/rocket/RocketMQpplication.java

@@ -0,0 +1,45 @@
+/*
+ *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
+ *
+ *  Redistribution and use in source and binary forms, with or without
+ *  modification, are permitted provided that the following conditions are met:
+ *
+ *  Redistributions of source code must retain the above copyright notice,
+ *  this list of conditions and the following disclaimer.
+ *  Redistributions in binary form must reproduce the above copyright
+ *  notice, this list of conditions and the following disclaimer in the
+ *  documentation and/or other materials provided with the distribution.
+ *  Neither the name of the dreamlu.net developer nor the names of its
+ *  contributors may be used to endorse or promote products derived from
+ *  this software without specific prior written permission.
+ *  Author: Chill 庄骞 (smallchill@163.com)
+ */
+package org.springblade.purchase.sales;
+
+import okio.Sink;
+import org.springblade.common.constant.LauncherConstant;
+import org.springblade.core.cloud.feign.EnableBladeFeign;
+import org.springblade.core.launch.BladeApplication;
+import org.springblade.core.transaction.annotation.SeataCloudApplication;
+import org.springframework.cloud.client.SpringCloudApplication;
+
+/**
+ * Desk启动器
+ *
+ * @author Chill
+ */
+
+/**
+ * 销售订单模块
+ */
+@EnableBladeFeign
+@SpringCloudApplication
+@SeataCloudApplication
+public class RocketMQpplication {
+
+	public static void main(String[] args) {
+		BladeApplication.run("blade-rocket", RocketMQpplication.class, args);
+	}
+
+}
+

blade-service/blade-rocket-mq/src/main/java/org/springblade/rocket/controller/TestRocketConsumer.java

@@ -0,0 +1,20 @@
+package org.springblade.rocket.controller;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Service;
+
+@Service
+@Slf4j
+@RocketMQMessageListener(consumerGroup = "consumer-group", topic = "test-msg")
+public class TestRocketConsumer implements RocketMQListener<String>
+{
+
+	@Override
+	public void onMessage(String str)
+	{
+       //监听消息
+		log.info("监听到主题为'test-msg'的消息：" + str);
+	}
+}

blade-service/blade-rocket-mq/src/main/java/org/springblade/rocket/producer/TestRocketProducer.java

@@ -0,0 +1,24 @@
+package org.springblade.rocket.producer;
+
+import lombok.RequiredArgsConstructor;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@Controller
+@RequiredArgsConstructor(onConstructor = @__(@Autowired))
+public class TestRocketProducer
+{
+
+	private final RocketMQTemplate rocketMQTemplate;
+
+	@PostMapping("/rocketmq/producer")
+	public String test() {
+		rocketMQTemplate.convertAndSend(
+			"test-msg",
+			"发送测试rocketMQ");
+
+		return "success";
+	}
+}

blade-service/blade-rocket-mq/src/main/resources/application-dev.yml

@@ -0,0 +1,24 @@
+#服务器端口
+server:
+  port: 7719
+  profile: D:/ruoyi/uploadPath
+
+#数据源配置
+spring:
+  datasource:
+    url: ${blade.datasource.dev.url}
+    username: ${blade.datasource.dev.username}
+    password: ${blade.datasource.dev.password}
+#mybatis-plus:
+#  mapper-locations: classpath:com/yh/project/mapper/*Mapper.xml
+#  type-aliases-package: com.yh.project.*.entity
+#swagger文档
+swagger:
+  base-packages:
+    - org.springblade.purchase.sales
+
+
+rocketmq:
+  name-server: 127.0.0.1:9876
+  producer:
+    group: producer-group

blade-service/blade-rocket-mq/src/main/resources/application-prod.yml

@@ -0,0 +1,10 @@
+#服务器端口
+server:
+  port: 7719
+
+#数据源配置
+spring:
+  datasource:
+    url: ${blade.datasource.prod.url}
+    username: ${blade.datasource.prod.username}
+    password: ${blade.datasource.prod.password}

blade-service/blade-rocket-mq/src/main/resources/application-test.yml

@@ -0,0 +1,10 @@
+#服务器端口
+server:
+  port: 7719
+
+#数据源配置
+spring:
+  datasource:
+    url: ${blade.datasource.test.url}
+    username: ${blade.datasource.test.username}
+    password: ${blade.datasource.test.password}

blade-service/blade-rocket-mq/src/main/resources/mapper.xmk

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
+<!--
+    注意: 这个配置文件并不会被实际使用到, 写这个文件仅仅是为了让 IDEA 的 Mybatis 插件找到实体类的位置
+ -->
+<configuration>
+    <typeAliases>
+        <package name="org.springblade.purchase.sales.entity"/> <!--替换成你的项目的实体类的路径-->
+    </typeAliases>
+</configuration>