知识大全 Java中SOCKET通讯源码

Posted 2022-07-18 源程序

篇首语：人永远是要学习的。死的时候，才是毕业的时候。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java中SOCKET通讯源码相关的知识，希望对你有一定的参考价值。

Java中SOCKET通讯源码 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　//ServeOneSocket java 服务端源程序　　　　import java io *;　　import *;　　　　public class ServeOneSocket extends Thread 　　　　private Socket socket;　　private BufferedReader in;　　private PrintWriter out;　　private String content;　　　　/**　　* Constructor　　*/　　public ServeOneSocket(Socket s String c)throws IOException 　　socket=s;　　content=c;　　in=new BufferedReader(　　new InputStreamReader(　　socket getInputStream()));　　//enable auto flush　　out=new PrintWriter(　　new BufferedWriter(　　new OutputStreamWriter(　　socket getOutputStream())) true);　　start();//calls run()　　　　　　public void run()　　try　　while (true)　　String str=in readLine();　　if (str equals( END ))break;　　System out println( Echoing: +str);　　out println(str);　　out println(content);　　　　System out println( Closing );　　catch(IOException e)　　finally　　try　　socket close();　　catch(IOException e)　　　　　　　　　　//SocketClientThread java 客户端源程序　　　　import *;　　import java io *;　　　　class SocketClientThread extends Thread　　private Socket socket;　　private BufferedReader in;　　private PrintWriter out;　　private static int counter= ;　　private int id=counter++;　　private static int threadcount= ;　　final int port= ;　　　　public static int threadCount()　　return threadcount;　　　　　　public SocketClientThread(InetAddress addr)　　System out println( Making client: +id);　　threadcount++;　　try　　socket=new Socket(addr port);　　catch(IOException e)　　　　try　　in=new BufferedReader(　　new InputStreamReader(　　socket getInputStream()));　　out=new PrintWriter(　　new BufferedWriter(　　new OutputStreamWriter(　　socket getOutputStream())) true);　　start();　　catch(IOException e)　　try　　socket close();　　catch(IOException e )　　　　　　　　public void run()　　try　　for (int i= ;i<25;i++)　　out.println("Client:"+id+":"+i);　　String str=in.readLine();　　System.out.println(str);　　　　out.println("END");　　catch(IOException e)　　finally　　try　　socket.close();　　catch(IOException e)　　threadcount--;　　　　　　　　　　public class MultiSocketClient 　　static final int MAX_THREADS=10;　　/**　　* main　　* @param args　　*/　　public static void main(String[] args)throws IOException,InterruptedException 　　InetAddress addr=InetAddress.getByName(null);　　while (true)　　if (SocketClientThread.threadCount() 　　new SocketClientThread(addr);　　Thread.currentThread().sleep(100);　　　　　　 cha138/Article/program/Java/gj/201311/27538