修改demo项目名

examples/local-rpc-lient/pom.xml → examples/local-rpc-client/pom.xml

@@ -4,11 +4,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <groupId>io.github.forezp</groupId>
-    <artifactId>local-rpc-lient</artifactId>
+    <artifactId>local-rpc-client</artifactId>
     <version>1.0.6</version>
     <packaging>jar</packaging>
-
-    <name>local-rpc-lient</name>
+    <name>local-rpc-client</name>
     <description>Demo project for Spring Boot</description>
 
     <parent>
@@ -30,19 +29,16 @@
             <groupId>io.github.forezp</groupId>
             <artifactId>boot-netty-rpc-core</artifactId>
             <version>${netty.rpc.core}</version>
-
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
-
     </dependencies>
 
     <build>

examples/local-rpc-lient/src/main/java/com/forezp/localrpclient/LocalRpcLientApplication.java → examples/local-rpc-client/src/main/java/com/forezp/localrpclient/LocalRpcLientApplication.java

@@ -3,7 +3,6 @@
 import com.forezp.localrpclient.client.IGreeting;
 import io.github.forezp.netty.rpc.core.annotation.EnableNettyRpc;
 import io.github.forezp.netty.rpc.core.common.dto.RespDTO;
-
 import io.github.forezp.netty.rpc.core.monitor.trace.MonitorMessage;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
@@ -20,22 +19,20 @@
 public class LocalRpcLientApplication {
 
     public static void main(String[] args) {
-        SpringApplication.run( LocalRpcLientApplication.class, args );
+        SpringApplication.run(LocalRpcLientApplication.class, args);
     }
 
-
     @Autowired
     IGreeting greeting;
 
     @GetMapping("/test")
     public RespDTO test() throws Exception {
-
 //        IGreeting invoker = (IGreeting) Invoker.invoke( IGreeting.class );
 //        Object result = invoker.sayHello( "sww" );
 
-        Object object = greeting.sayHello( "hi" );
-
-        return RespDTO.success( object );
+        //调用服务端sayHello()方法
+        Object object = greeting.sayHello("zhangsan");
+        return RespDTO.success(object);
     }
 
     @PostMapping("/postmsg")

examples/local-rpc-lient/src/main/java/com/forezp/localrpclient/client/IGreeting.java → examples/local-rpc-client/src/main/java/com/forezp/localrpclient/client/IGreeting.java

@@ -12,4 +12,5 @@
 public interface IGreeting {
 
     String sayHello(String name);
+
 }

examples/local-rpc-client/src/main/resources/application.yml

@@ -0,0 +1,31 @@
+server:
+  port: 7002
+
+netty:
+  clients:
+    -
+      name: server
+      host: localhost
+      port: 6001
+    -
+      name: server
+      host: localhost
+      port: 6001
+
+
+spring:
+  application:
+    name: client
+
+
+monitor:
+  mail:
+    enable:
+      ssl: false
+    host: smtp.163.com
+    password: yourpassword
+    username: miles02
+    from: [email protected]
+    to: [email protected]
+    cc: [email protected]  #抄送
+    bcc: [email protected] #密送

examples/local-rpc-server/pom.xml

@@ -7,7 +7,6 @@
     <artifactId>local-rpc-server</artifactId>
     <version>1.0.5</version>
     <packaging>jar</packaging>
-
     <name>local-rpc-server</name>
     <description>Demo project for Spring Boot</description>
 
@@ -34,7 +33,6 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>
@@ -44,15 +42,10 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
-
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-redis</artifactId>
         </dependency>
-
-
-
     </dependencies>
 
     <build>

examples/local-rpc-server/src/main/java/com/forezp/localrpcserver/LocalRpcServerApplication.java

@@ -2,8 +2,6 @@
 
 
 import io.github.forezp.netty.rpc.core.annotation.EnableNettyRpc;
-import io.github.forezp.netty.rpc.core.monitor.warm.*;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -19,9 +17,8 @@ public static void main(String[] args) {
         SpringApplication.run( LocalRpcServerApplication.class, args );
     }
 
-
-
     @GetMapping("/test")
-    public void test() {
+    public String test() {
+        return "server : test";
     }
 }

examples/local-rpc-server/src/main/java/com/forezp/localrpcserver/api/Greeting.java

@@ -10,8 +10,11 @@
  **/
 @Service
 public class Greeting implements IGreeting {
+
     @Override
     public String sayHello(String name) {
-        return "hi "+name;
+        System.out.println("server: Client message received {"+name+"}");
+        return "hi " + name;
     }
+
 }

examples/local-rpc-server/src/main/java/com/forezp/localrpcserver/api/IGreeting.java

@@ -9,4 +9,5 @@
 public interface IGreeting {
 
      String sayHello(String name);
+
 }

examples/local-rpc-server/src/main/resources/application.yml

@@ -1,17 +1,19 @@
 server:
   port: 7001
 
-netty.server.name: server
-netty.server.port: 6001
+netty:
+  server:
+    name: server
+    port: 6001
+
 
 spring:
   application:
     name: server
-
   redis:
     host: localhost
     port: 6379
-#    password: ee
+    #password: ee
     database: 1
     pool:
       max-active: 8
@@ -20,19 +22,18 @@ spring:
       min-idle: 0
     timeout: 0
 
+
 monitor:
+  #type: redis
   type: http
   url: http://localhost:7002/postmsg
-
-#monitor:
-#  type: redis
-
-monitor.mail.enable: false
-monitor.mail.host: smtp.163.com
-monitor.mail.username: miles02
-monitor.mail.password: yourpassword
-monitor.mail.enable.ssl:
-monitor.mail.from: [email protected]
-monitor.mail.to: [email protected]
-monitor.mail.cc: [email protected]
-monitor.mail.bcc: [email protected]
+  mail:
+    enable:
+      ssl: false
+    host: smtp.163.com
+    password: yourpassword
+    username: miles02
+    from: [email protected]
+    to: [email protected]
+    cc: [email protected]  #抄送
+    bcc: [email protected]  #密送

examples/pom.xml

@@ -15,12 +15,11 @@
     <packaging>pom</packaging>
 
     <modules>
-
         <module>example-rpc-lib</module>
         <module>example-eureka-server</module>
         <module>example-rpc-server</module>
         <module>example-rpc-client</module>
-        <module>local-rpc-lient</module>
+        <module>local-rpc-client</module>
         <module>local-rpc-server</module>
     </modules>
 
@@ -35,14 +34,12 @@
                 <scope>import</scope>
             </dependency>
 
-
             <dependency>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-starter-web</artifactId>
                 <version>${spring-boot.version}</version>
             </dependency>
 
-
             <dependency>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-starter</artifactId>
@@ -67,7 +64,6 @@
                 <scope>test</scope>
                 <version>${spring-boot.version}</version>
             </dependency>
-
         </dependencies>
     </dependencyManagement>