packagesockerk; importjava.io.DataInputStream; importjava.io.IOException; importjava.net.Socket; importjava.net.UnknownHostException; publicclassSocketClient{ publicstaticvoidmain(String[]args){ Socketsocket=null; try{ socket=newSocket("127.0.0.1",8888); DataInputStreamdis=newDataInputStream(socket.getInputStream()); Stringstring=""; while(!"end".equals(string)){ string=dis.readUTF(); System.out.println(string); } socket.close(); }catch(UnknownHostExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } } |
服务端
packagesocket; importjava.io.BufferedReader; importjava.io.DataOutputStream; importjava.io.IOException; importjava.io.InputStreamReader; importjava.net.ServerSocket; importjava.net.Socket; publicclassSocketSingleServer{ publicstaticvoidmain(String[]args)throwsIOException{ ServerSocketserverSocket=null; Socketclient=null; try{ serverSocket=newServerSocket(8888); client=serverSocket.accept(); BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in)); DataOutputStreamdos=newDataOutputStream(client.getOutputStream()); while(!client.isClosed()){ Stringstr=""; if((str=br.readLine())!=null){ dos.writeUTF(str); dos.flush(); } } }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }finally{ client.close(); } } } |
客服端
