clientthread.java

java scoket通信的源程序

import java.net.*;
import java.io.*;
public class ClientThread extends Thread          
{	//维持服务器与单个客户端的连接线程，负责接收客户端发来得信息
	//声明Socket对象，用于保存客户端的连接
    Socket clientSocket;
    
    //声明服务器端数据输入输出流
    DataInputStream in = null;
    DataOutputStream out = null;
    
    //声明ServerThread对象
    ServerThread serverThread;
    String str;
    public static int ConnectNumber=0;

    public ClientThread(Socket socket,ServerThread serverThread)
    {
        clientSocket=socket;   
        this.serverThread=serverThread;
        try
        {
        		//创建服务器端数据输入输出流
                in = new DataInputStream(clientSocket.getInputStream());
                out = new DataOutputStream(clientSocket.getOutputStream());
        }
        catch (IOException e2)
        {
            System.out.println("发生异常"+e2);
            System.out.println("建立I/O通道失败！");
            System.exit(3);
        }
    }

    public void run()
    {
        while(true)
        {
            try
            {
            	//读入客户端发送来得信息
                String Message=in.readUTF();
                synchronized(serverThread.messages)
                {
                    if(Message!=null)
                    {
                    	//将客户端发送来得信息存于Vector数组中
                        serverThread.messages.addElement(Message);
                        Sever.jTextArea1.append(Message+'\n');
                    }
                }
            }
            catch(IOException E){break;}
        }
    }
}