最近在试着用java写一个socket的服务器,用python写一个socket的客户端来完成二者之间的通信,但是发现存在一个问题,服务器方面就卡在读取inputsream的地方不动了,导致后面的代码没办法执行,调试许久,找到问题所在
1>python中客户端send函数发送字符串的时候没有在字符串末尾自动加换行,而我在java服务器中使用的读取函数为readline()。不难想明白二者的格 式不同,所以java一直在等换行附来完成一次读取,所以导致代码无法继续执行
2>在将python方面的字符串人为的加上换行后,java服务器单行字符串读取正常,但是出现了新问题,它不会结束读取,一直处于等待状态。百度之,发现解决这个问题的方法比较多,我采用的是超时判断的办法,即一旦读取字符串的间隔时间超时即判定为字符串传输完毕(因为我的需求比较简单,所以采用这种简陋的办法也可,实际上也可采用其他方法比如限制读取长度,比如采用特定的字符串标记结尾)。超时会弹出超时异常,捕获之并在catch中加入退出读取字符串的函数即可
JAVA SOCKET SERVER
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.SocketTimeoutException; public class Conn extends Thread { /**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Conn tmp=new Conn();
tmp.start();
} public void run(){
try {
int i=0;
ServerSocket server=new ServerSocket(9998);
while(true){
System.out.println(i++);
Socket deal=server.accept();
BufferedReader in=new BufferedReader(new InputStreamReader(deal.getInputStream()));
PrintWriter out = new PrintWriter(deal.getOutputStream(), true);
String msg=in.readLine();
while(msg!=null){
try{
deal.setSoTimeout(500);
System.out.println(msg);
msg=in.readLine();
System.out.println("msg:"+msg);
deal.setSoTimeout(1);
}
catch(SocketTimeoutException e){
break;
}
}
out.write("ok############");
out.flush();
in.close();
out.close();
deal.close();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.toString());
}
} }
PYTHON SOCKET CLIENT:
import socket
ip='127.0.0.1'
port=9998
while True:
time.sleep(3)#控制请求发送频率
out= 'THIS IS A MSG'
print out
client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect((ip,port))
client.send(out+'\n')
print client.recv(512)
client.close()