記錄寫thrift客戶端socket連接池的問題解決

在網上找了寫客戶端Tsocket連接池的博客。可以參見https://blog.csdn.net/tianwei7518/article/details/44003287。

1.按照博客寫好連接池之后。，用連接池管理類獲取TSocket（獲取的TSocket不為null），替換自己new的TSocket之后。啟動報錯。org.apache.thrift.transport.T Transport Exception：Socket_alreadyconnected.

 

2.把framedTransport.open();注釋后啟動報錯org.apache.thrift.transport.T Transport Exception：java.net.SocketException：Software caused_connection abort：recv failed.

　　初步診斷應該是客戶端和服務器端的協議不一致。

3.現打算把連接池中的transport.open();注釋掉。然后啟動。啟動后報錯java.lang.NullPointerExceptionat org.apache.thrift.transport.T Framed Transport.open(T Framed Transport.java：82)

連接池管理中獲取的TSocket,在連接池工廠創建對象時，
	/**
	 * 創建對象
	 */
	@Override
	public TTransport makeObject() throws Exception {
		try {
			TTransport transport = new TSocket(this.serviceIP, this.servicePort, this.timeOut);
			transport.open();
			return transport;
		} catch (Exception e) {
			logger.error("error ThriftPoolableObjectFactory()", e);
			throw new RuntimeException(e);
		}
	}

4.定位是獲取Tsocket為null。debugger跟蹤原來是校驗時拋異常，如果TSocket沒打開連接池就認為他不是有效的TSocket。把這個校驗注釋掉。就可以啦。

/**
	 * 檢驗對象是否可以由pool安全返回
	 */
	@Override
	public boolean validateObject(TTransport tTransport) {
		try {
			if (tTransport instanceof TSocket) {
				TSocket thriftSocket = (TSocket) tTransport;
				if (thriftSocket.isOpen()) {
					return true;
				} else {
					return false;
				}
			} else {
				return false;
			}
		} catch (Exception e) {
			return false;
		}
	}
}

　總結：分析原因，我的客戶端程序中用的是TFramedTransport，連接池中的是TTransport。我的服務器端用的是TNonblockingServerTransport。所以open需要在我的代碼中重寫。