commons-pool2

1、定义一个产生连接池的工厂,需要继承BasePooledObjectFactory,其用处是生产和销毁连接池中保存的对象。根据需求,现在池子里保存的应该是grpc客户端对象。

  GrpcClientFactory类:

 

2、连接池GrpcClientPool类

 

3、客户端程序

  这里仅仅简单列出了客户端GrpcClient类的代码,其他代码包括服务端代码见另一篇博客grpc(一)之helloworld。

 

4、客户端测试

 

  运行testService类的main()方法,客户端能正常调用grpc server得到数据,但是grpc服务端报错:

  出现这个问题的原因:客户端强制断开连接。参考https://stackoverflow.com/questions/46802521/io-grpc-netty-nettyservertransport-notifyterminated,

  

 

  我在GrpcClientFactory里面也实现了销毁方法:

  但是运行testService类的main()方法结束后服务端程序就结束了,程序没有主动调用destroyObject()方法销毁池子中的对象,所以grpcClient也没有shutdown,所以报错。

 

5、启动客户端springboot项目来测试

  但是这样当关闭客户端程序,还是出现同样的问题。其实很好理解,因为关闭客户端程序时,池中的对象还处于空闲状态,没有销毁,destroyObject()方法没有调用,所以grpcClient也没有shutdown。

  

6、解决方法

  客户端程序关闭时,池也要close。