wangkunTiny · Nov 4, 2020 · Nov 5, 2020 · Nov 5, 2020 · Nov 6, 2020 · Nov 6, 2020
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/ABCPlugin.java b/04fx/spring01/src/main/java/io/kimmking/spring04/ABCPlugin.java
@@ -0,0 +1,10 @@
+package io.kimmking.spring04;
+
+import org.springframework.core.Ordered;
+
+public interface ABCPlugin extends Ordered {
+
+    void startup()  throws Exception;
+    void shutdown() throws Exception;
+
+}
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/ABCStartup.java b/04fx/spring01/src/main/java/io/kimmking/spring04/ABCStartup.java
@@ -0,0 +1,26 @@
+package io.kimmking.spring04;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PreDestroy;
+import java.util.List;
+
+@Component
+public class ABCStartup {
+
+    @Autowired
+    private List<ABCPlugin> services;
+
+    public void call () {
+        services.forEach(System.out::println);
+    }
+
+    @PreDestroy
+    public void destroy() {
+
+        System.out.println(Thread.currentThread().getName()+"-destroy:" + this.getClass().getSimpleName());
+
+    }
+
+}
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/ABCStartupListener.java b/04fx/spring01/src/main/java/io/kimmking/spring04/ABCStartupListener.java
@@ -0,0 +1,46 @@
+package io.kimmking.spring04;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextClosedEvent;
+import org.springframework.context.event.ContextRefreshedEvent;
+import org.springframework.context.event.ContextStartedEvent;
+import org.springframework.context.event.ContextStoppedEvent;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class ABCStartupListener implements ApplicationListener<ApplicationEvent> {
+
+    @Autowired
+    private List<ABCPlugin> services;
+
+    @Override
+    public void onApplicationEvent(ApplicationEvent event) {
+
+        System.out.println(event);
+
+        // 如果用spring boot可以怎么改进
+        if (event instanceof ContextStartedEvent || event instanceof ContextRefreshedEvent) {
+            services.forEach(x -> {
+                try {
+                    x.startup();
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            });
+        }
+
+        if (event instanceof ContextClosedEvent | event instanceof ContextStoppedEvent) {
+            services.forEach(x -> {
+                try {
+                    x.shutdown();
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            });
+        }
+    }
+}
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/MockABCPlugin1.java b/04fx/spring01/src/main/java/io/kimmking/spring04/MockABCPlugin1.java
@@ -0,0 +1,36 @@
+package io.kimmking.spring04;
+
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.core.Ordered;
+import org.springframework.stereotype.Component;
+
+@Component()
+public class MockABCPlugin1 implements ABCPlugin, DisposableBean {
+
+    @Override
+    public String toString() {
+        System.out.println(Thread.currentThread().getName()+"-"+this.getClass().getSimpleName()+" toString.");
+        return this.getClass().getSimpleName();
+    }
+
+    @Override
+    public int getOrder() {
+        return 1;
+    }
+
+    @Override
+    public void startup() throws Exception {
+        // mock for netty server start
+        System.out.println(Thread.currentThread().getName()+"-"+this.toString()+" started.");
+    }
+
+    @Override
+    public void shutdown() throws Exception { // 线程池之类可以改进为优雅停机
+        System.out.println(Thread.currentThread().getName()+"-"+this.toString()+" stopped.");
+    }
+
+    @Override
+    public void destroy() throws Exception {
+        System.out.println(Thread.currentThread().getName()+"-DisposableBean:" + this.toString());
+    }
+}
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/MockABCPlugin2.java b/04fx/spring01/src/main/java/io/kimmking/spring04/MockABCPlugin2.java
@@ -0,0 +1,28 @@
+package io.kimmking.spring04;
+
+import org.springframework.core.Ordered;
+import org.springframework.stereotype.Component;
+
+@Component()
+public class MockABCPlugin2 implements ABCPlugin {
+
+    @Override
+    public String toString() {
+        return this.getClass().getSimpleName();
+    }
+
+    @Override
+    public int getOrder() {
+        return 2;
+    }
+
+    @Override
+    public void startup() throws Exception {
+        System.out.println(this.toString()+" started.");
+    }
+
+    @Override
+    public void shutdown() throws Exception {
+        System.out.println(this.toString()+" stopped.");
+    }
+}
diff --git a/04fx/spring01/src/main/java/io/kimmking/spring04/Spring04Main.java b/04fx/spring01/src/main/java/io/kimmking/spring04/Spring04Main.java
@@ -0,0 +1,21 @@
+package io.kimmking.spring04;
+
+import org.springframework.context.ApplicationEvent;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+
+public class Spring04Main {
+
+    public static void main(String[] args) {
+        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Spring04Main.class.getPackage().getName());
+        ABCStartup abc = context.getBean(ABCStartup.class);
+        abc.call();
+
+        context.publishEvent(new ApplicationEvent("myEvent") {});
+
+        context.close();
+        // context.destroy();
+        // context.stop(); // 这3个有什么区别？
+
+    }
+
+}
diff --git a/07rpc/mysql-demo/src/main/resources/application.properties b/07rpc/mysql-demo/src/main/resources/application.properties
diff --git a/07rpc/rpc01/rpcfx-demo-api/src/main/java/io/kimmking/rpcfx/demo/api/UserService.java b/07rpc/rpc01/rpcfx-demo-api/src/main/java/io/kimmking/rpcfx/demo/api/UserService.java
@@ -4,4 +4,6 @@ public interface UserService {
 
     User findById(int id);
 
+    //User findById(int id, String name);
+
 }
diff --git a/...x-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java b/...x-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java
@@ -28,16 +28,18 @@ public static void main(String[] args) {
 		// UserService service = new xxx();
 		// service.findById
 
-		UserService userService = Rpcfx.create(UserService.class, "http://localhost:8080/");
-		User user = userService.findById(1);
-		System.out.println("find user id=1 from server: " + user.getName());
-
+//		UserService userService = Rpcfx.create(UserService.class, "http://localhost:8080/");
+//		User user = userService.findById(1);
+//		System.out.println("find user id=1 from server: " + user.getName());
+//
 //		OrderService orderService = Rpcfx.create(OrderService.class, "http://localhost:8080/");
 //		Order order = orderService.findOrderById(1992129);
 //		System.out.println(String.format("find order name=%s, amount=%f",order.getName(),order.getAmount()));
-//
-//		//
-//		UserService userService2 = Rpcfx.createFromRegistry(UserService.class, "localhost:2181", new TagRouter(), new RandomLoadBalancer(), new CuicuiFilter());
+
+
+		UserService userService2 = Rpcfx.createFromRegistry(UserService.class, "localhost:2181", new TagRouter(), new RandomLoadBalancer(), new CuicuiFilter());
+		User user = userService2.findById(1);
+		System.out.println(user);
 
 //		SpringApplication.run(RpcfxClientApplication.class, args);
 	}

diff --git a/...1/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/OrderServiceImpl.java b/...1/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/OrderServiceImpl.java
@@ -7,6 +7,6 @@ public class OrderServiceImpl implements OrderService {
 
     @Override
     public Order findOrderById(int id) {
-        return new Order(id, "Cuijing" + System.currentTimeMillis(), 9.9f);
+        return new Order(id, "Order" + System.currentTimeMillis(), 9.9f);
     }
 }
diff --git a/...x-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java b/...x-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java
@@ -32,16 +32,16 @@ public class RpcfxServerApplication {
 	public static void main(String[] args) throws Exception {
 
 //		// start zk client
-//		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
-//		CuratorFramework client = CuratorFrameworkFactory.builder().connectString("localhost:2181").namespace("rpcfx").retryPolicy(retryPolicy).build();
-//		client.start();
+		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
+		CuratorFramework client = CuratorFrameworkFactory.builder().connectString("localhost:2181").namespace("rpcfx").retryPolicy(retryPolicy).build();
+		client.start();
 //
 //
 //		// register service
 //		// xxx "io.kimmking.rpcfx.demo.api.UserService"
 //
-//		String userService = "io.kimking.rpcfx.demo.api.UserService";
-//		registerService(client, userService);
+		String userService = "io.kimking.rpcfx.demo.api.UserService";
+		registerService(client, userService);
 //		String orderService = "io.kimking.rpcfx.demo.api.OrderService";
 //		registerService(client, orderService);
 
@@ -54,7 +54,7 @@ public static void main(String[] args) throws Exception {
 	private static void registerService(CuratorFramework client, String service) throws Exception {
 		ServiceProviderDesc userServiceSesc = ServiceProviderDesc.builder()
 				.host(InetAddress.getLocalHost().getHostAddress())
-				.port(8080).serviceClass(service).build();
+				.port(8081).serviceClass(service).build();
 		// String userServiceSescJson = JSON.toJSONString(userServiceSesc);
 
 		try {

diff --git a/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml b/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml
@@ -1,5 +1,5 @@
 server:
-  port: 8080
+  port: 8081
 
   profiles:
     active: true

diff --git a/07rpc/rpc02/dubbo-demo-consumer/pom.xml b/07rpc/rpc02/dubbo-demo-consumer/pom.xml
@@ -36,7 +36,7 @@
         <dependency>
             <groupId>org.apache.dubbo</groupId>
             <artifactId>dubbo-spring-boot-starter</artifactId>
-            <version>2.7.8</version>
+            <version>2.7.7</version>
         </dependency>
 
         <dependency>
Original file line number	Diff line number	Diff line change
Expand Up		@@ -4,4 +4,6 @@ public interface UserService {

		User findById(int id);

		//User findById(int id, String name);

		}