@dev change guide

wanxianliang · Sep 7, 2021 · b4184a0 · b4184a0
1 parent db187f9
commit b4184a0
Show file tree

Hide file tree

Showing 2 changed files with 44 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -14,14 +14,53 @@ serverRemote.run();
 
 
 
+Run Server in spring boot project
+
+```java
+public class SpringBootStartEvent implements ApplicationListener<SpringApplicationEvent>, ApplicationContextAware {
+    private ApplicationContext applicationContext;
+
+    @Bean(name = "serverRemote")
+    ServerRemote createNettyRemote() {
+        return ServerRemote.newServerInstance(8080, requestPlus -> {
+            //deal with request and return response
+            return ResponsePlus.build(0, "ok");
+        });
+    }
+
+    @Override
+    public void onApplicationEvent(SpringApplicationEvent springApplicationEvent) {
+        Object bean = applicationContext.getBean("serverRemote");
+        if (bean instanceof ServerRemote) {
+            try {
+                ((ServerRemote) bean).run();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            log.info("Start netty server successfully");
+        }
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+}
+```
+
+
+
 Run a client with follow code
 
 ```java
-ConnectManager connectManager = ConnectManager.newConnectInstance("127.0.0.1", 2222);
+String remoteAddress = "127.0.0.1";
+int port = 8080;
+ConnectManager connectManager = ConnectManager.newConnectInstance(remoteAddress, port);
 RequestPlus requestPlus = new RequestPlus();
 String requestId = connectManager.sendMsg(requestPlus);
 connectManager.handleResult(requestId, responsePlus -> {
-  //deal with response       
+//deal with response
+});
 });
 ```
 

diff --git a/src/test/java/tos/netty/client/ConnectManagerTest.java b/src/test/java/tos/netty/client/ConnectManagerTest.java
@@ -13,7 +13,9 @@ public class ConnectManagerTest {
 
     @Test
     public void sendMsg() throws ExecutionException, InterruptedException {
-        ConnectManager connectManager = ConnectManager.newConnectInstance("127.0.0.1", 8080);
+        String remoteAddress = "127.0.0.1";
+        int port = 8080;
+        ConnectManager connectManager = ConnectManager.newConnectInstance(remoteAddress, port);
         RequestPlus requestPlus = new RequestPlus();
         String requestId = connectManager.sendMsg(requestPlus);
         connectManager.handleResult(requestId, responsePlus -> {