TCP(传输控制协议)简介：面向连接、可靠的传输层协议

server.java

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
 private int port = 1122;
 private ServerSocket serverSocket;
 public Server() throws Exception{
  serverSocket = new ServerSocket(port,3);
  System.out.println("服务器启动!");
 }
 public void service(){
  while(true){
   Socket socket = null;
   try {
    socket = serverSocket.accept();
    System.out.println("New connection accepted "+
      socket.getInetAddress()+":"+socket.getPort());
   } catch (IOException e) {
    e.printStackTrace();
   }finally{
    if(socket!=null){
     try {
      socket.close();
     } catch (IOException e) {
      e.printStackTrace();
     }
    }
   }
  }
 }
 public static void main(String[] args) throws Exception{
  Server server = new Server();
  Thread.sleep(60000*10);
  server.service();
 }
} 

  Client 试图与 Server 进行 100 次连接. 在 Server 类中, 把连接请求队列的长度设为 3. 这意味着当队列中有了 3 个连接请求时, 如果Client 再请求连接, 就会被 Server 拒绝.  下面按照以下步骤运行 Server 和 Client 程序.

⑴仅在服务器中创建一个serversocket对象。构造方法中指定的监视端口的长度为1122，连接请求队列的长度为3。构造构造函数后，服务器程序将睡眠10分钟，并且serversocket.acccept.acccept（）方法。这意味着队列中的连接请求将永远不会被取出。运行服务器程序和客户端程序后，客户端程序的打印结果如下：

第一个连接成功

第二个连接成功

成功的连接

线程“ main” java.net.connectionxception中的异常：连接：连接

………………。

从上面打印的结果来看，可以看出，在成功建立客户端和服务器之后，由于服务器团队已满，因此无法再创建其余连接。

构造与服务器中⑴⑴相同的serverversocket的对象。服务器程序没有睡觉。在整个循环中，连续执行serversocket.accept（）方法。新连接请求的打印结果。客户端程序的打印结果如下：

第一个连接成功

第二个连接成功

成功的连接

.............. ..

第100个连接成功

从上面的打印结果可以看出，目前，客户端可以成功建立与服务器的100个连接。 （随时随地的循环太快了。如果太慢，队列的连接请求的速度比连接请求的速度慢。如果您无法成功连接）

1.3设置绑定的IP地址

如果主机在默认值中只有一个IP地址，则服务器程序被绑定到IP地址。 serversocket serversocket的第四个构造函数（int端口，int积压，intetAddress bingaddr）具有BINDADDR参数，该参数明确指定服务器绑定IP地址，该构造函数适用于具有多个IP地址的主机。假设主机有两张网卡，一张网卡用于连接到Internet，IP为222.67.5.94，并且使用网卡连接到连接连接到连接连接连接连接的连接。本地LAN，IP地址为192.168.3.4。如果仅在本地LAN中的客户访问服务器，则可以创建serverSocket如下：

serversocket serverSocket = new serversocket（8000，10，inetaddress.getByName

1.4默认结构方法的作用

serversocket具有无参数的默认构造函数。该方法创建的serversocket不会绑定到任何端口。接下来，您需要将bind（）方法绑定到特定端口。

该默认构造函数的目的是允许服务器在绑定到特定端口之前为serversocket设置一些选项。因为一旦服务器绑定到特定端口，就无法更改某些选项。例如：so_reuseaddr选项

  在以下代码中, 先把 ServerSocket 的 SO_REUSEADDR 选项设为 true, 然后再把它与 8000 端口绑定:

 ServerSocket serverSocket = new ServerSocket();
 serverSocket.setReuseAddress(true); //设置 ServerSocket 的选项
 serverSocket.bind(new InetSocketAddress(8000));  //与8000端口绑定

如果以上程序代码更改为：

  ServerSocket serverSocket = new ServerSocket(8000);
  serverSocket.setReuseAddress(true);//设置 ServerSocket 的选项

然后，serversocket.setReuseadDress（true）方法没有任何效果，因为必须在服务器绑定端口之前设置SO_REUSEADDDR选项。

多线程示例

客户：

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 {
            //1.创建客户端Socket，指定服务器地址和端口
            Socket socket=new Socket("localhost", 8888);
            //2.获取输出流，向服务器端发送信息
            OutputStream os=socket.getOutputStream();//字节输出流
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("用户名：whf;密码：789");
            pw.flush();
            socket.shutdownOutput();//关闭输出流
            //3.获取输入流，并读取服务器端的响应信息
            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();
        }
    }
}

服务器：

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.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
/*
 * 基于TCP协议的Socket通信，实现用户登陆
 * 服务器端
 */
public class Server {
    public static void main(String[] args) {
        try {
            //1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
            ServerSocket serverSocket=new ServerSocket(8888);
            Socket socket=null;
            //记录客户端的数量
            int count=0;
            System.out.println("***服务器即将启动，等待客户端的连接***");
            //循环监听等待客户端的连接
            while(true){
                //调用accept()方法开始监听，等待客户端的连接
                socket=serverSocket.accept();
                //创建一个新的线程
                ServerThread serverThread=new ServerThread(socket);
                //启动线程
                serverThread.start();
                count++;//统计客户端的数量
                System.out.println("客户端的数量："+count);
                InetAddress address=socket.getInetAddress();
                System.out.println("当前客户端的IP："+address.getHostAddress());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服务器处理类：

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;
/*
 * 服务器线程处理类
 */
public class ServerThread extends Thread {
    // 和本线程相关的Socket
    Socket socket = null;
    public ServerThread(Socket socket) {
        this.socket = socket;
    }
    //线程执行的操作，响应客户端的请求
    public void run(){
        InputStream is=null;
        InputStreamReader isr=null;
        BufferedReader br=null;
        OutputStream os=null;
        PrintWriter pw=null;
        try {
            //获取输入流，并读取客户端信息
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);
            String info=null;
            while((info=br.readLine())!=null){//循环读取客户端的信息
                System.out.println("我是服务器，客户端说："+info);
            }
            socket.shutdownInput();//关闭输入流
            //获取输出流，响应客户端的请求
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("欢迎您！");
            pw.flush();//调用flush()方法将缓冲输出
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            //关闭资源
            try {
                if(pw!=null)
                    pw.close();
                if(os!=null)
                    os.close();
                if(br!=null)
                    br.close();
                if(isr!=null)
                    isr.close();
                if(is!=null)
                    is.close();
                if(socket!=null)
                    socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}