多线程_TCP编程

java源码示例展示：

服务端：

package tcp2;

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 登录的服务器
 * @author superdrew 
 *     TCP 登录 
 *    功能:用户在客户端输入用户名和密码提交给服务器，服务器接收并处理,处理完后给客户端一个返回信息
 *        客户端接口服务器的反馈消息并输出
 *    缺点:服务器处理一次用户请求之后，就关闭了
 *            应该是服务器一直监听，可以处理多个用户的请求
 *        使用while循环类似达到效果，但是不可以
 *        不是并行，是串行的。请求一次，只能等待该次请求执行完毕
 *        
 *        问题:学生1-------咨询1     学生2---------咨询1 学    生3------------咨询1
 *        
 *        解决:
 *        学生1------------        ---------------咨询1            
 *        学生2    ------------ 前台接待  ---------------咨询2
 *        学生3------------       ----------------咨询3
 *      
 *      使用线程来处理
 */
public class LoginServer {
    public static void main(String[] args) throws IOException {
        //1.创建一个serversocket  创建服务
        @SuppressWarnings("resource")
        ServerSocket serverSocket = new ServerSocket(8888);//端口 8888  IP地址是本机
        int i =1;
        while(true){
            Socket socket = serverSocket.accept();
            InetAddress ia = socket.getInetAddress();
            new LoginThread(socket).start();
            System.out.println("第"+ i++ +"个人来访问,访问者ip是:"+ia.getHostAddress());
        }
    }
}

客户端：

package tcp2;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

/**
 * 登录的客户端
 * @author superdrew
 *
 */
public class LoginClient {
    public static void main(String[] args) throws UnknownHostException, IOException {
        //1.创建一个socket  连接服务器
        Socket socket = new Socket(InetAddress.getLocalHost(), 8888);//必须要知道服务器IP和端口号
        @SuppressWarnings("resource")
        Scanner sc = new Scanner(System.in);
        //2.通过 socket 发送数据给服务器
        //OutputStream os = new FileOutputStream("d:/b.txt");输出到文件
        System.out.println("请输入登入信息:");
        String info = sc.nextLine();
        OutputStream os = socket.getOutputStream();
        DataOutputStream dos = new DataOutputStream(os);
        dos.writeUTF(info);
        //3.接收服务器返回的消息
        DataInputStream dis = new DataInputStream(socket.getInputStream());
        String result = dis.readUTF();
        System.out.println("服务器返回的消息response："+result);
        
        //4.关闭资源
        dis.close();
        dos.close();
        socket.close();
    }
}

多人登入的线程：

package cn.com.sxt.tcp2;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

/**
 * 登录线程
 * @author superdrew
 *
 */
public class LoginThread extends Thread{
    private Socket socket;
    
    public void setSocket(Socket socket){
        this.socket = socket;
    }
    
    public LoginThread(Socket socket){
        this.socket = socket;
    }
    
    public void run() {
        InputStream is;
        DataOutputStream dos = null;
        DataInputStream dis = null;
        
        try {
            is = socket.getInputStream();
            dis = new DataInputStream(is);
            String result = dis.readUTF();
            System.out.println("客户端发送来的消息:"+result);
            //4.给客户端反馈一个消息 
            dos = new DataOutputStream(socket.getOutputStream());
            if("superdrew".equals(result)){
                dos.writeUTF("登录成功");
            }else{
                dos.writeUTF("登录失败");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(dos!=null){
                    dos.close();//关闭dos
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(dis!=null){
                    dis.close();//关闭dis
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(socket!=null){
                    socket.close();//关闭socket
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        
    }
}

操作步骤：

①运行服务端；②运行客户端；③输入登入信息为superdrew；④在console窗口下点击，可以看到这是第几次登入以及相关记录的信息；

结果展示---如图：