diff --git a/README.md b/README.md
index f00d2efa49863b629792ca74ccc17bb2628e98a4..e50f8ccd918b5bc4f1e3f45dbdf2a82f713f1389 100644
--- a/README.md
+++ b/README.md
@@ -11,11 +11,12 @@
 
 #### 安装教程
 1.在项目根目录下的build.gradle文件中，
-2.在entry模块的build.gradle文件中，
-依赖暂无
 
+2.在entry模块的build.gradle文件中，
+暂无
+在sdk5，DevEco Studio2.1 beta4下项目可直接运行 如无法运行，删除项目.gradle,.idea,build,gradle,build.gradle文件， 并依据自己的版本创建新项目，将新项目的对应文件复制到根目录下
 #### 效果演示
-![效果](https://images.gitee.com/uploads/images/2021/0525/154811_04cd5f34_7918188.gif "826e9023-8391-4085-f8ef-25931f5f4918.gif")
+![效果演示](https://images.gitee.com/uploads/images/2021/0526/111504_59461e61_7918188.gif "Stom.gif")
 
 #### 使用说明
 
@@ -145,6 +146,7 @@ CloudTest代码测试无异常
 - 0.0.1-SNAPSHOT
 
 ## 版权和许可信息
+````
 he MIT License (MIT)
 
 Copyright (c) 2016 Nickolay Savchenko
@@ -165,4 +167,5 @@ FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
\ No newline at end of file
+SOFTWARE.
+
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
index 37963975decb0df45a3626d273e1254fb7d1b9bb..68f4cba294c578607ad54ad2ca8c2b66be9e8663 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/OpenHarmonySchedulers.java
@@ -48,8 +48,8 @@ public final class OpenHarmonySchedulers {
     /**
      * from 根据 eventRunner 返回 Scheduler
      *
-     * @param eventRunner
-     * @return
+     * @param eventRunner eventRunner
+     * @return Scheduler
      */
     public static Scheduler from(EventRunner eventRunner) {
         if (eventRunner == null) {
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
index d99a248ea781d2e9696a1e182db223fc4b810f84..842082ddd29f46febd7b8432fabe673e95bc0b10 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/rxHarmony/RxHmOSPlugins.java
@@ -21,7 +21,7 @@ public class RxHmOSPlugins {
      * 创建线程
      *
      * @param scheduler
-     * @return
+     * @return Scheduler
      */
     public static Scheduler initMainThreadScheduler(Callable<Scheduler> scheduler) {
         if (scheduler == null) {
diff --git a/entry/src/main/java/ua/naiksoftware/stompclientexample/slice/MainAbilitySlice.java b/entry/src/main/java/ua/naiksoftware/stompclientexample/slice/MainAbilitySlice.java
index f319bea92c8d4bf6d3050e7508e6472f7f425094..7f138c3c4450a2b067e4b9b7827c38c5cd81d052 100644
--- a/entry/src/main/java/ua/naiksoftware/stompclientexample/slice/MainAbilitySlice.java
+++ b/entry/src/main/java/ua/naiksoftware/stompclientexample/slice/MainAbilitySlice.java
@@ -236,8 +236,9 @@ public class MainAbilitySlice extends AbilitySlice implements Component.ClickedL
     }
 
     private void notifyList(int pos) {
+        mRecyclerView.scrollBy(0,1700);
         mRecyclerView.scrollTo(pos);
-        mAdapter.notifyDataChanged();
+        mAdapter.notifyDataSetItemChanged(pos);
     }
 
     /**
diff --git a/entry/src/main/resources/base/layout/ability_main.xml b/entry/src/main/resources/base/layout/ability_main.xml
index 826f9c88e72281f0f43444ba28b0aab997b4d1d8..f56ee7f1ddcec2f977dab4a1df17b0cdfadeea10 100644
--- a/entry/src/main/resources/base/layout/ability_main.xml
+++ b/entry/src/main/resources/base/layout/ability_main.xml
@@ -1,9 +1,9 @@
 <?xml version="1.0" encoding="utf-8"?>
-<DirectionalLayout
+<DependentLayout
     xmlns:ohos="http://schemas.huawei.com/res/ohos"
     ohos:height="match_parent"
     ohos:width="match_parent"
-    ohos:orientation="vertical">
+   >
 
     <Text
         ohos:id="$+id:tv_title"
@@ -18,6 +18,8 @@
         ohos:text_size="20vp"/>
 
     <DirectionalLayout
+        ohos:id="$+id:first"
+        ohos:below="$id:tv_title"
         ohos:height="match_content"
         ohos:width="match_parent"
         ohos:orientation="horizontal">
@@ -59,14 +61,17 @@
     </DirectionalLayout>
 
     <Component
+        ohos:id="$+id:seconed"
         ohos:height="1vp"
         ohos:width="match_parent"
         ohos:background_element="#eee"
         ohos:left_margin="16vp"
+        ohos:below="$id:first"
         ohos:padding="1vp"
         ohos:right_margin="16vp"/>
 
     <DirectionalLayout
+        ohos:below="$id:seconed"
         ohos:height="match_content"
         ohos:width="match_parent"
         ohos:orientation="horizontal">
@@ -111,12 +116,14 @@
     </DirectionalLayout>
 
     <ListContainer
+        ohos:align_parent_bottom="true"
         ohos:id="$+id:recycler_view"
-        ohos:height="match_parent"
+        ohos:height="match_content"
         ohos:width="match_parent"
+        ohos:layout_alignment="bottom"
         ohos:bottom_padding="16vp"
         ohos:left_padding="16vp"
         ohos:right_padding="16vp"
         ohos:top_padding="16vp"/>
 
-</DirectionalLayout>
\ No newline at end of file
+</DependentLayout>
\ No newline at end of file
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java b/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java
index 1c7cc42ffccb4fd0c15880b3e4fb4357503f5075..3fd6b03204968a4f0e23d50ec2172999c431c296 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java
@@ -118,6 +118,8 @@ public class HeartBeatTask {
     /**
      * Analise heart-beat sent from server (if any), to adjust the frequency.
      * Startup the heart-beat logic.
+     *
+     * @param heartBeatHeader heartBeatHeader
      */
     private void heartBeatHandshake(final String heartBeatHeader) {
         if (heartBeatHeader != null) {
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/RabbitPathMatcher.java b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/RabbitPathMatcher.java
index 1694989871fc706bad99f31b8a26d81afa5836f1..fc28a090cb9f644a5f71b70a6da445c48237298f 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/RabbitPathMatcher.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/pathmatcher/RabbitPathMatcher.java
@@ -12,8 +12,12 @@ import java.util.ArrayList;
  */
 public class RabbitPathMatcher implements PathMatcher {
     /**
-     * RMQ-style wildcards.
-     * See more info <a href="https://www.rabbitmq.com/tutorials/tutorial-five-java.html">here</a>.
+     * RMQ-style wildcards.RabbitPathMatcher
+     * See more info <a href="https://www.rabbitmq
+     *
+     * @param path path
+     * @param msg  msg
+     * @return boolean
      */
     @Override
     public boolean matches(String path, StompMessage msg) {
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
index 6a123530e6d156458f6f9861e25fccb29c6a66aa..03e850cafa326c6f93fcfc92ca7df0f9264915e3 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/AbstractConnectionProvider.java
@@ -98,11 +98,8 @@ public abstract class AbstractConnectionProvider implements ConnectionProvider {
     /**
      * Get socket object.
      * Used for null checking; this object is expected to be null when the connection is not yet established.
-     * <p>
-     * For example:
-     * <pre>
-     * return webSocket;
-     * </pre>
+     *
+     * @return Object
      */
     @Nullable
     protected abstract Object getSocket();
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/ConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/ConnectionProvider.java
index 9c66b65f58e9dbd97721c21e20f85482b3d459a4..c16460ce321af92d85270db9937bb702ae3754be 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/ConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/ConnectionProvider.java
@@ -12,6 +12,7 @@ import ua.naiksoftware.stomp.dto.LifecycleEvent;
 public interface ConnectionProvider {
     /**
      * Subscribe this for receive stomp messages
+     * @return Observable
      */
     Observable<String> messages();
 
@@ -20,20 +21,23 @@ public interface ConnectionProvider {
      * onError if not connected or error detected will be called, or onCompleted id sending started
      * send messages with ACK
      *
-     * @param stompMessage
-     * @return
+     * @param stompMessage stompMessage
+     * @return Completable
      * @noinspection checkstyle:TodoComment
      */
     Completable send(String stompMessage);
 
     /**
      * Subscribe this for receive #LifecycleEvent events
+     * @return Observable
      */
     Observable<LifecycleEvent> lifecycle();
 
     /**
      * Disconnects from server. This is basically a Callable.
      * Automatically emits Lifecycle.CLOSE
+     *
+     * @return Completable Completable
      */
     Completable disconnect();
 }
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
index 15c641cb00e5e49932b6e4a94719cee0a574e9a3..91d37f67b1b5556094eecf1c3e61566e321b0ae6 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/provider/OkHttpConnectionProvider.java
@@ -123,7 +123,7 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
     /**
      * getSocket
      *
-     * @return
+     * @return Object
      */
     @Nullable
     @Override
@@ -134,8 +134,8 @@ public class OkHttpConnectionProvider extends AbstractConnectionProvider {
     /**
      * headersAsMap
      *
-     * @param response
-     * @return
+     * @param response response
+     * @return TreeMap
      */
     @NonNull
     private TreeMap<String, String> headersAsMap(@NonNull Response response) {