用Socket实现client和Server的有关问题-Java教程-爱易网页

用Socket实现client和Server的有关问题

日期：2014-05-20　浏览次数：20658 次

用Socket实现client和Server的问题
我们老师要我们写一个用Socket实现client和Server的作业
现在上网找了点代码
能实现客户端向服务器端发送消息
但只能是一个。。
我对线程认识太少了
希望各位帮我改改
实现服务端一直监听就是说客户端随时发信息服务器都能应答（以下程序只能服务端返回一次信息）

客户端:

Java code


package test.bwl;   
  
import java.io.BufferedReader;
import java.io.DataInputStream;   
import java.io.DataOutputStream;   
import java.io.IOException;   
import java.io.InputStreamReader;
import java.io.OutputStream;   
import java.net.Socket;   
import java.net.UnknownHostException;   
  
public class SocketClient {   
  
    public static void main(String[] args) {   
        Socket socket = null; 
        DataOutputStream doc; 
        DataInputStream in ; 
        try {   
            socket = new Socket("127.0.0.1", 1234);   
            OutputStream netOut = socket.getOutputStream();   
            doc = new DataOutputStream(netOut);   
            in = new DataInputStream(socket.getInputStream());   
            BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
            int flag=1;
            doc = new DataOutputStream(netOut);   
            in = new DataInputStream(socket.getInputStream()); 
            while(flag==1)
            {  
                System.out.print("请输入要发送的内容(输入exit退出)\n");
                String what=br.readLine();
                if("exit".equals(what))
                    break;
                doc.writeUTF(what);   
                String res = in.readUTF(); 
                System.out.println("客户端--->"+res);   
            }
            doc.close();   
            in.close();
        } catch (UnknownHostException e) {   
            e.printStackTrace();   
        } catch (IOException e) {   
            e.printStackTrace();   
        } finally {   
            if (socket != null) {   
                try {
                    socket.close(); 
                    System.out.println("关闭成功");
                } catch (IOException e) {   
                }   
            }   
        }   
    }   
}

服务器端:

Java code

package test.bwl;   
  
import java.io.DataInputStream;   
import java.io.DataOutputStream;   
import java.io.IOException;   
import java.net.ServerSocket;   
import java.net.Socket;   
  
public class SocketManager {   
    /**  
     * @param args  
     * @throws IOException   
     */  
    public static void main(String[] args) {   
        SocketManager manager = new SocketManager();
        System.out.println("启动监听.....");
        manager.doListen();
        
    }   
  
    public void doListen() {   
        ServerSocket server;   
        try {   
            server = new ServerSocket(1234);   
            while (true) {   
                Socket client = server.accept();   
                new Thread(new SSocket(client)).start();   
            }   
        } catch (IOException e) {   
            e.printStackTrace();   
        }   
  
    }   
  
    //服务器进程   
    class SSocket implements Runnable {   
  
        Socket client;   
  
        public SSocket(Socket client) {   
            this.client = client;   
        }   
  
        public void run() {
            
            DataInputStream input;   
            DataOutputStream output;   
            try {  
                
                input = new DataInputStream(client.getInputStream());   
                output = new DataOutputStream(client.getOutputStream());   
                String listMsg = input.readUTF();   
                output.writeUTF("服务器接收-->发回: " + listMsg );   
                System.out.println("接收:   " + listMsg);     
            } catch (Exception e) {   
                e.printStackTrace();   
            }   
        }   
    }   
  
}

免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。

用Socket实现client和Server的有关问题

相关资料更多>

推荐阅读更多>