服务器<br />import java.io.*;<br />import java.net.*;<br /><br /><br />class EchoServerTherad extends Thread<br />{<br />        private Socket conn;<br />        public EchoServerTherad(Socket _conn)<br />        {<br />                conn = _conn;<br />                start();<br />        }<br />        <br />        public void run()<br />        {<br />                try<br />                {<br />                        DataInputStream in = new DataInputStream(new BufferedInputStream(conn.getInputStream()));<br />                        DataOutputStream out = new DataOutputStream(new BufferedOutputStream(conn.getOutputStream()));<br />                        String line = &quot;&quot;;<br />                        while(&#33;line.equalsIgnoreCase(&quot;QUIT&quot;))<br />                        {<br />                                line = in.readUTF();<br />                                //System.out.println (&quot;接受完毕&quot;);<br />                                System.out.println (&quot;Server:&quot;+line);<br />                                out.writeUTF(line);<br />                                out.flush();<br />                                //System.out.println (&quot;发送完毕&quot;);<br />                        }<br />                        in.close();<br />                        out.close();<br />                        conn.close();<br />                }catch(IOException e1){<br />                        System.out.println (e1.toString());<br />                }<br />        }<br />}<br /><br />public class EchoServer <br />{<br />        public static void main(String [] args)<br />        {<br />                try<br />                {<br />                        ServerSocket server = new ServerSocket(2000);<br />                        System.out.println (&quot;服务器正在监听：&quot;+server.getLocalPort()+&quot;端口.....&quot;);<br />                        while(true)<br />                        {<br />                                Socket conn = server.accept();<br />                                EchoServerTherad Techo = new EchoServerTherad(conn);<br />                        }<br />                }catch(IOException e1){<br />                        System.out.println (e1.toString());<br />                }        <br />        }<br />}<br /><br />客户端<br />import java.net.*;<br />import java.io.*;<br />import java.util.*;<br />public class EchoClient<br />{<br />        public static void main(String [] arsg)<br />        {<br />                try<br />                {<br />                Socket conn = new Socket(&quot;127.0.0.1&quot;,2000);<br />                DataInputStream in = new DataInputStream(conn.getInputStream());<br />                DataOutputStream out = new DataOutputStream(conn.getOutputStream());<br />                <br />                String line = new String(&quot;&quot;);<br />                while(&#33;line.toUpperCase().equals(&quot;QUIT&quot;))<br />                {<br />                        BufferedReader console = new BufferedReader(new InputStreamReader(System.in));<br />                        line = console.readLine();<br />                        out.writeUTF(line);<br />                        out.flush();<br />                        //System.out.println (&quot;发送完毕&quot;);<br />                        line = in.readUTF();<br />                        //System.out.println (&quot;接受完毕&quot;);<br />                        System.out.println (&quot;Client:&quot;+line);<br />                }<br />                in.close();<br />                out.close();<br />                conn.close();<br />                }catch(IOException e1){<br />                        System.out.println (e1.toString());<br />                }<br />        }<br />}