心跳机制

心跳机制是常用的一个健康监测的机制，说白了就是每隔一段时间向服务器发送一个心跳的报文，服务收到报文后，就认为当前的客户端在活动的状态，否则会进入异常的机制，比如说主从切换。

既然存在一个通信，就一定会有服务端和客户端。服务端开启监听，客户端发起心跳报文，然后服务就再次响应。

IO本质上是对数据缓冲区的读写，主要分为文件IO和网络IO，基本模型有很多，可以从两个方面去认识 同步和异步，阻塞和非阻塞。根据上面分类可以分为下面五类：

1. 阻塞I/O（blocking I/O）
2. 非阻塞I/O （nonblocking I/O）
3. I/O复用(select 、poll和epoll) （I/O multiplexing）
4. 信号驱动I/O （signal driven I/O (SIGIO)）
5. 异步I/O （asynchronous I/O ）

在多路复用的IO的模型中，存在三种机制，分别是select，poll和epoll.为了便于理解，可以使用简单的伪代码来表示一个原始的IO的读写：

1
2
3
4
5
6
7
8
9
10

while(true)  
{  
     for(Stream i: streamArr)  
     {  
          if(i.isNotReady()){
               continue;
          }
          doSomething();
     }  
}  

全局组件初始化

对于组件的全局的初始化，可以使用前面所说的ImportBeanDefinitionRegistrar这个方法来指定初始化方法，以开源的队列QMQ的源码为例：

@EnableQmq实现方式

1
2
3
4
5
6
7
8
9
10
11

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
@Documented
@Import(QmqConsumerRegister.class)
public @interface EnableQmq {

    String appCode();

    String metaServer();
}

这个Demo的功能是客户端向服务端发送一个Hello Netty的消息，然后服务端又把消息返回给客户端

Server端

这些都是一些公共的代码，代码比较简单，服务端负责监听端口，Handler负责处理业务逻辑

获得接口的实现类有点困难

在Java中，由于反射的局限性，无法直接获取一个接口的所有实现子类，所以为了能够实现一个接口动态的注入实现的子类对象，需要借助ServiceLoader

简单的Demo使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

public interface IService {
	void doSomeThing();
}

public class DefalutService implements IService{
	@Override
	public void doSomeThing() {
		RzLogger.info("默认服务");
	}
}

public class LogService implements IService {
	@Override
	public void doSomeThing() {
		RzLogger.info("日志服务");
	}
}


public static void main(String[] args) {
		ServiceLoader<IService> loader = ServiceLoader.load(IService.class);
		for (IService service : loader) {
			service.doSomeThing();
		}
	}

AOP的使用

所谓AOP的思想是现在程序设计中常用的一种设计思想，主要是为了能够更好的监控程序的运行的情况。 在Spring中AOP的思想展现的淋漓尽致。

实现一个简单的AOP。

1
2
3
4
5
6
7
8

@Component
public class OrderBiz {
	
	public void doSomething(int x, int y) {
		System.out.println(x + y);
	}
}

在Spring容器中，实例对象都会有三个过程，创建，初始化和消亡。

创建 Bean 的方式

@Bean 注解指定方法

1
2
3
4

@Bean(initMethod = "init",destroyMethod = "destroy")
public  Dog getDog(){
     return new Dog();
}

IOC的使用

@Configuration是入口

在Spring中，在一个类的上面增加@Configuration注解，这个就表示当前为配置类，可以代替xml形式的配置形式。在类中可以定义各种bean的定义，这些定义会被AnnotationConfigApplicationContext容器扫描。

1
2
3
4
5

@Configuration
public class RzConfig 
{

}

发现addShutdownHook

在阅读QMQ的源码的时候，在Server端启动的时候，注册了一个shutdown的代码,具体的代码如下：

1
2

Runtime.getRuntime().addShutdownHook(new Thread(wrapper::destroy));

addShutdownHook作用

addShutdownHook方法可以添加一个指定的线程来在Java程序退出的时候做一些事情，在以下几个场景会被调用：

1. 程序运行完成后退出
2. 使用Ctrl+C时终端退出
3. 调用系统退出的方法， System.exit(0)