Sokect简单入门（2）TCP协议二

通过多线程实现服务器端的多用户访问

一、线程方法

  

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

import pb.socket.entity.User;

/**
 * 专门的线程类
 * */
public class ServerThread extends Thread {
    //和本线程相关的Socket
    Socket socket=null;
    
    public ServerThread(Socket socket){
        this.socket=socket;
    }
    
    //线程启动:响应客户请求
    public void run(){
        try {
            //3.获得输入流
            InputStream is=socket.getInputStream();
            //获得流：可以对对象进行反序列化
            ObjectInputStream ois=new ObjectInputStream(is);
            //获得输出流
            OutputStream os=socket.getOutputStream();
            PrintWriter pw=new PrintWriter(os);
            //4.读取用户输入信息
            User user=(User)ois.readObject();
            System.out.println("用户信息："+user.getLoginName()+"---"+user.getPwd());
            //给客户一个响应
            String reply="welcome!";
            pw.write(reply);
            pw.flush();
            //5.关闭资源
            pw.close();
            os.close();
            ois.close();
            is.close();
            socket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

二、服务器端代码

/**
 * 服务器端
 * */
public class LoginServer {
    public static void main(String[] args) {
        try {
            //1.建立一个服务器Socket（ServerSocket）绑定指定端口并开始监听
            ServerSocket serverSocket=new ServerSocket(8800);
            //2.使用accept()方法阻塞等待监听，获得新的连接
            Socket socket=null;
            //客户数量
            int num=0;
            //一直处于监听状态
            while(true){
                socket=serverSocket.accept();
                ServerThread serverThread=new ServerThread(socket);
                serverThread.start();
                num++;
                System.out.println("客户数量为："+num);
                
                //客户的IP信息
                InetAddress ia=socket.getInetAddress();
                //客户的Ip
                String ip=ia.getHostAddress();
                System.out.println("本客户的IP为："+ip);
                //客户的主机名称
                String hostname=ia.getHostName();
                System.out.println("本客户的主机为："+hostname);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } 
        
    }
}

 三、客户端代码

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

import pb.socket.entity.User;

/**
 * 客户端
 * */
public class LoginClient {
    public static void main(String[] args) {
        try {
            //1.建立客户端Socket连接，指定服务器的位置以及端口
            Socket socket=new Socket("localhost",8800);
            //2.得到Socket的读写流
            OutputStream os=socket.getOutputStream();
            //对象序列化流
            ObjectOutputStream oos=new ObjectOutputStream(os);
            //输入流
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            //3.利用流按照一定的协议对Socket进行读/写操作
            User user=new User();
            user.setLoginName("kate");
            user.setPwd("120056");
            oos.writeObject(user);
            
            socket.shutdownOutput();
            //接受服务器的响应并打印显示
            String reply=null;
            while(!((reply=br.readLine())==null)){
                System.out.println("我是客户端，服务器的响应为："+reply);
            }
            //4.关闭资源
            br.close();
            is.close();
            oos.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}