Java--Socket通信(客户端服务端双向)
新建两个工程,一个客户端,一个服务端,先启动服务端再启动客户端
两个工程的读写操作线程类基本上完全相同
服务端:
importjava.io.BufferedReader; importjava.io.DataInputStream; importjava.io.DataOutputStream; importjava.io.IOException; importjava.io.InputStreamReader; importjava.net.ServerSocket; importjava.net.Socket; publicclassServer{ publicstaticfinalintPORT=8000;//监听的端口号 publicstaticvoidmain(String[]args){ Serverserver=newServer(); server.init(); } publicvoidinit(){ ServerSocketserverSocket=null; try{ serverSocket=newServerSocket(PORT); while(true){ Socketclient=serverSocket.accept(); //一个客户端连接就开户两个线程处理读写 newThread(newReadHandlerThread(client)).start(); newThread(newWriteHandlerThread(client)).start(); } }catch(Exceptione){ e.printStackTrace(); }finally{ try{ if(serverSocket!=null){ serverSocket.close(); } }catch(IOExceptione){ e.printStackTrace(); } } } } /* *处理读操作的线程 */ classReadHandlerThreadimplementsRunnable{ privateSocketclient; publicReadHandlerThread(Socketclient){ this.client=client; } @Override publicvoidrun(){ DataInputStreamdis=null; try{ while(true){ //读取客户端数据 dis=newDataInputStream(client.getInputStream()); Stringreciver=dis.readUTF(); System.out.println("客户端发过来的内容:"+reciver); } }catch(Exceptione){ e.printStackTrace(); }finally{ try{ if(dis!=null){ dis.close(); } if(client!=null){ client=null; } }catch(IOExceptione){ e.printStackTrace(); } } } } /* *处理写操作的线程 */ classWriteHandlerThreadimplementsRunnable{ privateSocketclient; publicWriteHandlerThread(Socketclient){ this.client=client; } @Override publicvoidrun(){ DataOutputStreamdos=null; BufferedReaderbr=null; try{ while(true){ //向客户端回复信息 dos=newDataOutputStream(client.getOutputStream()); System.out.print("请输入:\t"); //键盘录入 br=newBufferedReader(newInputStreamReader(System.in)); Stringsend=br.readLine(); //发送数据 dos.writeUTF(send); } }catch(Exceptione){ e.printStackTrace(); }finally{ try{ if(dos!=null){ dos.close(); } if(br!=null){ br.close(); } if(client!=null){ client=null; } }catch(IOExceptione){ e.printStackTrace(); } } } }
客户端:
importjava.io.BufferedReader; importjava.io.DataInputStream; importjava.io.DataOutputStream; importjava.io.IOException; importjava.io.InputStreamReader; importjava.net.Socket; publicclassClient{ publicstaticfinalStringIP="localhost";//服务器地址 publicstaticfinalintPORT=8000;//服务器端口号 publicstaticvoidmain(String[]args){ handler(); } privatestaticvoidhandler(){ try{ //实例化一个Socket,并指定服务器地址和端口 Socketclient=newSocket(IP,PORT); //开启两个线程,一个负责读,一个负责写 newThread(newReadHandlerThread(client)).start(); newThread(newWriteHandlerThread(client)).start(); }catch(Exceptione){ e.printStackTrace(); } } } /* *处理读操作的线程 */ classReadHandlerThreadimplementsRunnable{ privateSocketclient; publicReadHandlerThread(Socketclient){ this.client=client; } @Override publicvoidrun(){ DataInputStreamdis=null; try{ while(true){ //读取服务器端数据 dis=newDataInputStream(client.getInputStream()); Stringreceive=dis.readUTF(); System.out.println("服务器端返回过来的是:"+receive); } }catch(IOExceptione){ e.printStackTrace(); }finally{ try{ if(dis!=null){ dis.close(); } if(client!=null){ client=null; } }catch(IOExceptione){ e.printStackTrace(); } } } } /* *处理写操作的线程 */ classWriteHandlerThreadimplementsRunnable{ privateSocketclient; publicWriteHandlerThread(Socketclient){ this.client=client; } @Override publicvoidrun(){ DataOutputStreamdos=null; BufferedReaderbr=null; try{ while(true){ //取得输出流 dos=newDataOutputStream(client.getOutputStream()); System.out.print("请输入:\t"); //键盘录入 br=newBufferedReader(newInputStreamReader(System.in)); Stringsend=br.readLine(); //发送数据 dos.writeUTF(send); } }catch(IOExceptione){ e.printStackTrace(); }finally{ try{ if(dos!=null){ dos.close(); } if(br!=null){ br.close(); } if(client!=null){ client=null; } }catch(Exceptione){ e.printStackTrace(); } } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。