diff --git a/src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
similarity index 93%
rename from src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java
rename to src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
index 737ef3e..358d2fc 100644
--- a/src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java
+++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java
@@ -1,4 +1,4 @@
-package cn.hezhaohui.rabbitmq;
+package cn.hezhaohui.rabbitmq.amqp;
 
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
diff --git a/src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
similarity index 86%
rename from src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java
rename to src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
index a600484..ec21e03 100644
--- a/src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java
+++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java
@@ -1,5 +1,6 @@
-package cn.hezhaohui.rabbitmq;
+package cn.hezhaohui.rabbitmq.amqp;
 
+import cn.hezhaohui.rabbitmq.entity.Message;
 import jakarta.annotation.Resource;
 import lombok.Data;
 import org.springframework.amqp.core.AmqpTemplate;
diff --git a/src/main/java/cn/hezhaohui/rabbitmq/Message.java b/src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java
similarity index 75%
rename from src/main/java/cn/hezhaohui/rabbitmq/Message.java
rename to src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java
index 607d4e2..27ee973 100644
--- a/src/main/java/cn/hezhaohui/rabbitmq/Message.java
+++ b/src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java
@@ -1,4 +1,4 @@
-package cn.hezhaohui.rabbitmq;
+package cn.hezhaohui.rabbitmq.entity;
 
 import lombok.Data;
 
diff --git a/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java b/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java
index 173c492..f4b96df 100644
--- a/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java
+++ b/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java
@@ -1,5 +1,6 @@
 package cn.hezhaohui.rabbitmq;
 
+import cn.hezhaohui.rabbitmq.amqp.MessageProducer;
 import jakarta.annotation.Resource;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;