diff --git a/api-boot-project/api-boot-autoconfigure/pom.xml b/api-boot-project/api-boot-autoconfigure/pom.xml
index 7f52bcb2..e065ef1f 100644
--- a/api-boot-project/api-boot-autoconfigure/pom.xml
+++ b/api-boot-project/api-boot-autoconfigure/pom.xml
@@ -161,6 +161,21 @@
             <artifactId>minbox-oss</artifactId>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-client</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-server</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-spring-context</artifactId>
+            <optional>true</optional>
+        </dependency>
 
 
         <!--Others-->
diff --git a/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientAutoConfiguration.java b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientAutoConfiguration.java
new file mode 100644
index 00000000..78c9689d
--- /dev/null
+++ b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientAutoConfiguration.java
@@ -0,0 +1,34 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.client;
+
+import org.minbox.framework.message.pipe.client.config.ClientConfiguration;
+import org.minbox.framework.message.pipe.spring.annotation.client.EnableMessagePipeClient;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+
+/**
+ * The Message Pipe configuration
+ *
+ * @author 恒宇少年
+ */
+@ConditionalOnClass(ClientConfiguration.class)
+@EnableConfigurationProperties(MessagePipeClientProperties.class)
+@EnableMessagePipeClient
+public class MessagePipeClientAutoConfiguration {
+    private MessagePipeClientProperties messagePipeClientProperties;
+
+    public MessagePipeClientAutoConfiguration(MessagePipeClientProperties messagePipeClientProperties) {
+        this.messagePipeClientProperties = messagePipeClientProperties;
+    }
+
+    /**
+     * Create {@link ClientConfiguration} instance
+     *
+     * @return The {@link ClientConfiguration} instance
+     * @see MessagePipeClientProperties#getConfiguration
+     */
+    @Bean
+    public ClientConfiguration clientConfiguration() {
+        return messagePipeClientProperties.getConfiguration();
+    }
+}
diff --git a/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientProperties.java b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientProperties.java
new file mode 100644
index 00000000..0303e23a
--- /dev/null
+++ b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/client/MessagePipeClientProperties.java
@@ -0,0 +1,27 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.client;
+
+import lombok.Data;
+import org.minbox.framework.message.pipe.client.config.ClientConfiguration;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.NestedConfigurationProperty;
+
+import static org.minbox.framework.api.boot.autoconfigure.message.pipe.client.MessagePipeClientProperties.MESSAGE_PIPE_PREFIX;
+
+/**
+ * The Message Pipe client config properties
+ *
+ * @author 恒宇少年
+ */
+@ConfigurationProperties(prefix = MESSAGE_PIPE_PREFIX)
+@Data
+public class MessagePipeClientProperties {
+    /**
+     * The config prefix for "message-pipe-client"
+     */
+    public static final String MESSAGE_PIPE_PREFIX = "api.boot.message.pipe.client";
+    /**
+     * The {@link ClientConfiguration} client configuration
+     */
+    @NestedConfigurationProperty
+    private ClientConfiguration configuration = new ClientConfiguration();
+}
diff --git a/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerAutoConfiguration.java b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerAutoConfiguration.java
new file mode 100644
index 00000000..739e33c4
--- /dev/null
+++ b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerAutoConfiguration.java
@@ -0,0 +1,54 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.server;
+
+import org.minbox.framework.message.pipe.server.config.MessagePipeConfiguration;
+import org.minbox.framework.message.pipe.server.config.ServerConfiguration;
+import org.minbox.framework.message.pipe.spring.annotation.server.EnableMessagePipeServer;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+
+/**
+ * The Message Pipe Server configuration
+ *
+ * @author 恒宇少年
+ */
+@ConditionalOnClass(ServerConfiguration.class)
+@EnableConfigurationProperties(MessagePipeServerProperties.class)
+@EnableMessagePipeServer
+public class MessagePipeServerAutoConfiguration {
+    private MessagePipeServerProperties messagePipeServerProperties;
+
+    public MessagePipeServerAutoConfiguration(MessagePipeServerProperties messagePipeServerProperties) {
+        this.messagePipeServerProperties = messagePipeServerProperties;
+    }
+
+    /**
+     * Create {@link ServerConfiguration} instance
+     *
+     * @return The {@link ServerConfiguration} instance
+     * @see MessagePipeServerProperties#getConfiguration
+     */
+    @Bean
+    public ServerConfiguration serverConfiguration() {
+        return messagePipeServerProperties.getConfiguration();
+    }
+
+    /**
+     * Create {@link MessagePipeConfiguration}
+     * <p>
+     * The common configuration instance for each channel
+     *
+     * @return The {@link MessagePipeConfiguration} instance
+     */
+    @Bean
+    public MessagePipeConfiguration messagePipeConfiguration() {
+        MessagePipeConfiguration configuration = MessagePipeConfiguration.defaultConfiguration();
+        MessagePipeConfiguration.LockTime lockTime =
+            new MessagePipeConfiguration.LockTime()
+                .setLeaseTime(messagePipeServerProperties.getLockLeaseTime())
+                .setTimeUnit(messagePipeServerProperties.getLockLeaseTimeUnit());
+        configuration.setLockTime(lockTime);
+        configuration.setDistributionMessagePoolSize(messagePipeServerProperties.getDistributionMessagePoolSize());
+        return configuration;
+    }
+}
diff --git a/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerProperties.java b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerProperties.java
new file mode 100644
index 00000000..0567a704
--- /dev/null
+++ b/api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerProperties.java
@@ -0,0 +1,41 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.server;
+
+import lombok.Data;
+import org.minbox.framework.message.pipe.server.config.ServerConfiguration;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.NestedConfigurationProperty;
+
+import java.util.concurrent.TimeUnit;
+
+import static org.minbox.framework.api.boot.autoconfigure.message.pipe.server.MessagePipeServerProperties.MESSAGE_PIPE_PREFIX;
+
+/**
+ * The Message Pipe server config properties
+ *
+ * @author 恒宇少年
+ */
+@ConfigurationProperties(prefix = MESSAGE_PIPE_PREFIX)
+@Data
+public class MessagePipeServerProperties {
+    /**
+     * The config prefix for "message-pipe-server"
+     */
+    public static final String MESSAGE_PIPE_PREFIX = "api.boot.message.pipe.server";
+    /**
+     * The {@link ServerConfiguration} server configuration
+     */
+    @NestedConfigurationProperty
+    private ServerConfiguration configuration = new ServerConfiguration();
+    /**
+     * The redisson lock lease time
+     */
+    private long lockLeaseTime = 10;
+    /**
+     * The redisson lock lean {@link TimeUnit}
+     */
+    private TimeUnit lockLeaseTimeUnit = TimeUnit.SECONDS;
+    /**
+     * The number of threads in the message thread pool
+     */
+    private int distributionMessagePoolSize = 10;
+}
diff --git a/api-boot-project/api-boot-autoconfigure/src/main/resources/META-INF/spring.factories b/api-boot-project/api-boot-autoconfigure/src/main/resources/META-INF/spring.factories
index d2fe528c..e1ae8a8a 100644
--- a/api-boot-project/api-boot-autoconfigure/src/main/resources/META-INF/spring.factories
+++ b/api-boot-project/api-boot-autoconfigure/src/main/resources/META-INF/spring.factories
@@ -22,4 +22,6 @@ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
   org.minbox.framework.api.boot.autoconfigure.logging.admin.ApiBootLoggingAdminSecurityAutoConfiguration,\
   org.minbox.framework.api.boot.autoconfigure.sequence.ApiBootSequenceAutoConfiguration,\
   org.minbox.framework.api.boot.autoconfigure.mongo.ApiBootMongoClientSettingsAutoConfiguration,\
-  org.minbox.framework.api.boot.autoconfigure.tools.ApiBootToolsAutoConfiguration
+  org.minbox.framework.api.boot.autoconfigure.tools.ApiBootToolsAutoConfiguration,\
+  org.minbox.framework.api.boot.autoconfigure.message.pipe.client.MessagePipeClientAutoConfiguration,\
+  org.minbox.framework.api.boot.autoconfigure.message.pipe.server.MessagePipeServerAutoConfiguration
diff --git a/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ClassTools.java b/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ClassTools.java
index 1495469f..f9dfdd30 100644
--- a/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ClassTools.java
+++ b/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ClassTools.java
@@ -55,6 +55,7 @@ static Reflections initReflections(String scannerPackage) {
      * 获取指定package下的接口实现类
      *
      * @param scannerPackage 扫描的package
+     * @param clazz          The class type
      * @return 实现类集合
      */
     public static Collection<?> getSubClassList(String scannerPackage, Class clazz) {
diff --git a/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ListTools.java b/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ListTools.java
index 2e189e57..001712ac 100644
--- a/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ListTools.java
+++ b/api-boot-project/api-boot-common/src/main/java/org/minbox/framework/api/boot/common/tools/ListTools.java
@@ -35,8 +35,8 @@ public class ListTools {
     /**
      * value converter to list
      *
-     * @param value
-     * @return
+     * @param value The object value
+     * @return list collection
      */
     public static List<String> convertToList(Object value) {
         List<String> resourceUrls = new ArrayList<>();
diff --git a/api-boot-project/api-boot-dependencies/pom.xml b/api-boot-project/api-boot-dependencies/pom.xml
index 76a19307..91a214ac 100644
--- a/api-boot-project/api-boot-dependencies/pom.xml
+++ b/api-boot-project/api-boot-dependencies/pom.xml
@@ -16,12 +16,13 @@
         <main.basedir>${basedir}/../..</main.basedir>
 
         <!--Spring Projects-->
-        <spring.version>5.2.7.RELEASE</spring.version>
+        <spring.version>5.2.8.RELEASE</spring.version>
         <spring.boot.version>2.3.3.RELEASE</spring.boot.version>
 
         <!--Minbox Projects-->
-        <minbox-bom.version>1.0.1-SNAPSHOT</minbox-bom.version>
+        <minbox-bom.version>1.0.1.RELEASE</minbox-bom.version>
         <code.builder.core.version>1.0.5.RELEASE</code.builder.core.version>
+        <message-pipe.version>1.0.0.RELEASE</message-pipe.version>
 
         <!--Others-->
         <druid.starter.version>1.1.21</druid.starter.version>
@@ -56,6 +57,14 @@
                 <scope>import</scope>
                 <type>pom</type>
             </dependency>
+            <dependency>
+                <groupId>org.minbox.framework</groupId>
+                <artifactId>message-pipe-bom</artifactId>
+                <version>${message-pipe.version}</version>
+                <scope>import</scope>
+                <type>pom</type>
+            </dependency>
+
             <!--SpringBoot Related Dependencies-->
             <dependency>
                 <groupId>com.alibaba</groupId>
@@ -190,6 +199,16 @@
                 <artifactId>api-boot-starter-mongo-client-settings</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.minbox.framework</groupId>
+                <artifactId>api-boot-starter-message-pipe-client</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.minbox.framework</groupId>
+                <artifactId>api-boot-starter-message-pipe-server</artifactId>
+                <version>${project.version}</version>
+            </dependency>
 
 
             <!--Others-->
diff --git a/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-client/pom.xml b/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-client/pom.xml
new file mode 100644
index 00000000..c6368aee
--- /dev/null
+++ b/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-client/pom.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>api-boot-starters</artifactId>
+        <groupId>org.minbox.framework</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>api-boot-starter-message-pipe-client</artifactId>
+    <properties>
+        <main.basedir>${basedir}/../../..</main.basedir>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>api-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-spring-context</artifactId>
+        </dependency>
+    </dependencies>
+    <developers>
+        <developer>
+            <name>恒宇少年</name>
+            <email>jnyuqy@gmail.com</email>
+            <organization>minbox-projects</organization>
+            <organizationUrl>https://gitee.com/minbox-projects</organizationUrl>
+        </developer>
+    </developers>
+
+</project>
diff --git a/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-server/pom.xml b/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-server/pom.xml
new file mode 100644
index 00000000..61759f05
--- /dev/null
+++ b/api-boot-project/api-boot-starters/api-boot-starter-message-pipe-server/pom.xml
@@ -0,0 +1,38 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>api-boot-starters</artifactId>
+        <groupId>org.minbox.framework</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>api-boot-starter-message-pipe-server</artifactId>
+    <properties>
+        <main.basedir>${basedir}/../../..</main.basedir>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>api-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-server</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>message-pipe-spring-context</artifactId>
+        </dependency>
+    </dependencies>
+    <developers>
+        <developer>
+            <name>恒宇少年</name>
+            <email>jnyuqy@gmail.com</email>
+            <organization>minbox-projects</organization>
+            <organizationUrl>https://gitee.com/minbox-projects</organizationUrl>
+        </developer>
+    </developers>
+</project>
diff --git a/api-boot-project/api-boot-starters/pom.xml b/api-boot-project/api-boot-starters/pom.xml
index 6bb7eaa0..19d6c54f 100644
--- a/api-boot-project/api-boot-starters/pom.xml
+++ b/api-boot-project/api-boot-starters/pom.xml
@@ -33,6 +33,8 @@
         <module>api-boot-starter-logging-admin</module>
         <module>api-boot-starter-sequence</module>
         <module>api-boot-starter-mongo-client-settings</module>
+        <module>api-boot-starter-message-pipe-client</module>
+        <module>api-boot-starter-message-pipe-server</module>
     </modules>
 
 </project>
diff --git a/api-boot-samples/api-boot-sample-message-pipe-client/pom.xml b/api-boot-samples/api-boot-sample-message-pipe-client/pom.xml
new file mode 100644
index 00000000..33a62a07
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-client/pom.xml
@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>api-boot-samples</artifactId>
+        <groupId>org.minbox.framework</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>api-boot-sample-message-pipe-client</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.redisson</groupId>
+            <artifactId>redisson-spring-boot-starter</artifactId>
+            <version>3.13.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>api-boot-starter-message-pipe-client</artifactId>
+        </dependency>
+    </dependencies>
+    <dependencyManagement>
+        <dependencies>
+            <!--ApiBoot 版本依赖-->
+            <dependency>
+                <groupId>org.minbox.framework</groupId>
+                <artifactId>api-boot-dependencies</artifactId>
+                <version>${api-boot.version}</version>
+                <scope>import</scope>
+                <type>pom</type>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+</project>
diff --git a/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/MessagePipeClientSampleApplication.java b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/MessagePipeClientSampleApplication.java
new file mode 100644
index 00000000..e3bffb56
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/MessagePipeClientSampleApplication.java
@@ -0,0 +1,22 @@
+package org.minbox.framework.api.boot.sample.message.pipe.client;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author 恒宇少年
+ */
+@SpringBootApplication
+public class MessagePipeClientSampleApplication {
+    /**
+     * logger instance
+     */
+    static Logger logger = LoggerFactory.getLogger(MessagePipeClientSampleApplication.class);
+
+    public static void main(String[] args) {
+        SpringApplication.run(MessagePipeClientSampleApplication.class, args);
+        logger.info("ApiBoot Message Pipe Client 服务启动成功.");
+    }
+}
diff --git a/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java
new file mode 100644
index 00000000..4cd7f6e0
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java
@@ -0,0 +1,27 @@
+package org.minbox.framework.api.boot.sample.message.pipe.client.processor;
+
+import lombok.extern.slf4j.Slf4j;
+import org.minbox.framework.message.pipe.client.process.MessageProcessor;
+import org.springframework.stereotype.Service;
+
+/**
+ * 示例 {@link MessageProcessor}
+ *
+ * @author 恒宇少年
+ */
+@Slf4j
+@Service
+public class TestMessageProcessor implements MessageProcessor {
+    private static final String TEST_PIPE_NAME = "test";
+
+    @Override
+    public String bindingPipeName() {
+        return TEST_PIPE_NAME;
+    }
+
+    @Override
+    public boolean processing(String requestId, byte[] messageBody) {
+        log.info("消费消息：{}，内容：{}", requestId, new String(messageBody));
+        return true;
+    }
+}
diff --git a/api-boot-samples/api-boot-sample-message-pipe-client/src/main/resources/application.yml b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/resources/application.yml
new file mode 100644
index 00000000..40cf7cd9
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/resources/application.yml
@@ -0,0 +1,23 @@
+spring:
+  redis:
+    port: 6379
+    timeout: 10000
+    database: 1
+    lettuce:
+      pool:
+        max-active: 200
+        max-idle: 200
+server:
+  port: 8082
+api:
+    boot:
+        message:
+            pipe:
+                client:
+                    configuration:
+                        # Server地址，默认为 "localhost"
+                        server-address: localhost
+                        # Server端口号，默认为 "5200"
+                        server-port: 5200
+                        # 本地Client端口号，默认为 "5201"
+                        local-port: 5201
diff --git a/api-boot-samples/api-boot-sample-message-pipe-server/pom.xml b/api-boot-samples/api-boot-sample-message-pipe-server/pom.xml
new file mode 100644
index 00000000..d52467dd
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-server/pom.xml
@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>api-boot-samples</artifactId>
+        <groupId>org.minbox.framework</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>api-boot-sample-message-pipe-server</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.redisson</groupId>
+            <artifactId>redisson-spring-boot-starter</artifactId>
+            <version>3.13.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>api-boot-starter-message-pipe-server</artifactId>
+        </dependency>
+    </dependencies>
+    <dependencyManagement>
+        <dependencies>
+            <!--ApiBoot 版本依赖-->
+            <dependency>
+                <groupId>org.minbox.framework</groupId>
+                <artifactId>api-boot-dependencies</artifactId>
+                <version>${api-boot.version}</version>
+                <scope>import</scope>
+                <type>pom</type>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+</project>
diff --git a/api-boot-samples/api-boot-sample-message-pipe-server/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/server/MessagePipeServerSampleApplication.java b/api-boot-samples/api-boot-sample-message-pipe-server/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/server/MessagePipeServerSampleApplication.java
new file mode 100644
index 00000000..7462721d
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-server/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/server/MessagePipeServerSampleApplication.java
@@ -0,0 +1,22 @@
+package org.minbox.framework.api.boot.sample.message.pipe.server;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author 恒宇少年
+ */
+@SpringBootApplication
+public class MessagePipeServerSampleApplication {
+    /**
+     * logger instance
+     */
+    static Logger logger = LoggerFactory.getLogger(MessagePipeServerSampleApplication.class);
+
+    public static void main(String[] args) {
+        SpringApplication.run(MessagePipeServerSampleApplication.class, args);
+        logger.info("ApiBoot Message Pipe Server服务启动成功.");
+    }
+}
diff --git a/api-boot-samples/api-boot-sample-message-pipe-server/src/main/resources/application.yml b/api-boot-samples/api-boot-sample-message-pipe-server/src/main/resources/application.yml
new file mode 100644
index 00000000..6c3ade7f
--- /dev/null
+++ b/api-boot-samples/api-boot-sample-message-pipe-server/src/main/resources/application.yml
@@ -0,0 +1,20 @@
+spring:
+  redis:
+    port: 6379
+    timeout: 10000
+    database: 1
+    lettuce:
+      pool:
+        max-active: 200
+        max-idle: 200
+server:
+  port: 8081
+
+api:
+    boot:
+        message:
+            pipe:
+                server:
+                    configuration:
+                        # 配置监听端口号，默认为5200
+                        server-port: 5200
diff --git a/api-boot-samples/pom.xml b/api-boot-samples/pom.xml
index 40c0cef2..929fe2a2 100644
--- a/api-boot-samples/pom.xml
+++ b/api-boot-samples/pom.xml
@@ -43,5 +43,7 @@
         <module>api-boot-sample-sequence</module>
         <module>api-boot-sample-mongo-client-settings</module>
         <module>api-boot-sample-tools</module>
+        <module>api-boot-sample-message-pipe-client</module>
+        <module>api-boot-sample-message-pipe-server</module>
     </modules>
 </project>