java实现socket
java编程对于Socket之间的通信过程如下:
服务端往Socket的输出流里面写东西,客户端就可以通过Socket的输入流读取对应的内容。Socket与Socket之间是双向连通的,所以客户端也可以往对应的Socket输出流里面写东西,然后服务端对应的Socket的输入流就可以读出对应的内容。下面来看一些服务端与客户端通信的例子:
publicclassServer{
publicstaticvoidmain(Stringargs[])throwsIOException{
//为了简单起见,所有的异常信息都往外抛
intport=8899;
//定义一个ServerSocket监听在端口8899上
ServerSocketserver=newServerSocket(port);
//server尝试接收其他Socket的连接请求,server的accept方法是阻塞式的
Socketsocket=server.accept();
//跟客户端建立好连接之后,我们就可以获取socket的InputStream,并从中读取客户端发过来的信息了。
Readerreader=newInputStreamReader(socket.getInputStream());
charchars[]=newchar[64];
intlen;
StringBuildersb=newStringBuilder();
while((len=reader.read(chars))!=-1){
sb.append(newString(chars,0,len));
}
System.out.println("fromclient:"+sb);
reader.close();
socket.close();
server.close();
}
}
客户端代码
Java代码publicclassClient{
publicstaticvoidmain(Stringargs[])throwsException{
//为了简单起见,所有的异常都直接往外抛
Stringhost="127.0.0.1";//要连接的服务端IP地址
intport=8899;//要连接的服务端对应的监听端口
//与服务端建立连接
Socketclient=newSocket(host,port);
//建立连接后就可以往服务端写数据了
Writerwriter=newOutputStreamWriter(client.getOutputStream());
writer.write("HelloServer.");
writer.flush();//写完后要记得flush
writer.close();
client.close();
}
}
② java socket输入流inputStream.read(byte[])方法一次读入多帧数据,也就是多帧数据连在一起
在使用Java Socket的inputStream.read(byte[])方法时,如果服务端发送数据的速度超过客户端读取的速度,客户端可能会一次性读取到多帧数据连在一起的情况。这种情况下,数据包的读取和处理就需要特别注意。一种处理方式是在服务端将每一帧数据作为一行写入Socket,客户端则通过BufferedReader逐行读取。这样可以确保每次读取的数据都是一个完整的数据帧。
具体实现步骤如下:
1. 在服务端使用PrintWriter将数据帧作为一行写入Socket输出流:
2. 代码示例如下:
java
PrintWriter writer = new PrintWriter(socket.getOutputStream());
writer.println(data);
2. 在客户端,通过BufferedReader逐行读取Socket输入流的数据:
2. 代码示例如下:
java
BufferedReader reader = new BufferedReader(new BufferedInputStream(socket.getInputStream()));
String s = reader.readLine();
这种方式可以确保客户端每次读取到的数据都是一个完整的数据帧,而不会出现多帧数据连在一起的情况。通过这种方式,可以更好地管理和处理Socket通信中不同帧数据的读取。
使用这种方法处理数据帧时,需要注意的是,每一帧数据必须以换行符结束,这样才能被正确地解析为一行。此外,客户端在读取每一行数据后,应该进行适当的解析和处理,以确保数据的完整性和正确性。
通过这种方式处理数据帧,可以有效地解决服务端发送数据速度过快,而客户端读取速度较慢的问题,从而提高数据通信的稳定性和可靠性。
③ Java Socket 长连接怎么实现
现编这个就是个多线程服务器,只要在client不释放连接,服务器端的run里边写while(TRUE)循环,那么就可以长期连接。
class ConnectionThread extends Thread{
Socket client;
int counter;
public ConnectionThread(Socket cl,int c){
client = cl;
counter= c;
}
@Override
public void run()
{
try{
String destIP=client.getInetAddress().toString();
int destport =client.getPort();
PrintStream outstream=new PrintStream(client.getOutputStream());
DataInputStream instream=new DataInputStream(client.getInputStream());
String inline=instream.readLine();
}//try
catch(IOException e){System.out.println(e);}
}//run