|
Problem with Socket Client - Intermittent Truncated Response in AIX
Hi guru
I have written on Socket Client method below to send request byte[] to Host and receive response byte[] from Host.
For this particular response, I'm expecting Host to return me byte[] with length 2274.
My problem is intermittently I received truncated message byte[] from Host with length only 1392. Sometimes I received full 2274 message, sometimes I received 1392 length. I tested in continual of 10 times by sending the same request to host, intermittently received truncated response message.
My real problem is that this only happened in AIX machine. With the same class, I tested on Windows platform and i received full response message byte[] with 2274 lenght always. Therefore, im counting out the possibilities that Host might send me truncated message.
Can anyone pls help to tell me how should I proceed to troubleshoot this problem in AIX? Is possible for me to trace what coming in?
[i] public byte[] sendToHost(byte[] requestMessage, String requestId, String localTxnCode) throws Exception {
BufferedInputStream bis = null;
BufferedOutputStream bos = null;
long startTime = 0;
long elapsed = 0;
try {
LogManager.log(LogManager.DEBUG, Constants.DEFAULT_LOGGER_NAME, requestId, "[" + localTxnCode + "] To connect and send message to Host hostAddr=[" + hostAddr + "], hostPort=[" + hostPort
+ "]");
startTime = System.currentTimeMillis();
hostSocket = new Socket(InetAddress.getByName(hostAddr), hostPort);
hostSocket.setSoTimeout(timeOut);
byte responseData[] = new byte[4096];
bis = new BufferedInputStream(hostSocket.getInputStream());
bos = new BufferedOutputStream(hostSocket.getOutputStream()) ;
bos.write(requestMessage);
bos.flush();
int length = bis.read(responseData);
elapsed = System.currentTimeMillis() - startTime;
ARBAdapterUtil.log(LogManager.DEBUG, Constants.DEFAULT_LOGGER_NAME, requestId, "[" + localTxnCode + "] Received message from Host length=[" + length + "]");
// The response byte must not be 4096 everytime
byte[] returnByte = new byte[length];
for (int i = 0; i < length; i++) {
returnByte[i] = responseData;
}
return returnByte;
} catch (BindException b) {
elapsed = System.currentTimeMillis() - startTime;
throw new SocketException("Socket Exception: BindException IP=" + hostAddr + " PORT=" + hostPort + " Error type=" + b.getClass().getName() + " Error message=" + b.getMessage());
} catch (ConnectException c) {
elapsed = System.currentTimeMillis() - startTime;
throw new SocketException("Socket Exception: ConnectException IP=" + hostAddr + " PORT=" + hostPort + " Error type=" + c.getClass().getName() + " Error message=" + c.getMessage());
} catch (NoRouteToHostException nrth) {
elapsed = System.currentTimeMillis() - startTime;
throw new SocketException("Socket Exception: NoRouteToHostException IP=" + hostAddr + " PORT=" + hostPort + " Error type=" + nrth.getClass().getName() + " Error message="
+ nrth.getMessage());
} catch (SocketTimeoutException se) {
elapsed = System.currentTimeMillis() - startTime;
throw new SocketTimeoutException("Socket Exception: SocketTimeoutException IP=" + hostAddr + " PORT=" + hostPort + " Error type=" + se.getClass().getName() + " Error message=" + se.getMessage());
} catch (SocketException s) {
elapsed = System.currentTimeMillis() - startTime;
throw new SocketException("Socket Exception: SocketException IP=" + hostAddr + " PORT=" + hostPort + " Error type=" + s.getClass().getName() + " Error message=" + s.getMessage());
} catch (Exception e) {
elapsed = System.currentTimeMillis() - startTime;
throw new Exception("Unknown Exception: Exception IP=" + hostAddr + " PORT=" + hostPort + "Error type=" + e.getClass().getName() + " Error message=" + e.getMessage());
} finally {
try {
ARBAdapterUtil.log(LogManager.INFO, Constants.DEFAULT_LOGGER_NAME, requestId, "ARBConnection.sendToHost() [" + localTxnCode + "] Time Elapsed via Socket in millisecond = [" + elapsed + "]");
if (bis != null) {
bis.close();
bis = null;
}
if (bos != null) {
bos.close();
bos = null;
}
} catch (Exception e) {
LogManager.log(LogManager.ERROR, Constants.DEFAULT_LOGGER_NAME, requestId, "ARBConnection.sendToHost() [" + localTxnCode + "] Exception during closing BufferedInputStream and BufferedOutputStream");
}
}
}
|
Linear Mode
