[ISSUE apache#219]Supply detail information or read.me for eventmesh …

…running in docker
xwm1992 · Mar 11, 2021 · 499e478 · 499e478
1 parent 07bf12a
commit 499e478
Show file tree

Hide file tree

Showing 25 changed files with 69 additions and 90 deletions.
diff --git a/docs/cn/instructions/eventmesh-runtime-quickstart.zh-CN.md b/docs/cn/instructions/eventmesh-runtime-quickstart.zh-CN.md
@@ -56,7 +56,7 @@ sh start.sh
 
 **2.3.1 项目结构说明：**
 
-![](../../images/project-structure.png)
+![project-structure](../../images/project-structure.png)
 - eventmesh-common : eventmesh公共类与方法模块
 - eventmesh-connector-api : eventmesh插件接口定义模块
 - eventmesh-connector-rocketmq : eventmesh rocketmq插件模块
@@ -157,15 +157,15 @@ docker run -d -p 10000:10000 -p 10105:10105 -v /data/eventmesh/rocketmq/conf/pro
 
 执行 `docker ps` 来检查容器的运行状况
 
-![image-20210309155917269](..\..\images\docker\docker-ps.png)
+![image-docker-ps](..\..\images\docker\docker-ps.png)
 
 执行 `docker logs [container id]` 可以得到如下结果
 
-![image-20210309195623836](..\..\images\docker\docker-logs.png)
+![image-docker-logs](..\..\images\docker\docker-logs.png)
 
 执行 `docker exec -it [container id] /bin/bash` 可以进入到容器中并查看详细信息
 
-![image-20210309200327627](..\..\images\docker\docker-exec.png)
+![image-docker-exec](..\..\images\docker\docker-exec.png)
 
 ### 3.4 测试
 

diff --git a/docs/cn/instructions/eventmesh-sdk-java-quickstart.zh-CN.md b/docs/cn/instructions/eventmesh-sdk-java-quickstart.zh-CN.md
@@ -10,7 +10,7 @@ TCP 和 Http 示例都在**eventmesh-test**模块下
 
 **注意：**下载了源代码后，需要将`/conf/application.properties` 和 `/conf/log4j2.xml` 复制到 `resources` 目录下
 
-![image-20210311193048090](..\..\images\eventmesh-test-structure.png)
+![image-test-structure](..\..\images\eventmesh-test-structure.png)
 
 ### 1. TCP DEMO
 
@@ -21,14 +21,14 @@ TCP 和 Http 示例都在**eventmesh-test**模块下
 - 启动消费者，订阅上一步骤已经创建的Topic
 
 ```
-运行com.webank.eventmesh.client.tcp.demo.AsyncSubscribe的主要方法
+运行com.webank.eventmesh.tcp.demo.AsyncSubscribe的主要方法
 ```
 
 - 启动发送端，发送消息
 
 
 ```
-运行com.webank.eventmesh.client.tcp.demo.AsyncPublish的主要方法
+运行com.webank.eventmesh.tcp.demo.AsyncPublish的主要方法
 ```
 
 <h4>广播消息</h4>
@@ -38,13 +38,13 @@ TCP 和 Http 示例都在**eventmesh-test**模块下
 - 启动消费端，订阅上一步骤已经创建的Topic
 
 ```
-运行com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast的主要方法
+运行com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast的主要方法
 ```
 
 - 启动发送端，发送广播消息
 
 ```
-运行com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast的主要方法
+运行com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast的主要方法
 ```
 
 ### 2. HTTP演示
@@ -62,13 +62,13 @@ TCP 和 Http 示例都在**eventmesh-test**模块下
   异步事件消费端为spring boot demo，运行demo即可启动服务并完成Topic订阅
 
 ```
-运行com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication的主要方法
+运行com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication的主要方法
 ```
 
 - 启动发送端，发送消息
 
 ```
-运行com.webank.eventmesh.client.http.demo.AsyncPublishInstance的主要方法
+运行com.webank.eventmesh.http.demo.AsyncPublishInstance的主要方法
 ```
 
 

diff --git a/docs/en/instructions/eventmesh-runtime-quickstart.md b/docs/en/instructions/eventmesh-runtime-quickstart.md
@@ -56,7 +56,7 @@ Same with 1.2
 
 **2.3.1 Project structure：**
 
-![](..\..\images\project-structure.png)
+![project-structure.png](../../images/project-structure.png)
 
 - eventmesh-common : eventmesh common classes and method module
 - eventmesh-connector-api : eventmesh connector api definition module
@@ -156,15 +156,15 @@ docker run -d -p 10000:10000 -p 10105:10105 -v /data/eventmesh/rocketmq/conf/pro
 
 execute `docker ps` to check the container health
 
-![image-20210309155917269](..\..\images\docker\docker-ps.png)
+![image-docker-ps](..\..\images\docker\docker-ps.png)
 
 execute `docker logs [container id]` you will get following result:
 
-![image-20210309195623836](..\..\images\docker\docker-logs.png)
+![image-docker-logs](..\..\images\docker\docker-logs.png)
 
 execute `docker exec -it [container id] /bin/bash` you will go into the container and see the details:
 
-![image-20210309200327627](..\..\images\docker\docker-exec.png)
+![image-docker-exec](..\..\images\docker\docker-exec.png)
 
 ### 3.4 Test
 

diff --git a/docs/en/instructions/eventmesh-sdk-java-quickstart.md b/docs/en/instructions/eventmesh-sdk-java-quickstart.md
@@ -10,7 +10,7 @@ TCP demos and Http demos are both under the **eventmesh-test** module.
 
 **prerequisite**：after download the source code you should copy `/conf/application.properties` and `/conf/log4j2.xml` to the `resources` directory
 
-![image-20210311193048090](..\..\images\eventmesh-test-structure.png)
+![image-test-structure](..\..\images\eventmesh-test-structure.png)
 
 ###  1. TCP DEMO
 
@@ -21,34 +21,30 @@ TCP demos and Http demos are both under the **eventmesh-test** module.
 - start consumer ,subscribe topic in previous step. 
 
 ```
-Run the main method of com.webank.eventmesh.client.tcp.demo.AsyncSubscribe
+Run the main method of com.webank.eventmesh.tcp.demo.AsyncSubscribe
 ```
 
 - start producer, send  message
 
 
 ```
-Run the main method of com.webank.eventmesh.client.tcp.demo.AsyncPublish
+Run the main method of com.webank.eventmesh.tcp.demo.AsyncPublish
 ```
 
 #### Broadcast msg 
 
 - create topic FT0-e-80030000-01-3 on rocketmq-console
 
-```
-sh runadmin.sh updateTopic  -c ${ClusterName} -t ${topic} -n ${namesrvAddr}
-```
-
 - start consumer ,subscribe topic in previous step. 
 
 ```
-Run the main method of com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast
+Run the main method of com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast
 ```
 
 * start producer, send broadcast message
 
 ```
-Run the main method of com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast
+Run the main method of com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast
 ```
 
 ### 2. HTTP DEMO
@@ -66,12 +62,12 @@ Run the main method of com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcas
   Async consumer demo is a spring boot application demo,  you can easily run this demo to start service and subscribe the topic.
 
 ```
-Run the main method of com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication
+Run the main method of com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication
 ```
 
 - start producer, produce msg
 
 ```
-Run the main method of com.webank.eventmesh.client.http.demo.AsyncPublishInstance
+Run the main method of com.webank.eventmesh.http.demo.AsyncPublishInstance
 ```
 
diff --git a/eventmesh-test/bin/http_pub.sh b/eventmesh-test/bin/http_pub.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.http.demo.AsyncPublishInstance" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.client.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_http_pub.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.http.demo.AsyncPublishInstance
+DEMO_MAIN=com.webank.eventmesh.http.demo.AsyncPublishInstance
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_http_pub.out

diff --git a/eventmesh-test/bin/http_sub.sh b/eventmesh-test/bin/http_sub.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_http_sub.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.http.demo.sub.SpringBootDemoApplication
+DEMO_MAIN=com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_http_sub.out

diff --git a/eventmesh-test/bin/tcp_pub.sh b/eventmesh-test/bin/tcp_pub.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublish" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_pub.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.tcp.demo.AsyncPublish
+DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncPublish
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_pub.out

diff --git a/eventmesh-test/bin/tcp_pub_broadcast.sh b/eventmesh-test/bin/tcp_pub_broadcast.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_pub_broadcast.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.tcp.demo.AsyncPublishBroadcast
+DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_pub_broadcast.out

diff --git a/eventmesh-test/bin/tcp_sub.sh b/eventmesh-test/bin/tcp_sub.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribe" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_sub.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.tcp.demo.AsyncSubscribe
+DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncSubscribe
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_sub.out

diff --git a/eventmesh-test/bin/tcp_sub_broadcast.sh b/eventmesh-test/bin/tcp_sub_broadcast.sh
@@ -43,13 +43,13 @@ function get_pid {
 	else
 		if [[ $OS =~ Msys ]]; then
 			# 在Msys上存在可能无法kill识别出的进程的BUG
-			ppid=`jps -v | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
+			ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
 		elif [[ $OS =~ Darwin ]]; then
 			# 已知问题：grep java 可能无法精确识别java进程
-			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		else
 			#在Linux服务器上要求尽可能精确识别进程
-			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
+			ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $PROXY_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
 		fi
 	fi
 	echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
 echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_sub_broadcast.out
 
 
-DEMO_MAIN=com.webank.eventmesh.client.tcp.demo.AsyncSubscribeBroadcast
+DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast
 if [ $DOCKER ]
 then
 	$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_sub_broadcast.out

diff --git a/eventmesh-test/conf/log4j2.xml b/eventmesh-test/conf/log4j2.xml
@@ -28,7 +28,7 @@
             <AppenderRef ref="console"/>
         </AsyncRoot>
 
-        <AsyncLogger name="com.webank.eventmesh.client" level="debug" additivity="false" includeLocation="true">
+        <AsyncLogger name="com.webank.eventmesh" level="debug" additivity="false" includeLocation="true">
             <AppenderRef ref="console"/>
         </AsyncLogger>
     </Loggers>

diff --git a/...lient/http/demo/AsyncPublishInstance.java → ...tmesh/http/demo/AsyncPublishInstance.java b/...lient/http/demo/AsyncPublishInstance.java → ...tmesh/http/demo/AsyncPublishInstance.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.client.http.demo;
+package com.webank.eventmesh.http.demo;
 import com.webank.eventmesh.client.http.conf.LiteClientConfig;
 import com.webank.eventmesh.client.http.producer.LiteProducer;
 import com.webank.eventmesh.common.Constants;

diff --git a/...t/http/demo/AsyncSyncRequestInstance.java → ...h/http/demo/AsyncSyncRequestInstance.java b/...t/http/demo/AsyncSyncRequestInstance.java → ...h/http/demo/AsyncSyncRequestInstance.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.client.http.demo;
+package com.webank.eventmesh.http.demo;
 import com.webank.eventmesh.client.http.conf.LiteClientConfig;
 import com.webank.eventmesh.client.http.producer.LiteProducer;
 import com.webank.eventmesh.client.http.producer.RRCallback;

diff --git a/...client/http/demo/SyncRequestInstance.java → ...ntmesh/http/demo/SyncRequestInstance.java b/...client/http/demo/SyncRequestInstance.java → ...ntmesh/http/demo/SyncRequestInstance.java
@@ -1,22 +1,14 @@
-package com.webank.eventmesh.client.http.demo;
+package com.webank.eventmesh.http.demo;
 import com.webank.eventmesh.client.http.conf.LiteClientConfig;
 import com.webank.eventmesh.client.http.producer.LiteProducer;
 import com.webank.eventmesh.common.IPUtil;
 import com.webank.eventmesh.common.LiteMessage;
-import com.webank.eventmesh.common.ThreadPoolFactory;
 import com.webank.eventmesh.common.ThreadUtil;
-import com.webank.eventmesh.util.Utils;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.LinkedList;
-import java.util.Properties;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicLong;
-
 public class SyncRequestInstance {
 
     public static Logger logger = LoggerFactory.getLogger(SyncRequestInstance.class);

diff --git a/...p/demo/sub/SpringBootDemoApplication.java → ...p/demo/sub/SpringBootDemoApplication.java b/...p/demo/sub/SpringBootDemoApplication.java → ...p/demo/sub/SpringBootDemoApplication.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.client.http.demo.sub;
+package com.webank.eventmesh.http.demo.sub;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;

diff --git a/...tp/demo/sub/controller/SubController.java → ...tp/demo/sub/controller/SubController.java b/...tp/demo/sub/controller/SubController.java → ...tp/demo/sub/controller/SubController.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.client.http.demo.sub.controller;
+package com.webank.eventmesh.http.demo.sub.controller;
 
 import com.alibaba.fastjson.JSONObject;
 import org.slf4j.Logger;