这里是tcp客户端的代码
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class Socket_client {
public static void main(String[] args) throws UnknownHostException, IOException {
//first,创建一个socket对象
Socket s = new Socket("192.168.1.107",20000);
//second,获取Socket中的输出流
OutputStream out = s.getOutputStream();
//third,发送信息
out.write("嘿嘿嘿".getBytes());
//添加读取服务器返回信息功能
//使用socket流读取服务器返回数据
InputStream in = s.getInputStream();
byte[] b = new byte[1024];
int len = in.read(b);
String str = new String(b,0,len);
System.out.println(str);
//关闭资源
s.close();
}
}
这里是tcp服务端的代码
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server_Socket {
public static void main(String[] agrs) throws IOException{
//先建立一个服务Socket
ServerSocket ss = new ServerSocket(20000);
//获取客户Socket对象
Socket s = ss.accept();
//使用客户的Socket对象将信息打印出来
InputStream in = s.getInputStream();
byte[] b = new byte[1024];
int len;
while((len = in.read(b))!=-1){ //问题就出在这里,用循环读取,读取-1时,出现阻塞,后面代码无法运行
String str = new String(b,0,len);
System.out.println(str);
}
//使用客户的Socket对象将成功接受信息的信息反馈给客户端
OutputStream out = s.getOutputStream();
out.write("成功接受到信息".getBytes());
//关闭资源
s.close();
ss.close();
}
}
先执行了服务端,然后再执行客户端,服务端收到客户端发来的string后阻塞了,客户端也阻塞了,无法接受服务端回复的string
如果我把服务端循坏代码改成如下:
//使用客户的Socket对象将信息打印出来
InputStream in = s.getInputStream();
byte[] b = new byte[1024];
int len = in.read(b);
String str = new String(b,0,len);
System.out.println(str);
--------------------------------------------------
程序能正常运行,为何,求解?
这个问题本人已经解决了,一直没时间,现在写一下。为什么 while((len=in.read(b))!=-1) 会阻塞呢?这是因为read()在读的时候没有读到结束符,
也就是说从socket的输入流中没有获取到结束标记,所以一直在等待着客户端继续发送字节,然而客户端已经发送完毕,进行到 “使用socket流读取服务器返回数据”
这一步,这时,客户端这边的read()开始等待服务端返回的字节,因此,两边就陷入互相等待的状况!!!
解决办法:在客户端
//third,发送信息
out.write("嘿嘿嘿".getBytes());
//在这一步后面,再加一句作用是加入socket流的结束标志,但并不是关闭流资源,告诉服务端,数据发送完毕,让服务器停止读取
s.shutdownOutput();
PS:其实shutdownOutput()这个方法相当于服务端的while((len=in.read())!=null){..........省略; 加入 if(in.read()=="end"){break}},当接受到结束标记“end”的时候就
跳出循环了,或者理解为传入了一个null,就跳出循环。
1,查看服务开启是否正常一般看到start8161就正常了
2. 看端口,监听地址是否正确对应,消息队列。
3,监听只能监听本机的,别人的你时间听不到的。你可以往客户的IP上发送消息,在客户的机器上得有监听地址和处理消息的程序
下面这个,你可以参考下
我这也卡住了,API文档中是这样解释的
public void shutdownOutput()
throws IOException禁用此套接字的输出流。对于 TCP 套接字,任何以前写入的数据都将被发送,并且后跟 TCP 的正常连接终止序列。 如果在套接字上调用 shutdownOutput() 后写入套接字输出流,则该流将抛出 IOException。
我想不明白的是,如果客户端也采用whlie的方法读取信息,服务器端为什么不用 socket.shutdownOutput()方法,客户端也能正常读取服务器端发送的消息