Java在同一个套接字上的客户端和服务器端之间发送和接收多条消息
Java在同一个套接字上的客户端和服务器端之间发送和接收多条消息
提问于 2014-03-15 06:18:30
我有以下情况，
- TCP服务器将接受连接fron客户端。
- 客户端将发送第一个请求，服务器将响应该请求，服务器必须在同一个套接字上等待接收来自同一个客户端的下一个请求。
- 请参阅我所做的代码，此代码服务器无法接收服务器发送的第二个请求，客户端在第二次接收时也接收来自服务器的第一个响应。
- 请对此提出建议，代码中有什么问题。
- 我试着模拟这个案例，如果有人以前遇到过，请尽快提出建议。
Client_MultipleMessages.java：
public class Client_MultipleMessages {
public static void main(String[] args) {
Socket clientSocket = null;
SocketAddress sockaddr = null;
boolean IsSocketCreated = false;
String p_Response = "";
OutputStream outToServer = null;
InputStream in = null;
String strRequestString = "";
try{
clientSocket = new Socket();
sockaddr = new InetSocketAddress("192.168.121.121", 1234);
try{
clientSocket.connect(sockaddr, 1000);
if (clientSocket.isConnected()){
IsSocketCreated = true;
}
}catch(Exception e){
System.out.println("Exception while creating socket,Reason is:"+ e.getMessage());
}
int index = 1;
String req = "REGISTRATION_REQUEST";
while(index <= 2){
if(clientSocket.isConnected()){
outToServer = clientSocket.getOutputStream();
System.out.println("Request "+index+":"+req);
outToServer.write(req.getBytes());
outToServer.flush();
//clientSocket.setSoTimeout(1000);
in = clientSocket.getInputStream();
int i = -1;
while((i = in.read()) > 0){
p_Response += (char) i;
}
System.out.println("Response "+index+":"+p_Response);
}
index++;
req = "LERGD_ALLOCATE_MSISDN";
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}Server_MultipleMessages.java
public class Server_MultipleMessages {
public static void main(String[] args) {
try{
ServerSocket Server = new ServerSocket (1234);
while(true){
Socket socket = Server.accept();
String fromclient = "";
BufferedReader inFromClient = null;
PrintWriter outToClient = null;
String strresponse = "";
try{
int reqCount = 1;
socket.setSoTimeout(2000);
while(reqCount <= 2){
System.out.println("Request-"+reqCount);
inFromClient = new BufferedReader(new InputStreamReader(socket.getInputStream()));
outToClient = new PrintWriter(socket.getOutputStream(),true);
char data[] = new char[1200];
inFromClient.read(data);
for (int i = 0; i < data.length; i++) {
fromclient = fromclient + Character.toString(data[i]);
}
System.out.println("XML Request is from client: "+fromclient+"\n\n");
String returnDesc = "success";
if(fromclient.contains("REGISTRATION_REQUEST")){
System.out.println("Request if for Registeration !!");
strresponse = "<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>" + 0 + "</ERROR_CODE> <ERROR_DESC>" + returnDesc + "</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>";
}else if(fromclient.contains("LERGD_ALLOCATE_MSISDN")){
System.out.println("Request is for allocate Msisdnm !!");
strresponse = "<RESPONSE><HEADER><TRANSACTION_ID>123456</TRANSACTION_ID><REQUEST_TYPE>LERGD_ALLOCATE_MSISDN</REQUEST_TYPE><ERROR_CODE>" + 0 + "</ERROR_CODE><ERROR_DESC>" + returnDesc + "</ERROR_DESC></HEADER><BODY><ACTION_TAKEN>B</ACTION_TAKEN><ALLOCATED_MSISDN>7525600000</ALLOCATED_MSISDN></BODY></RESPONSE>";
}else{
System.out.println("Invalid Request from client !!");
}
System.out.println("XML Response to be send to client: "+strresponse+"\n\n");
outToClient.print(strresponse);
outToClient.flush();
strresponse = "";
fromclient = "";
reqCount++;
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
if(!socket.isClosed()){
socket.close();
}
}
}
}catch(Exception ex){
System.out.println("Error in ProcessXmlRequest : "+ex.getMessage());
}
}}服务器端输出：
Request-1
XML Request is from client: REGISTRATION_REQUEST
Request if for Registeration !!
XML Response to be send to client: <REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>
Request-2
java.net.SocketTimeoutException: Read timed out客户端输出：
Request 1:REGISTRATION_REQUEST
Response 1:<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>
Request 2:LERGD_ALLOCATE_MSISDN
Response 2:<REGISTRATION_RESPONSE><HEADER><ERROR_CODE>0</ERROR_CODE><ERROR_DESC>success</ERROR_DESC></HEADER><BODY>,DIAMETER-S6A,TCAP,</BODY></REGISTRATION_RESPONSE>回答 2
Stack Overflow用户
发布于 2014-03-15 06:51:07
您的客户端正在读取响应，直到流结束，只有当对等方关闭套接字时才会发生这种情况，这使得不可能有多个交换。您需要设计另一种分隔消息的方法。在这种情况下，仅仅发送和接收线路就足够了。
Stack Overflow用户
发布于 2015-10-28 09:51:10
在服务器上，PrintWriter设置为autoFlush (第二个param)
outToClient = new PrintWriter(socket.getOutputStream(),true);还可以在编写完后调用刷新()。
outToClient.print(strresponse); //autoFlush here
outToClient.flush();然后当客户端读取
while((i = in.read()) > 0)它可能是第二次刷新。在这种情况下，它没有什么可读取的，退出循环并打印先前的响应。打印后，试着清除客户端的响应，并检查这是否是问题所在。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/22420342
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号