TCP

一、Socket是什么：

Socket是连接运行在网络上的两个程序间的双向通讯的端点。

为了能够方便的开发网络应用软件，由美国伯克利大学在Unix上推出了一种应用程序访问通信协议的操作系统调socket(套接字)。socket的出现，使程序员可以很方便地访问TCP/IP，从而开发各种网络应用的程序。随着Unix的应用推广，套接字在编写网络软件中得到了极大的普及。后来，套接字又被引进了Windows等操作系统中。Java语言也引入了套接字编程模型。

二、使用Socket进行网络通信的过程:

1.服务器程序将一个套接字绑定到一个特定的端口，并通过此套接字等待和监听客户的连接请求。

2.客户程序根据服务器程序所在的主机名和端口号发出连接请求。

3.如果一切正常，服务器接受连接请求。并获得一个新的绑定到不同端口地址的套接字。

4.客户和服务器通过读、写套接字进行通讯。

三、使用ServerSocket和Socket实现服务器端和客户端的 Socket通信总结：

1.建立Socket连接

2. 获得输入/输出流

3.读/写数据

4.关闭输入/输出流

5. 关闭Socket

Server端

import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;

/*
 * 基于TCP协议的Socket通信，实现用户登陆
 * 服务器端
 */
public class Server {
    public static void main(String[] args) {
        try {
            // 创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
            ServerSocket serverSocket = new ServerSocket(8888);
            Socket socket = null;
            System.out.println("服务器启动");

            // 监听等待客户端的连接
            socket = serverSocket.accept();

            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br= new BufferedReader(isr);

            String a;
            while ((a = br.readLine()) != null) {
                System.out.println("用户信息：" + a);
            }
            
            OutputStream os = socket.getOutputStream();
            OutputStreamWriter osw=new OutputStreamWriter(os);
            //osw.write("asd");
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("welcome");
            pw.flush();
            
            osw.close();
            os.close();
            br.close();
            isr.close();
            is.close();
            
            socket.close();
            serverSocket.close();
            
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Client端

 package test_1;

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

/*
 * 客户端
 */
public class Client {
    public static void main(String[] args) {
        try {
            //创建客户端Socket，指定服务器地址和端口
            Socket socket=new Socket("localhost", 8888);
            //获取输出流，向服务器端发送信息
            OutputStream os=socket.getOutputStream();//字节输出流
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("用户名：alice;密码：789");
            pw.flush();
            socket.shutdownOutput();//关闭输出流
            //获取输入流，并读取服务器端的响应信息
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            String info=null;
            while((info=br.readLine())!=null){
                System.out.println("我是客户端，服务器说："+info);
            }
            //4.关闭资源
            br.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 多线程的Server端：

package test_1;

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

/*
 * 基于TCP协议的Socket通信，实现用户登陆
 * 服务器端
 */
public class Server {
    public static void main(String[] args) {
        try {
            // 创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
            ServerSocket serverSocket = new ServerSocket(8888);
            Socket socket = null;
            System.out.println("服务器启动");
            
            while(true){
                // 监听等待客户端的连接
                socket = serverSocket.accept();
                
                Serverthread serverthread=new Serverthread(socket);
                
                serverthread.start();
                InetAddress address=socket.getInetAddress();
                System.out.println("当前客户端的IP："+address.getHostAddress());
            }

            
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}


package test_1;

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

public class Serverthread extends Thread{
    Socket socket=null;
    
    public Serverthread(Socket socket) {
        this.socket=socket;
    }
    
    public void run() {
        try {
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br= new BufferedReader(isr);

            String a;
            while ((a = br.readLine()) != null) {
                System.out.println("用户信息：" + a);
            }
            
            OutputStream os = socket.getOutputStream();
            OutputStreamWriter osw=new OutputStreamWriter(os);
            //osw.write("asd");
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("welcome");
            pw.flush();
            
            osw.close();
            os.close();
            br.close();
            isr.close();
            is.close();
            
            socket.close();
        } catch (IOException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        
    };
}