diff --git a/message-queue-example/rabbitmq-example/.gitignore b/message-queue-example/rabbitmq-example/.gitignore
new file mode 100644
index 0000000000000000000000000000000000000000..5ff6309b7199129c1afe4f4ec1906e640bec48c6
--- /dev/null
+++ b/message-queue-example/rabbitmq-example/.gitignore
@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
\ No newline at end of file
diff --git a/message-queue-example/rabbitmq-example/pom.xml b/message-queue-example/rabbitmq-example/pom.xml
new file mode 100644
index 0000000000000000000000000000000000000000..ba75b450a6fd7a0360e0d29cc5c6c45b9c5233c5
--- /dev/null
+++ b/message-queue-example/rabbitmq-example/pom.xml
@@ -0,0 +1,28 @@
+
+
+ 4.0.0
+
+ com.opensource
+ message-queue-example
+ 1.0.0-SNAPSHOT
+
+
+ rabbitmq-example
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+ com.opensource
+ rocketmq-example
+ 1.0.0-SNAPSHOT
+ compile
+
+
+
+
\ No newline at end of file
diff --git a/message-queue-example/rabbitmq-example/src/main/java/com/opensource/MQApplication.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/MQApplication.java
new file mode 100644
index 0000000000000000000000000000000000000000..b54e8caa577911768b33dd187ebf3c12e51517ed
--- /dev/null
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/MQApplication.java
@@ -0,0 +1,20 @@
+package com.opensource;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+
+/**
+ * @author Kevin
+ */
+@SpringBootApplication
+@ComponentScan(basePackages = {"com.queue.**"})
+//@ComponentScan(basePackages = {"com.queue.common.*", "com.queue.ribbitmq.*"})
+@Slf4j
+public class MQApplication {
+ public static void main(String[] args) {
+ SpringApplication.run(MQApplication.class, args);
+ }
+
+}
diff --git a/message-queue-example/src/main/java/com/common/entity/AccountTbl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java
similarity index 94%
rename from message-queue-example/src/main/java/com/common/entity/AccountTbl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java
index 322ad03b32d96ef6199b519d75545493c3feabeb..6607ce2f6451616c546480aac79a72cf1bcf228d 100644
--- a/message-queue-example/src/main/java/com/common/entity/AccountTbl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java
@@ -1,4 +1,4 @@
-package com.common.entity;
+package com.opensource.common.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git a/message-queue-example/src/main/java/com/common/entity/OrderTbl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java
similarity index 94%
rename from message-queue-example/src/main/java/com/common/entity/OrderTbl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java
index cc6845450bd56351db8d041d9a785ef2b57dc712..5d3e2a606dbc58a8bfdef9de4f4b7e21dd1b8604 100644
--- a/message-queue-example/src/main/java/com/common/entity/OrderTbl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java
@@ -1,4 +1,4 @@
-package com.common.entity;
+package com.opensource.common.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
diff --git a/message-queue-example/src/main/java/com/common/mapper/AccountTblMapper.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java
similarity index 75%
rename from message-queue-example/src/main/java/com/common/mapper/AccountTblMapper.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java
index 48c162dbedc6a1cc7d33cd4760882b984279985e..a872de2e4e3a48b091935cbb781dea2ad649b857 100644
--- a/message-queue-example/src/main/java/com/common/mapper/AccountTblMapper.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java
@@ -1,8 +1,8 @@
-package com.common.mapper;
+package com.opensource.common.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.common.entity.AccountTbl;
+import com.opensource.common.entity.AccountTbl;
import org.apache.ibatis.annotations.Mapper;
/**
diff --git a/message-queue-example/src/main/java/com/common/mapper/OrderTblMapper.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java
similarity index 75%
rename from message-queue-example/src/main/java/com/common/mapper/OrderTblMapper.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java
index 89d1078d8115d02baa64fddd8cf076828e0fb35a..1da20dacc7092a830d7c01893ec6f4cd1b1a0f1a 100644
--- a/message-queue-example/src/main/java/com/common/mapper/OrderTblMapper.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java
@@ -1,7 +1,7 @@
-package com.common.mapper;
+package com.opensource.common.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.common.entity.OrderTbl;
+import com.opensource.common.entity.OrderTbl;
import org.apache.ibatis.annotations.Mapper;
/**
diff --git a/message-queue-example/src/main/java/com/common/service/IAccountService.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IAccountService.java
similarity index 79%
rename from message-queue-example/src/main/java/com/common/service/IAccountService.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IAccountService.java
index 2cebf8c9d2b7e6d1a1383526b3c14e61ce55b632..771bef19c9cb401bd346d67a73652be5f4159af2 100644
--- a/message-queue-example/src/main/java/com/common/service/IAccountService.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IAccountService.java
@@ -1,7 +1,7 @@
-package com.common.service;
+package com.opensource.common.service;
import com.baomidou.mybatisplus.extension.service.IService;
-import com.common.entity.AccountTbl;
+import com.opensource.common.entity.AccountTbl;
/**
*
diff --git a/message-queue-example/src/main/java/com/common/service/IOrderService.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
similarity index 72%
rename from message-queue-example/src/main/java/com/common/service/IOrderService.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
index f86b8ae2769293e79985d0d6e83a9456aee9a92c..ece692397081c713df0f615d2360c42b0c7752b9 100644
--- a/message-queue-example/src/main/java/com/common/service/IOrderService.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
@@ -1,8 +1,8 @@
-package com.common.service;
+package com.opensource.common.service;
import com.baomidou.mybatisplus.extension.service.IService;
-import com.common.entity.OrderTbl;
-import com.rocketmq.example.vo.OrderVo;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.vo.OrderVo;
/**
*
diff --git a/message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
similarity index 86%
rename from message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
index 12edfae3bf9e41f6287ff0d9ce4848fafe5254ca..66f496426fc3aa68cf9ab21820fc3ba35665e0a0 100644
--- a/message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
@@ -1,10 +1,10 @@
-package com.common.service.impl;
+package com.opensource.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.common.entity.AccountTbl;
-import com.common.mapper.AccountTblMapper;
-import com.common.service.IAccountService;
+import com.opensource.common.entity.AccountTbl;
+import com.opensource.common.mapper.AccountTblMapper;
+import com.opensource.common.service.IAccountService;
import com.saturday.common.exception.BusinessException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
similarity index 83%
rename from message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
index 8fb309b0d1f67a393c1d8ce6cc47ab2e0b7d0b4e..436ef75ae99ec60028c1d86fe38d17fa8b2785ff 100644
--- a/message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
@@ -1,11 +1,11 @@
-package com.common.service.impl;
+package com.opensource.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.common.entity.OrderTbl;
-import com.common.mapper.OrderTblMapper;
-import com.common.service.IOrderService;
-import com.rocketmq.example.vo.OrderVo;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.common.mapper.OrderTblMapper;
+import com.opensource.common.service.IOrderService;
+import com.opensource.vo.OrderVo;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
index 75734c12afb52951f9c31460e6e0a3e855b3ac9f..d4306e682976d20eef3af4af80a6c91bed613cb9 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.opensource.example;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/Producer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/Producer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
index 293ae853eeaf9f11bb67f23ce074a58aa31ef030..74bd527bea05a3355f4544e7ab99b0c737ee6261 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/Producer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.opensource.example;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
index f92e35578ce01a8c785a40924d7bfa793ca4705b..0c75bbec2634824ba7a82ce6db7e07fa9c988a2a 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.opensource.example;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/TestController.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
similarity index 94%
rename from message-queue-example/src/main/java/com/rabbitmq/example/TestController.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
index d838f3f9eb3c2458fb50232325bb788fa110cf35..c705ae0fc684ed230652c7739ca9794a0850a748 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/TestController.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.opensource.example;
import com.saturday.common.util.ResultUtils;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
index c18ea9a25f6fb2285f8ca870df7551d1562a03f9..c4a76cbad5959e2619a26ea4816d6ea62c8d56d5 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.ack;
+package com.opensource.example.ack;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/ack/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/ack/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
index 227048ed7333a3906c8490ac122a10399ca698ff..679f86d0ba86ebc2f1b2d47a6da5d8fb7431b9f0 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
similarity index 87%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
index 0a2771963f96c4111a70828c3830dfaeca4cae46..cb9ea5efb098487d29e4011e239000b3c1aabe3b 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.HashMap;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
index acce7bc31ba8b03b9da73d606aad8f43bdab4c5d..f1205c0fe113391260ba7157aecfbaa0a8603eac 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/note.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/note.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/note.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/note.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
index 75ba0dbeb7979ff4e42b1a713f36092ac5deec5e..3c8233c0617a8b231143ac1a69cab9b65e63845c 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example.common;
+package com.opensource.example.common;
public class Constants {
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
similarity index 97%
rename from message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
index f3cca8844a50701658ae3263185e77b4b2f45361..16f30d50190a0b9a1325cea3642b41e07c2e78ca 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example.common;
+package com.opensource.example.common;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
index 209b99fc8e2553572f34c0a26fecbbaa8c1e8dd3..cf9a9e584be3184b6054cedec4be90f4032d095b 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
index c6f3576c476c2e2b4b26fb9650ff2be0a5b1f24b..0a3f2d77e295664e0a3d00c6dacd03f358746ec3 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
index 3a159a9e139e3568ce2fe590c6b39e0e1e7c0016..1623dc15aa270de529cad337125f9f22f9cadfbf 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
similarity index 85%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
index b117d091cc01f2cefab91698d8381c11eed76d31..a47ae7c4d4feff187067dcb531e8f02d757328d9 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
index 4e7b844cb4b5cb2f96f23703336d7a1cd73cc265..105db3f42fd13a4b5f60b1e18435fd3a90822d24 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
index eecff5ff6501c8856eb25d6121ffdeee34e7b68b..52e48e205e43c9a55be9cf46910d8dbcae7eafcf 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
index 39004cb21db993fbe70c072fea8e9df3be75e3f3..071cfede9720bcb548a9a785a016f864e8f01fe0 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
index 1660f83f93e40c029c0bb08bdc42098d71b77fe5..7b4955889b0f42fc047675b2f0058176db739223 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
similarity index 87%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
index 738897c4f244066a285ba1222ef74878db92919c..7ba737ffa0462c4d10cf4aa43e7c6cd8d8d23b02 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.message;
+package com.opensource.example.message;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
index 1bb42b233d7eec881b81cfcbf8b5a89279050cc7..641160604335398811b30044c11b162b2e3bd48c 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.message;
+package com.opensource.example.message;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
index 86a281846fa785cecb8e13a43990f1043c94ab7c..2a4490b50348314970dc79b7d4ae122e24e491c2 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.message;
+package com.opensource.example.message;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
index 722bee6fd266e8b8f51b7c2dab18ac0a3503377b..75cb9ccc188f4cc85edda2ce13b0c730b64383b4 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.quickstart;
+package com.opensource.example.quickstart;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
index 14841cc2b3118823f73c601c41c087a453631ab3..25a57caf20904d55f0ad3daf6510d43ffc4e0435 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
@@ -1,11 +1,11 @@
-package com.rabbitmq.example.quickstart;
+package com.opensource.example.quickstart;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.MessageProperties;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
similarity index 93%
rename from message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
index f87d464c720700a76a3e6b96311d4a93e41f6dff..d4f4ff9f4e53046ef6cb875f05d007648e67862b 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.reject;
+package com.opensource.example.reject;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/reject/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/reject/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
index 92c33f4dbc7016a8d8cb7f753c95497189486a76..d4ad7debf5e112f028f0bed3692cd383885262c7 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.transaction;
+package com.opensource.example.transaction;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
index 13c47ec7f26b759cd82ee41b298e2221c307593d..d03dc459a7e1f8b809f702462299a3d6caadfbe2 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.transaction;
+package com.opensource.example.transaction;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
index d17655e2417cd7c007fc5dc10afc60b48cfeb317..c937a89c10115536a3581b66ca4988268b0d9f37 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
@@ -1,7 +1,7 @@
-package com.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.SneakyThrows;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
index f297baf44be1c051aa4c7ae368e05163d9246bd5..98c48c8f5c9dcab4ccdba139f2c104a5dea68868 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
@@ -1,7 +1,7 @@
-package com.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.SneakyThrows;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
similarity index 87%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
index 1a04c4edd04aa326d4aa2fe5fecfb8b926619fc5..5805a576751ed77c289841a9db0ade93a527498a 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/readme.txt
diff --git a/message-queue-example/src/main/resources/application.yml b/message-queue-example/rabbitmq-example/src/main/resources/application.yml
similarity index 100%
rename from message-queue-example/src/main/resources/application.yml
rename to message-queue-example/rabbitmq-example/src/main/resources/application.yml
diff --git a/message-queue-example/rabbitmq-example/src/main/resources/mapper/AccountTblMapper.xml b/message-queue-example/rabbitmq-example/src/main/resources/mapper/AccountTblMapper.xml
new file mode 100644
index 0000000000000000000000000000000000000000..5f5a10c9e6286eac1e67da28e100ac9ad66757d5
--- /dev/null
+++ b/message-queue-example/rabbitmq-example/src/main/resources/mapper/AccountTblMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/message-queue-example/src/main/resources/mapper/OrderTblMapper.xml b/message-queue-example/rabbitmq-example/src/main/resources/mapper/OrderTblMapper.xml
similarity index 72%
rename from message-queue-example/src/main/resources/mapper/OrderTblMapper.xml
rename to message-queue-example/rabbitmq-example/src/main/resources/mapper/OrderTblMapper.xml
index 29ac530bd9344027ee6d6a9b73ef12834675f59f..a63f4038aad87ebe2e87781c2064f116352cdc44 100644
--- a/message-queue-example/src/main/resources/mapper/OrderTblMapper.xml
+++ b/message-queue-example/rabbitmq-example/src/main/resources/mapper/OrderTblMapper.xml
@@ -1,5 +1,5 @@
-
+
diff --git a/message-queue-example/rocketmq-example/.gitignore b/message-queue-example/rocketmq-example/.gitignore
new file mode 100644
index 0000000000000000000000000000000000000000..5ff6309b7199129c1afe4f4ec1906e640bec48c6
--- /dev/null
+++ b/message-queue-example/rocketmq-example/.gitignore
@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
\ No newline at end of file
diff --git a/message-queue-example/rocketmq-example/pom.xml b/message-queue-example/rocketmq-example/pom.xml
new file mode 100644
index 0000000000000000000000000000000000000000..b1f6470a893d4403bdc2485ca149fac22c469387
--- /dev/null
+++ b/message-queue-example/rocketmq-example/pom.xml
@@ -0,0 +1,20 @@
+
+
+ 4.0.0
+
+ com.opensource
+ message-queue-example
+ 1.0.0-SNAPSHOT
+
+
+ rocketmq-example
+
+
+ 17
+ 17
+ UTF-8
+
+
+
\ No newline at end of file
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/ConsumerConfig.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ConsumerConfig.java
new file mode 100644
index 0000000000000000000000000000000000000000..e29156fb6266393037a35ef15fa7983b8f04d7d1
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ConsumerConfig.java
@@ -0,0 +1,111 @@
+package com.opensource;//package com.queue.rocketmq.example;
+//
+//import com.queue.rocketmq.example.consumer.RocketAccountConsumerService;
+//import lombok.extern.slf4j.Slf4j;
+//import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
+//import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
+//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
+//import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
+//import org.apache.rocketmq.client.exception.MQClientException;
+//import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
+//import org.apache.rocketmq.common.message.MessageExt;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.util.CollectionUtils;
+//
+//import java.util.List;
+//
+//@Configuration
+//@Slf4j
+//public class ConsumerConfig {
+//
+// @Value("${rocketmq.name-server}")
+// private String nameServer;
+//
+// @Autowired
+// private RocketAccountConsumerService accountConsumerService;
+//
+// @Bean
+// public DefaultMQPushConsumer traceTopicConsumer() throws MQClientException {
+// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("trace-topic-consumer-group", true);
+// consumer.setNamesrvAddr(nameServer);
+// consumer.subscribe("trace-topic", "*");
+// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+// consumer.setConsumeTimestamp("20200722110701");
+// consumer.setMessageListener(new MessageListenerConcurrently() {
+// @Override
+// public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
+// if (!CollectionUtils.isEmpty(list)) {
+// try {
+// for (MessageExt messageExt : list) {
+// log.info("回溯消息:{}", messageExt);
+// }
+// } catch (Exception e) {
+// log.error("处理异常:{}", e);
+// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
+// }
+// }
+// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+// }
+// });
+// consumer.start();
+// return consumer;
+// }
+//
+// @Bean
+// public DefaultMQPushConsumer traceConsumer() throws MQClientException {
+// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("topic-test-consumer-group", true, "trace-topic");
+// consumer.setNamesrvAddr(nameServer);
+// consumer.subscribe("topic-test", "trace");
+//// consumer.setConsumerGroup("topic-test-consumer-group");
+// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+//// consumer.setConsumeTimestamp("20200722093001");
+// consumer.setMessageListener(new MessageListenerConcurrently() {
+// @Override
+// public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
+// if (!CollectionUtils.isEmpty(list)) {
+// try {
+// for (MessageExt messageExt : list) {
+// log.info("消费消息:{}", messageExt);
+// }
+// } catch (Exception e) {
+// log.error("处理异常:{}", e);
+// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
+// }
+// }
+// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+// }
+// });
+// consumer.start();
+// return consumer;
+// }
+//
+// @Bean
+// public DefaultMQPushConsumer defaultMQPushConsumer() throws MQClientException {
+// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer();
+// consumer.setNamesrvAddr(nameServer);
+// consumer.subscribe("account1", "*");
+// consumer.setConsumerGroup("consumer-group");
+// consumer.setMessageListener(accountConsumerService);
+// consumer.start();
+// return consumer;
+// }
+//
+// @Bean
+// public DefaultLitePullConsumer defaultLitePullConsumer() throws MQClientException {
+// DefaultLitePullConsumer pullConsumer = new DefaultLitePullConsumer();
+// pullConsumer.setNamesrvAddr(nameServer);
+// pullConsumer.subscribe("topic-test", "trace");
+// while (true) {
+//// pullConsumer.
+// }
+//// pullConsumer.
+//// pullConsumer.start();
+//// log.info("defaultLitePullConsumer is started...");
+//// return pullConsumer;
+// }
+//
+//}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ExtRocketMqTemplate.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ExtRocketMqTemplate.java
similarity index 84%
rename from message-queue-example/src/main/java/com/rocketmq/example/ExtRocketMqTemplate.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/ExtRocketMqTemplate.java
index dcd2623d18deb81ebf4de31a51de8f4369c8bdcd..92dc0019138cac77cdb5227f74b1daa0057ff107 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/ExtRocketMqTemplate.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ExtRocketMqTemplate.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example;
+package com.opensource;//package com.rocketmq.example;
//
//import org.apache.rocketmq.spring.annotation.ExtRocketMQTemplateConfiguration;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
diff --git a/message-queue-example/src/main/java/com/MQApplication.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/MQApplication.java
similarity index 68%
rename from message-queue-example/src/main/java/com/MQApplication.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/MQApplication.java
index 52a5e71c6b25aa805e1b5837b8467c3f6dcb929a..9835af4e9a568b6d33fe8e6ef166278960ea32c1 100644
--- a/message-queue-example/src/main/java/com/MQApplication.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/MQApplication.java
@@ -1,4 +1,4 @@
-package com;
+package com.opensource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
@@ -10,15 +10,11 @@ import org.springframework.context.annotation.ComponentScan;
* @author Kevin
*/
@SpringBootApplication
-@ComponentScan(basePackages = {"com.common.*", "com.rocketmq.*"})
-//@ComponentScan(basePackages = {"com.common.*", "com.ribbitmq.*"})
+@ComponentScan(basePackages = {"com.opensource.**"})
@Slf4j
public class MQApplication {
public static void main(String[] args) {
SpringApplication.run(MQApplication.class, args);
}
- @Value("${rocketmq.name-server}")
- private String nameServer;
-
}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ProduceConfig.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/ProduceConfig.java
index 3c6e82a859bed3138ef64550fe5e10a6ee2d9052..cfda637a136636938e78f6ac7fab4f8d5412c6b0 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/ProduceConfig.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example;
+package com.opensource;
-import com.common.service.IAccountService;
-import com.rocketmq.example.listener.AccountRocketMQTransactionLister;
+import com.opensource.common.service.IAccountService;
+import com.opensource.listener.AccountRocketMQTransactionLister;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java
new file mode 100644
index 0000000000000000000000000000000000000000..6607ce2f6451616c546480aac79a72cf1bcf228d
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/AccountTbl.java
@@ -0,0 +1,33 @@
+package com.opensource.common.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ *
+ *
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class AccountTbl implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ @TableId(value = "ID", type = IdType.AUTO)
+ private Integer id;
+
+ private String userId;
+
+ private Integer money;
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java
new file mode 100644
index 0000000000000000000000000000000000000000..5d3e2a606dbc58a8bfdef9de4f4b7e21dd1b8604
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/entity/OrderTbl.java
@@ -0,0 +1,39 @@
+package com.opensource.common.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ *
+ *
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class OrderTbl implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ @TableId(value = "ID", type = IdType.AUTO)
+ private Integer id;
+
+ private String userId;
+
+ private String commodityCode;
+
+ private Integer count;
+
+ private Integer money;
+
+ private String orderId;
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java
new file mode 100644
index 0000000000000000000000000000000000000000..a872de2e4e3a48b091935cbb781dea2ad649b857
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/AccountTblMapper.java
@@ -0,0 +1,19 @@
+package com.opensource.common.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.opensource.common.entity.AccountTbl;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Mapper
+public interface AccountTblMapper extends BaseMapper {
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java
new file mode 100644
index 0000000000000000000000000000000000000000..1da20dacc7092a830d7c01893ec6f4cd1b1a0f1a
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/mapper/OrderTblMapper.java
@@ -0,0 +1,18 @@
+package com.opensource.common.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.opensource.common.entity.OrderTbl;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Mapper 接口
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Mapper
+public interface OrderTblMapper extends BaseMapper {
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IAccountService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IAccountService.java
new file mode 100644
index 0000000000000000000000000000000000000000..771bef19c9cb401bd346d67a73652be5f4159af2
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IAccountService.java
@@ -0,0 +1,23 @@
+package com.opensource.common.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.opensource.common.entity.AccountTbl;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+public interface IAccountService extends IService {
+
+ /**
+ * 从用户账户中借出
+ */
+ void debit(String userId, int money);
+
+ AccountTbl get(AccountTbl accountTbl);
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IOrderService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IOrderService.java
new file mode 100644
index 0000000000000000000000000000000000000000..ece692397081c713df0f615d2360c42b0c7752b9
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/IOrderService.java
@@ -0,0 +1,24 @@
+package com.opensource.common.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.vo.OrderVo;
+
+/**
+ *
+ * 服务类
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+public interface IOrderService extends IService {
+
+ /**
+ * 创建订单
+ */
+ OrderTbl create(OrderVo orderVo);
+
+ boolean hasOrder(String orderId);
+
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
new file mode 100644
index 0000000000000000000000000000000000000000..66f496426fc3aa68cf9ab21820fc3ba35665e0a0
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
@@ -0,0 +1,46 @@
+package com.opensource.common.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.opensource.common.entity.AccountTbl;
+import com.opensource.common.mapper.AccountTblMapper;
+import com.opensource.common.service.IAccountService;
+import com.saturday.common.exception.BusinessException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Service
+public class AccountServiceImpl extends ServiceImpl implements IAccountService {
+
+ @Override
+ @Transactional
+ public void debit(String userId, int money) {
+ QueryWrapper accountQuery = new QueryWrapper<>();
+ accountQuery.eq("USER_ID", userId);
+ AccountTbl accountTbl = getOne(accountQuery);
+ if (accountTbl == null) {
+ throw new BusinessException("无账户信息");
+ }
+ accountTbl.setMoney(accountTbl.getMoney() - money);
+
+ if (accountTbl.getMoney() < 0) {
+ throw new BusinessException("账户余额不足");
+ }
+
+ updateById(accountTbl);
+ }
+
+ @Override
+ public AccountTbl get(AccountTbl accountTbl) {
+ AccountTbl result = getOne(new QueryWrapper<>(accountTbl));
+ return result;
+ }
+}
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
new file mode 100644
index 0000000000000000000000000000000000000000..436ef75ae99ec60028c1d86fe38d17fa8b2785ff
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
@@ -0,0 +1,50 @@
+package com.opensource.common.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.common.mapper.OrderTblMapper;
+import com.opensource.common.service.IOrderService;
+import com.opensource.vo.OrderVo;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ *
+ * 服务实现类
+ *
+ *
+ * @author wanggd
+ * @since 2019-12-13
+ */
+@Service
+public class OrderServiceImpl extends ServiceImpl implements IOrderService {
+
+ @Override
+ @Transactional
+ public OrderTbl create(OrderVo orderVo) {
+
+ OrderTbl param = new OrderTbl();
+ param.setOrderId(orderVo.getOrderId());
+ if (getOne(new QueryWrapper<>(param)) != null) {
+ throw new RuntimeException("订单已存在");
+ }
+
+ OrderTbl order = new OrderTbl();
+ BeanUtils.copyProperties(orderVo, order);
+
+ save(order);
+ return order;
+ }
+
+ @Override
+ public boolean hasOrder(String orderId) {
+ OrderTbl param = new OrderTbl();
+ param.setOrderId(orderId);
+ if (getOne(new QueryWrapper<>(param)) != null) {
+ return true;
+ }
+ return false;
+ }
+}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService.java
index a44b3fc4fe8d4dacaf81a33482647886bbb55ca1..b6bdbe5bdd3bf8531aa7739145308270f014db90 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.consumer;
+package com.opensource.consumer;//package com.queue.rocketmq.example.consumer;
//
//import com.common.service.IAccountService;
//import com.rocketmq.example.vo.AccountVo;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService1.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService1.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService1.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService1.java
index 18d10accd084f3782aa4c07c66247cf4c4017f13..6b1bcb4cf0341d3f2702675cc8aa0a9f47367f2c 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService1.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/AccountConsumerService1.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.consumer;
+package com.opensource.consumer;
//
//import com.common.service.IAccountService;
//import com.rocketmq.example.vo.AccountVo;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/OrderConsumerService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/OrderConsumerService.java
similarity index 96%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/OrderConsumerService.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/OrderConsumerService.java
index b2b074069856f54ef1f1fc359fd3e1966308fe71..6158a102853f7b6ead5d313ec19971e6f674dffe 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/OrderConsumerService.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/OrderConsumerService.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.consumer;
+package com.opensource.consumer;
//
//import com.common.service.IAccountService;
//import com.rocketmq.example.vo.OrderVo;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/RocketAccountConsumerService.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/RocketAccountConsumerService.java
index 9506cc6e215b21b4d10affa1fda846f523295048..4b34156d2e4ff0e2ce74366153572eb839416eac 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/RocketAccountConsumerService.java
@@ -1,9 +1,8 @@
-package com.rocketmq.example.consumer;
+package com.opensource.consumer;
-import com.common.service.IAccountService;
-import com.rocketmq.example.vo.AccountVo;
+import com.opensource.common.service.IAccountService;
+import com.opensource.vo.AccountVo;
import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/Storage2Service.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/Storage2Service.java
similarity index 87%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/Storage2Service.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/Storage2Service.java
index 3e4034b218ceca514959a5dd0c4374170c8d08d2..4b0a35aa619f6c6e5cfe5a8d386dbad7eee4a428 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/Storage2Service.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/Storage2Service.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.consumer;
+package com.opensource.consumer;//package com.queue.rocketmq.example.consumer;
//
//import com.rocketmq.example.vo.ProductVo;
//import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageReplyService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageReplyService.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageReplyService.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageReplyService.java
index 0e2cdb8d2cee830efdc0f7a92315605a0898380a..940cf82264db1d422b07f5364f7757b7a033b81e 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageReplyService.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageReplyService.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.consumer;
+package com.opensource.consumer;//package com.queue.rocketmq.example.consumer;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageService.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageService.java
new file mode 100644
index 0000000000000000000000000000000000000000..5e3efd9426511d428cf92870dddd8218beba7a33
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/consumer/StorageService.java
@@ -0,0 +1,15 @@
+package com.opensource.consumer;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+
+@RocketMQMessageListener(topic = "${demo.rocketmq.orderTopic}", consumerGroup = "storage-group2", namespace = "${rocketmq.name-server}")
+@Slf4j
+public class StorageService implements RocketMQListener {
+ @Override
+ public void onMessage(String s) {
+ log.info("扣库存:{}", s);
+
+ }
+}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountRocketMQTransactionLister.java
similarity index 94%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountRocketMQTransactionLister.java
index 4042fa597a713532efae9dd30ec5375e4830dd0c..6d1b049f037ca4e0aecc4c6cb7c59cbebd934dbe 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountRocketMQTransactionLister.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example.listener;
+package com.opensource.listener;
-import com.common.entity.AccountTbl;
-import com.common.service.IAccountService;
+import com.opensource.common.entity.AccountTbl;
+import com.opensource.common.service.IAccountService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.LocalTransactionState;
import org.apache.rocketmq.client.producer.TransactionListener;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountTransactionLister.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountTransactionLister.java
similarity index 96%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/AccountTransactionLister.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountTransactionLister.java
index 772007fb49ce3cb212244b6d5eee91c274a689af..aa208f2d9428c215aa13802fca32af81c48ac447 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountTransactionLister.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/AccountTransactionLister.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.listener;
+package com.opensource.listener;//package com.rocketmq.example.listener;
//
//import com.common.entity.AccountTbl;
//import com.common.service.IAccountService;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/OrderTransactionLister.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/OrderTransactionLister.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/OrderTransactionLister.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/OrderTransactionLister.java
index d9c2da59b34f78c21a74b4ed62a08ffcbedf030a..1c111941002f23eee236b5dd431a2aa9c9258ac4 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/listener/OrderTransactionLister.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/listener/OrderTransactionLister.java
@@ -1,4 +1,4 @@
-//package com.rocketmq.example.listener;
+package com.opensource.listener;//package com.rocketmq.example.listener;
//
//import com.common.service.IOrderService;
//import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/Consumer.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/Consumer.java
new file mode 100644
index 0000000000000000000000000000000000000000..c698a7a3da966d103acf8d2c752ab63f5bc408af
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/Consumer.java
@@ -0,0 +1,34 @@
+package com.opensource.simple;
+
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
+import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
+import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
+import org.apache.rocketmq.client.exception.MQClientException;
+import org.apache.rocketmq.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+ public static void main(String[] args) throws InterruptedException, MQClientException {
+ // Initialize Consumer and set Consumer Goup Name
+ DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer-light-9");
+
+ // Set the address of NameServer
+ consumer.setNamesrvAddr("localhost:9876");
+ // Subscribe One or more of topics,and specify the tag filtering conditions, here specify * means receive all tag messages
+ consumer.subscribe("TopicTest", "*");
+ // Register a callback interface to handle messages received from the Broker
+ consumer.registerMessageListener(new MessageListenerConcurrently() {
+ @Override
+ public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) {
+ System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
+ // Return to the message consumption status, ConsumeConcurrentlyStatus.CONSUME_SUCCESS for successful consumption
+ return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+ }
+ });
+ // Start Consumer
+ consumer.start();
+ System.out.printf("Consumer Started.%n");
+ }
+}
\ No newline at end of file
diff --git a/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/SyncProducer.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/SyncProducer.java
new file mode 100644
index 0000000000000000000000000000000000000000..e393fc34831519f419adec5d01fbb7a0c45477a8
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/simple/SyncProducer.java
@@ -0,0 +1,29 @@
+package com.opensource.simple;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.common.message.Message;
+import org.apache.rocketmq.remoting.common.RemotingHelper;
+
+public class SyncProducer {
+ public static void main(String[] args) throws Exception {
+ // Initialize a producer and set the Producer group name
+ DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); //(1)
+ // Set the address of NameServer
+ producer.setNamesrvAddr("localhost:9876"); //(2)
+ // Start Producer
+ producer.start();
+ for (int i = 0; i < 100; i++) {
+ // Create a message and set the topic, tag, body and so on. The tag can be understood as a label to categorize the message, and RocketMQ can filter the tag on the consumer side.
+ Message msg = new Message("TopicTest" /* Topic */,
+ "TagA" /* Tag */,
+ ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
+ ); //(3)
+ // Use the producer to send and wait for the result of sending synchronously
+ SendResult sendResult = producer.send(msg); //(4)
+ System.out.printf("%s%n", sendResult);
+ }
+ // Close the producer once it is no longer in use
+ producer.shutdown();
+ }
+}
\ No newline at end of file
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/AccountVo.java
similarity index 93%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/AccountVo.java
index 496f16b0ec9752bb03ccda7046f52bc9edd71560..a319e54558e29bccf6040b08f236a433c3d5ebdb 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/AccountVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.opensource.vo;
import lombok.Data;
import lombok.EqualsAndHashCode;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/OrderVo.java
similarity index 87%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/OrderVo.java
index 1161590d07f7e9bf25bbf3473f989a153b90b1a8..446df0eb3570b79f18c0370acb09ad1156b309d3 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/OrderVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.opensource.vo;
import lombok.Data;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/ProductVo.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/ProductVo.java
index f0e2ac6b4730b6ff39d86c485e7c689ced18982a..8144115ce15e616ac6159252cd3afa0884e773fb 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/vo/ProductVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.opensource.vo;
import lombok.Data;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderRocketController.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderRocketController.java
index 2919686fee1dc6a91a8d09090777dc03a44a30a4..5f59cf4e11e8c1ce40524849833f1810834640f9 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderRocketController.java
@@ -1,11 +1,12 @@
-package com.rocketmq.example.web;
+package com.opensource.web;
-import com.common.service.IOrderService;
-import com.rocketmq.example.vo.AccountVo;
+import com.opensource.common.service.IOrderService;
+import com.opensource.vo.AccountVo;
import com.saturday.common.exception.BusinessException;
import com.saturday.common.model.vo.ResponseVO;
import com.saturday.common.util.ResultUtils;
+import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.*;
@@ -16,7 +17,6 @@ import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
-import javax.annotation.Resource;
@RestController
@Slf4j
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java b/message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderSpringRocketController.java
similarity index 97%
rename from message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java
rename to message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderSpringRocketController.java
index 3853effc190dee4baf08f0cd4952e76381f9dbdc..5d9b69561b2a94a3f1d4aed3d0857594364cce2f 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java
+++ b/message-queue-example/rocketmq-example/src/main/java/com/opensource/web/OrderSpringRocketController.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example.web;
+package com.opensource.web;
-import com.common.service.IOrderService;
+import com.opensource.common.service.IOrderService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.*;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/rocketmq-example/src/main/resources/application.yml b/message-queue-example/rocketmq-example/src/main/resources/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..0724515acd9067a0571f71a2f67e08cef62e27e3
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/resources/application.yml
@@ -0,0 +1,34 @@
+server:
+ port: 7080
+
+rocketmq:
+ name-server: localhost:9876
+ producer:
+ sendMessageTimeout: 300000
+ group: order-group
+demo:
+ rocketmq:
+ objectRequestTopic: objectRequestTopic:tagA
+ stringRequestTopic: stringRequestTopic:tagA
+ msgExtTopic: message-ext-topic
+ transTopic: spring-transaction-topic
+ bytesRequestTopic: bytesRequestTopic:tagA
+ orderTopic: order-paid-topic
+ topic: string-topic
+ extNameServer: 127.0.0.1:9876
+ genericRequestTopic: genericRequestTopic:tagA
+
+mybatis:
+ mapper-locations: classpath:/mapper/*.xml
+ type-aliases-package: com.common.entity.*
+
+spring:
+ datasource:
+ password:
+ username: root
+ url: jdbc:mysql://localhost:3306/cloud_demo?useSSL=false&serverTimezone=UTC
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ rabbitmq:
+ addresses: 127.0.0.1:5672
+ username: guest
+ password: guest
diff --git a/message-queue-example/rocketmq-example/src/main/resources/mapper/AccountTblMapper.xml b/message-queue-example/rocketmq-example/src/main/resources/mapper/AccountTblMapper.xml
new file mode 100644
index 0000000000000000000000000000000000000000..5f5a10c9e6286eac1e67da28e100ac9ad66757d5
--- /dev/null
+++ b/message-queue-example/rocketmq-example/src/main/resources/mapper/AccountTblMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml b/message-queue-example/rocketmq-example/src/main/resources/mapper/OrderTblMapper.xml
similarity index 72%
rename from message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
rename to message-queue-example/rocketmq-example/src/main/resources/mapper/OrderTblMapper.xml
index 9d72ca740455b1315c8d41e74cf80c06b4474a0a..a63f4038aad87ebe2e87781c2064f116352cdc44 100644
--- a/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
+++ b/message-queue-example/rocketmq-example/src/main/resources/mapper/OrderTblMapper.xml
@@ -1,5 +1,5 @@
-
+
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java b/message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java
deleted file mode 100644
index 063850d2bc42f46eb6c739ba4bee392854be50d9..0000000000000000000000000000000000000000
--- a/message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java
+++ /dev/null
@@ -1,111 +0,0 @@
-package com.rocketmq.example;
-
-import com.rocketmq.example.consumer.RocketAccountConsumerService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
-import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
-import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
-import org.apache.rocketmq.client.exception.MQClientException;
-import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
-import org.apache.rocketmq.common.message.MessageExt;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.util.CollectionUtils;
-
-import java.util.List;
-
-@Configuration
-@Slf4j
-public class ConsumerConfig {
-
- @Value("${rocketmq.name-server}")
- private String nameServer;
-
- @Autowired
- private RocketAccountConsumerService accountConsumerService;
-
- @Bean
- public DefaultMQPushConsumer traceTopicConsumer() throws MQClientException {
- DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("trace-topic-consumer-group", true);
- consumer.setNamesrvAddr(nameServer);
- consumer.subscribe("trace-topic", "*");
- consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
- consumer.setConsumeTimestamp("20200722110701");
- consumer.setMessageListener(new MessageListenerConcurrently() {
- @Override
- public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
- if (!CollectionUtils.isEmpty(list)) {
- try {
- for (MessageExt messageExt : list) {
- log.info("回溯消息:{}", messageExt);
- }
- } catch (Exception e) {
- log.error("处理异常:{}", e);
- return ConsumeConcurrentlyStatus.RECONSUME_LATER;
- }
- }
- return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
- }
- });
- consumer.start();
- return consumer;
- }
-
- @Bean
- public DefaultMQPushConsumer traceConsumer() throws MQClientException {
- DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("topic-test-consumer-group", true, "trace-topic");
- consumer.setNamesrvAddr(nameServer);
- consumer.subscribe("topic-test", "trace");
-// consumer.setConsumerGroup("topic-test-consumer-group");
- consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
-// consumer.setConsumeTimestamp("20200722093001");
- consumer.setMessageListener(new MessageListenerConcurrently() {
- @Override
- public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
- if (!CollectionUtils.isEmpty(list)) {
- try {
- for (MessageExt messageExt : list) {
- log.info("消费消息:{}", messageExt);
- }
- } catch (Exception e) {
- log.error("处理异常:{}", e);
- return ConsumeConcurrentlyStatus.RECONSUME_LATER;
- }
- }
- return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
- }
- });
- consumer.start();
- return consumer;
- }
-
- @Bean
- public DefaultMQPushConsumer defaultMQPushConsumer() throws MQClientException {
- DefaultMQPushConsumer consumer = new DefaultMQPushConsumer();
- consumer.setNamesrvAddr(nameServer);
- consumer.subscribe("account1", "*");
- consumer.setConsumerGroup("consumer-group");
- consumer.setMessageListener(accountConsumerService);
- consumer.start();
- return consumer;
- }
-
- @Bean
- public DefaultLitePullConsumer defaultLitePullConsumer() throws MQClientException {
- DefaultLitePullConsumer pullConsumer = new DefaultLitePullConsumer();
- pullConsumer.setNamesrvAddr(nameServer);
- pullConsumer.subscribe("topic-test", "trace");
- while (true) {
-// pullConsumer.
- }
-// pullConsumer.
-// pullConsumer.start();
-// log.info("defaultLitePullConsumer is started...");
-// return pullConsumer;
- }
-
-}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageService.java b/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageService.java
deleted file mode 100644
index 24659fe37bd9b9dae2418609fe4f5eedf83152de..0000000000000000000000000000000000000000
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageService.java
+++ /dev/null
@@ -1,17 +0,0 @@
-//package com.rocketmq.example.consumer;
-//
-//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
-//@RocketMQMessageListener(topic = "${demo.rocketmq.orderTopic}", consumerGroup = "storage-group2")
-//@Slf4j
-//public class StorageService implements RocketMQListener {
-// @Override
-// public void onMessage(String s) {
-// log.info("扣库存:{}", s);
-//
-// }
-//}
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java b/message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java
deleted file mode 100644
index 80521babd48f38920be721900afaeaa6490e4f03..0000000000000000000000000000000000000000
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package com.rocketmq.example.web;
-
-import cn.hutool.json.JSONUtil;
-import com.rocketmq.example.vo.ProductVo;
-import lombok.Data;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.List;
-
-@RestController
-@Slf4j
-public class JsonController {
-
- @PostMapping("/demo")
- public Object test(@RequestBody Demo demo) {
- log.info("参数:{}", JSONUtil.toJsonStr(demo));
- return "xxxx";
- }
-
- @Data
- static class Demo {
-
- private String name;
-
- private String age;
-
- private List products;
-
- }
-
-}
diff --git a/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java b/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java
index af1951b60c9e95778498e8e24ee45304bce962b8..9ae29d38c12a6c7f44ca1f03c1f5e660c36a4981 100644
--- a/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java
+++ b/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java
@@ -1,118 +1,118 @@
-package com.example.springdemo.mybatis;
-
-import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
-import com.baomidou.mybatisplus.core.toolkit.StringPool;
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
-import com.baomidou.mybatisplus.generator.AutoGenerator;
-import com.baomidou.mybatisplus.generator.InjectionConfig;
-import com.baomidou.mybatisplus.generator.config.*;
-import com.baomidou.mybatisplus.generator.config.po.TableInfo;
-import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
-import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Scanner;
-
-public class CodeGenerator {
-
- /**
- *
- * 读取控制台内容
- *
- */
- public static String scanner(String tip) {
- Scanner scanner = new Scanner(System.in);
- StringBuilder help = new StringBuilder();
- help.append("请输入" + tip + ":");
- System.out.println(help.toString());
- if (scanner.hasNext()) {
- String ipt = scanner.next();
- if (StringUtils.isNotEmpty(ipt)) {
- return ipt;
- }
- }
- throw new MybatisPlusException("请输入正确的" + tip + "!");
- }
-
- public static void main(String[] args) {
- // 代码生成器
- AutoGenerator mpg = new AutoGenerator();
-
- // 全局配置
- GlobalConfig gc = new GlobalConfig();
- String projectPath = System.getProperty("user.dir");
- gc.setOutputDir(projectPath + "/src/main/java");
- gc.setAuthor("wanggd");
- gc.setOpen(false);
- // gc.setSwagger2(true); 实体属性 Swagger2 注解
- mpg.setGlobalConfig(gc);
-
- // 数据源配置
- DataSourceConfig dsc = new DataSourceConfig();
- dsc.setUrl("jdbc:mysql://localhost:3306/chat-app?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC");
- // dsc.setSchemaName("public");
- dsc.setDriverName("com.mysql.cj.jdbc.Driver");
- dsc.setUsername("root");
- dsc.setPassword("123456");
- mpg.setDataSource(dsc);
-
- // 包配置
- PackageConfig pc = new PackageConfig();
- pc.setModuleName(scanner("模块名"));
- pc.setParent("com");
- mpg.setPackageInfo(pc);
-
- // 自定义配置
- InjectionConfig cfg = new InjectionConfig() {
- @Override
- public void initMap() {
- // to do nothing
- }
- };
-
- // 如果模板引擎是 freemarker
- String templatePath = "/templates/mapper.xml.ftl";
- // 如果模板引擎是 velocity
- // String templatePath = "/templates/mapper.xml.vm";
-
- // 自定义输出配置
- List focList = new ArrayList<>();
- // 自定义配置会被优先输出
- focList.add(new FileOutConfig(templatePath) {
- @Override
- public String outputFile(TableInfo tableInfo) {
- // 自定义输出文件名 , 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化!!
- return projectPath + "/src/main/resources/mapper/" + pc.getModuleName()
- + "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
- }
- });
-
- cfg.setFileOutConfigList(focList);
- mpg.setCfg(cfg);
-
- // 配置模板
- TemplateConfig templateConfig = new TemplateConfig();
-
- templateConfig.setXml(null);
- mpg.setTemplate(templateConfig);
-
- // 策略配置
- StrategyConfig strategy = new StrategyConfig();
- strategy.setNaming(NamingStrategy.underline_to_camel);
- strategy.setColumnNaming(NamingStrategy.underline_to_camel);
-// strategy.setSuperEntityClass("com.example.springdemo.common.BaseEntity");
- strategy.setEntityLombokModel(true);
- strategy.setRestControllerStyle(true);
- // 公共父类
-// strategy.setSuperControllerClass("com.baomidou.ant.common.BaseController");
- // 写于父类中的公共字段
- strategy.setSuperEntityColumns("id");
- strategy.setInclude(scanner("表名,多个英文逗号分割").split(","));
- strategy.setControllerMappingHyphenStyle(true);
- strategy.setTablePrefix(pc.getModuleName() + "_");
- mpg.setStrategy(strategy);
- mpg.setTemplateEngine(new FreemarkerTemplateEngine());
- mpg.execute();
- }
-}
+//package com.example.springdemo.mybatis;
+//
+//import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
+//import com.baomidou.mybatisplus.core.toolkit.StringPool;
+//import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+//import com.baomidou.mybatisplus.generator.AutoGenerator;
+//import com.baomidou.mybatisplus.generator.InjectionConfig;
+//import com.baomidou.mybatisplus.generator.config.*;
+//import com.baomidou.mybatisplus.generator.config.po.TableInfo;
+//import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
+//import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
+//
+//import java.util.ArrayList;
+//import java.util.List;
+//import java.util.Scanner;
+//
+//public class CodeGenerator {
+//
+// /**
+// *
+// * 读取控制台内容
+// *
+// */
+// public static String scanner(String tip) {
+// Scanner scanner = new Scanner(System.in);
+// StringBuilder help = new StringBuilder();
+// help.append("请输入" + tip + ":");
+// System.out.println(help.toString());
+// if (scanner.hasNext()) {
+// String ipt = scanner.next();
+// if (StringUtils.isNotEmpty(ipt)) {
+// return ipt;
+// }
+// }
+// throw new MybatisPlusException("请输入正确的" + tip + "!");
+// }
+//
+// public static void main(String[] args) {
+// // 代码生成器
+// AutoGenerator mpg = new AutoGenerator();
+//
+// // 全局配置
+// GlobalConfig gc = new GlobalConfig();
+// String projectPath = System.getProperty("user.dir");
+// gc.setOutputDir(projectPath + "/src/main/java");
+// gc.setAuthor("wanggd");
+// gc.setOpen(false);
+// // gc.setSwagger2(true); 实体属性 Swagger2 注解
+// mpg.setGlobalConfig(gc);
+//
+// // 数据源配置
+// DataSourceConfig dsc = new DataSourceConfig();
+// dsc.setUrl("jdbc:mysql://localhost:3306/chat-app?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC");
+// // dsc.setSchemaName("public");
+// dsc.setDriverName("com.mysql.cj.jdbc.Driver");
+// dsc.setUsername("root");
+// dsc.setPassword("123456");
+// mpg.setDataSource(dsc);
+//
+// // 包配置
+// PackageConfig pc = new PackageConfig();
+// pc.setModuleName(scanner("模块名"));
+// pc.setParent("com");
+// mpg.setPackageInfo(pc);
+//
+// // 自定义配置
+// InjectionConfig cfg = new InjectionConfig() {
+// @Override
+// public void initMap() {
+// // to do nothing
+// }
+// };
+//
+// // 如果模板引擎是 freemarker
+// String templatePath = "/templates/mapper.xml.ftl";
+// // 如果模板引擎是 velocity
+// // String templatePath = "/templates/mapper.xml.vm";
+//
+// // 自定义输出配置
+// List focList = new ArrayList<>();
+// // 自定义配置会被优先输出
+// focList.add(new FileOutConfig(templatePath) {
+// @Override
+// public String outputFile(TableInfo tableInfo) {
+// // 自定义输出文件名 , 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化!!
+// return projectPath + "/src/main/resources/mapper/" + pc.getModuleName()
+// + "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
+// }
+// });
+//
+// cfg.setFileOutConfigList(focList);
+// mpg.setCfg(cfg);
+//
+// // 配置模板
+// TemplateConfig templateConfig = new TemplateConfig();
+//
+// templateConfig.setXml(null);
+// mpg.setTemplate(templateConfig);
+//
+// // 策略配置
+// StrategyConfig strategy = new StrategyConfig();
+// strategy.setNaming(NamingStrategy.underline_to_camel);
+// strategy.setColumnNaming(NamingStrategy.underline_to_camel);
+//// strategy.setSuperEntityClass("com.example.springdemo.common.BaseEntity");
+// strategy.setEntityLombokModel(true);
+// strategy.setRestControllerStyle(true);
+// // 公共父类
+//// strategy.setSuperControllerClass("com.baomidou.ant.common.BaseController");
+// // 写于父类中的公共字段
+// strategy.setSuperEntityColumns("id");
+// strategy.setInclude(scanner("表名,多个英文逗号分割").split(","));
+// strategy.setControllerMappingHyphenStyle(true);
+// strategy.setTablePrefix(pc.getModuleName() + "_");
+// mpg.setStrategy(strategy);
+// mpg.setTemplateEngine(new FreemarkerTemplateEngine());
+// mpg.execute();
+// }
+//}
diff --git a/pom.xml b/pom.xml
index b84bbd8ae32edb562c729fd03a90c0295d3a22ca..a5ecafed80ba9525fb3eb064d5f958dd423b0a21 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
com.saturday
saturday-parent
- 1.0.0-SNAPSHOT
+ 1.1.0-SNAPSHOT
4.0.0
@@ -32,8 +32,8 @@
Demo project for Spring Boot
- 1.8
- 1.0.0-SNAPSHOT
+ 17
+ 1.1.0-SNAPSHOT
2.6
1.1.23
1.2
@@ -75,7 +75,7 @@
org.springframework.cloud
spring-cloud-starter-netflix-zuul
- 2.2.6.RELEASE
+ 4.0.0
@@ -87,7 +87,7 @@
org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
- 2.2.6.RELEASE
+ 4.0.0
diff --git a/spring-cloud-learn/gateway-server/src/main/java/com/gateway/GatewayServerApplication.java b/spring-cloud-learn/gateway-server/src/main/java/com/gateway/GatewayServerApplication.java
index 3c94c4a143e3bbeee10ce592f5638a93ebd12001..a4b2fba8f15e1d763c761918e4b55a01e5352e97 100644
--- a/spring-cloud-learn/gateway-server/src/main/java/com/gateway/GatewayServerApplication.java
+++ b/spring-cloud-learn/gateway-server/src/main/java/com/gateway/GatewayServerApplication.java
@@ -3,14 +3,14 @@ package com.gateway;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
-import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
import org.springframework.web.bind.annotation.RestController;
/**
* @author Kevin
*/
@SpringBootApplication
-@EnableEurekaClient
+
@EnableDiscoveryClient
@RestController
public class GatewayServerApplication {
diff --git a/spring-cloud-learn/hystrix-dashboard-server/src/main/java/com/hystrix/HystrixDashboardServerApplication.java b/spring-cloud-learn/hystrix-dashboard-server/src/main/java/com/hystrix/HystrixDashboardServerApplication.java
index 7d749672b11ae75355de93cf1738f7dad9d9de56..8d8e1a50cd6856b4c570c0c42e9a67fa24e05329 100644
--- a/spring-cloud-learn/hystrix-dashboard-server/src/main/java/com/hystrix/HystrixDashboardServerApplication.java
+++ b/spring-cloud-learn/hystrix-dashboard-server/src/main/java/com/hystrix/HystrixDashboardServerApplication.java
@@ -2,14 +2,14 @@ package com.hystrix;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
/**
* @author Kevin
*/
@SpringBootApplication
-@EnableEurekaClient
+
@EnableHystrixDashboard
public class HystrixDashboardServerApplication {
diff --git a/spring-cloud-learn/order-server/pom.xml b/spring-cloud-learn/order-server/pom.xml
index 2019648422af87edc365be370e14d54c0bee2cee..644dddf4a45e0febed043bafa92d23d2c808b790 100644
--- a/spring-cloud-learn/order-server/pom.xml
+++ b/spring-cloud-learn/order-server/pom.xml
@@ -54,10 +54,10 @@
spring-cloud-starter-openfeign
-
- org.springframework.boot
- spring-boot-starter-test
-
+
+
+
+
com.baomidou
diff --git a/spring-cloud-learn/order-server/src/main/java/com/order/OrderApplication.java b/spring-cloud-learn/order-server/src/main/java/com/order/OrderApplication.java
index 5296e0177969fef5778e4ab97d5fb41c36d5a990..ac8909e955caa05091c85c14e6956a00417f9dd0 100644
--- a/spring-cloud-learn/order-server/src/main/java/com/order/OrderApplication.java
+++ b/spring-cloud-learn/order-server/src/main/java/com/order/OrderApplication.java
@@ -2,9 +2,8 @@ package com.order;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
-import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
@@ -17,7 +16,7 @@ import org.springframework.web.client.RestTemplate;
*/
@SpringBootApplication
@ComponentScans(value = {@ComponentScan("com.order.**"), @ComponentScan("com.saturday.**")})
-@EnableEurekaClient
+
@EnableAspectJAutoProxy
@EnableFeignClients
public class OrderApplication {
diff --git a/spring-cloud-learn/system-server/system-server-web/pom.xml b/spring-cloud-learn/system-server/system-server-web/pom.xml
index 14f3be5898158c4019417a31b7de9f4522630548..d1cd1c93159d74ad1cf60390a0c3508438b07677 100644
--- a/spring-cloud-learn/system-server/system-server-web/pom.xml
+++ b/spring-cloud-learn/system-server/system-server-web/pom.xml
@@ -52,10 +52,10 @@
spring-boot-starter-actuator
-
- org.springframework.cloud
- spring-cloud-starter-sleuth
-
+
+
+
+