Socket编程

1.Socket编程

套接字使用TCP创建两台计算机之间的通讯机制，客户端程序建立一个套接字尝试链接服务器的套接字。当创建链接时，服务器建立Socket对象，随后，客户端和服务器能够经过Socket对象的写入和读取来进行通讯。Java.net.Socket类表明一个套接字，而且Java.net.ServerSocket类为服务器提供了一种来监听客户端bingyu2他们创建链接的机制

1. 服务器实例化一个ServerSocket对象，表示经过服务器的端口进行通讯
2. ServerSocket类accept()方法监听，直到客户端链接服务器
3. 服务器在等待过程当中，一个客户端实例化一个Socket对象，指定服务器名称和端口号来请求链接
4. Socket类的构造函数将客户端链接到指定的服务器和端口号。若是通讯被创建，则在客户端建立一个Socket对象与服务器通讯
5. 服务器端，accept()方法返回服务器上一个socket引用，该socket链接到客户端的socket

链接创建后，经过I/O流通讯，每个Socket都有一个输入输出流，客户端的输出流链接到服务器端的输入流，客户端的输入流链接到服务器端的输出流；TCP是双向的传输控制协议，数据能够经过两个数据流在同一时间发送。

1.1Socket类构造方法及经常使用方法：

java.net.Socket类是服务器端和客户端用来沟通的套接字

• 客户端经过实例化获取Socket对象
• 服务器端经过ServerSocket的accept()方法的返回值来获取Socket对象

public Socket(String host, int port) //建立流套接字并链接到指定主机上的指定端口号
public Socket(InetAddress host, int port)//建立流套接字并链接到指定 IP 地址的指定端口号
public Socket()//经过系统默认类型的 SocketImpl 建立未链接套接字
//远程传递四个参数

  当Socket构造方法返回，会尝试链接到指定服务器和端口，由于客户端和服务器端Socket对象，能够调用socket方法：

public InetAddress getInetAddress()//返回套接字链接的地址
public InputStream getInputStream() //返回此套接字的输入流
public OutputStream getOutputStream()//返回此套接字的输出流
public SocketAddress getRemoteSocketAddress()//返回此套接字链接远程的端点的地址

1.2 ServerSocket类的构造方法及经常使用方法

public ServerSocket()//建立非绑定服务器套接字
public ServerSocket(int port) //建立绑定到特定端口的服务器套接字
ublic ServerSocket(int port, int backlog)// 利用指定的 backlog监听建立服务器套接字并将其绑定到指定的本地端口号

   调用ServerSocket构造方法-应用程序已经成功绑定指定端口，侦听客户端请求

public Socket accept()//侦听并接受到此套接字的链接
public void bind(SocketAddress host, int backlog)// ServerSocket 绑定到特定地址(IP+端口)
public int getLocalPort()//返回此套接字在其上侦听的端口

1.3InetAddress类(互联网协议)IP地址的方法

String getHostName() //获取IP地址主机名
static InetAddress getByAddress(byte[] addr)//在给定原始 IP 地址的状况下，返回 InetAddress 对象
static InetAddress getByName(String host)//在给定主机名的状况下肯定主机的 IP 地址

Socket链接服务器发送请求，等待响应

package com.day13;

import com.sun.security.ntlm.Server;

import java.io.*;
import java.net.Socket;

/**
 * @author SFJ
 * @date 2019/11/19
 * @time 21:29
 **/
public class Test1 {
    public static void main(String[] args) {//args数组传递参数
        String serverName = args[0];//第一个参数
        int port = Integer.parseInt(args[1]);//转成整型数据
        System.out.println("ServerName:"+serverName+" Port:"+port);
        try {
            Socket client = new Socket(serverName,port);
            System.out.println("RemoteHostAddress:"+client.getRemoteSocketAddress());
            OutputStream outputStreamToServer = client.getOutputStream();//返回此套接字输出流
            DataOutputStream outputStream = new DataOutputStream(outputStreamToServer);
            outputStream.writeUTF("hello comes from"+client.getLocalSocketAddress());
            InputStream inputStreamFromServer = client.getInputStream();
            DataInputStream inputStream = new DataInputStream(inputStreamFromServer);
            System.out.println("Server response:"+inputStream.readUTF());
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服务器应用程序-Socket监听指定端口

package com.day13;

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

/**
 * @author SFJ
 * @date 2019/11/19
 * @time 21:55
 **/
public class Test2  {

    public static void main(String[] args) {
        int port = Integer.parseInt(args[0]);
        try {
            Thread thread = new Server(port);
            thread.run();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}
class Server extends Thread{
    private ServerSocket serverSocket;
    public Server(int port) throws IOException
    {
        serverSocket = new ServerSocket(port);
        serverSocket.setSoTimeout(22222);
    }
    public void run()
    {
        for (;;)
        {
            System.out.println("Waiting for connection-Port:"+serverSocket.getLocalPort());
            try {
                Socket server = serverSocket.accept();
                System.out.println("RemoteSocketAddress: "+server.getRemoteSocketAddress());
                DataInputStream inputStream = new DataInputStream(server.getInputStream());
                System.out.println(inputStream.readUTF());
                DataOutputStream outputStream = new DataOutputStream(server.getOutputStream());
                outputStream.writeUTF("Thanks for connecting me "+server.getLocalSocketAddress()+"\nbye");
                server.close();
            } catch (IOException e) {
                e.printStackTrace();
                System.out.println("timed out");
            }
        }
    }
}