Java网络


网络编程一词指的是编写在多个设备(计算机)上执行的程序,其中的设备都是用网络相互连接的。

J2SE API的java.net包包含提供低级通信详细信息的类和接口的集合,使你可以编写专注于解决当前问题的程序。

java.net软件包提供对以下两种常见网络协议的支持:

  • TCP:TCP代表传输控制协议,它允许两个应用程序之间进行可靠的通信,TCP通常在Internet协议(称为TCP / IP)上使用。

  • UDP:UDP代表用户数据报协议,这是一种无连接协议,允许在应用程序之间传输数据包。

本章对以下两个主题有很好的理解:

  • 套接字编程:这是网络中使用最广泛的概念,并且已经对其进行了非常详细的说明。

  • URL处理:这将单独介绍。点击这里了解 URL处理 Java语言。

套接字编程


套接字提供了两台计算机之间使用TCP的通信机制。客户端程序在其通信的一端创建一个套接字,并试图将该套接字连接到服务器。

当连接建立后,服务器在其通信的一端创建一个套接字对象。客户端和服务器现在可以通过向套接字写入和读取来进行通信。

java.net.Socket类代表一个套接字,而java.net.ServerSocket类为服务器程序提供了一种机制,以监听客户并与之建立连接。

使用套接字在两台计算机之间建立TCP连接时,将发生以下步骤:

  • 服务器实例化一个ServerSocket对象,表示要在指定端口号上进行通信;

  • 服务器调用ServerSocket类的accept()方法,该方法一直等待,直到客户端在给定端口上连接到服务器;

  • 服务器等待之后,客户端实例化一个Socket对象,指定服务器和要连接的端口号;

  • Socket类的构造方法尝试将客户端连接到指定的服务器和端口号,如果建立了通信,则客户端现在具有一个能够与服务器通信的Socket对象;

  • 在服务器端,accept()方法返回对服务器上与客户端套接字连接的新套接字的引用。

建立连接后,可以使用I / O流进行通信,每个套接字都有一个OutputStream和一个InputStream。

客户端的OutputStream连接到服务器的InputStream,并且客户端的InputStream连接到服务器的OutputStream。

TCP是一种双向通信协议,因此可以同时在两个流之间发送数据。以下是相关的类,提供了用于实现套接字的完整方法集。

ServerSocket类方法


java.net.ServerSocket服务器应用程序使用该类来获取一个端口号并监听客户端请求。

ServerSocket类具有四个构造方法:

序号方法与说明
1

public ServerSocket(int port) throws IOException

尝试创建绑定到指定端口的服务器套接字,如果端口已被另一个应用程序绑定,则会发生异常。

2

public ServerSocket(int port, int backlog) throws IOException

与先前的构造方法类似,backlog参数指定在等待队列中存储多少个待传入的客户端。

3

public ServerSocket(int port, int backlog, InetAddress address) throws IOException

与先前的构造方法类似,InetAddress参数指定要绑定到的本地IP地址。 InetAddress用于可能具有多个IP地址的服务器,从而允许服务器指定其哪个IP地址接受客户端请求。

4

public ServerSocket() throws IOException

创建一个未绑定的服务器套接字。使用此构造方法时,准备绑定服务器套接字时,请使用bind()方法。

如果ServerSocket构造方法没有引发异常,则意味着应用程序已成功绑定到指定的端口,并准备接受客户端请求。

以下是ServerSocket类的一些常用方法:

序号方法与说明
1

public int getLocalPort()

返回服务器套接字正在监听的端口。如果在构造方法中传入0作为端口号,并让服务器找到端口,则此方法很有用。

2

public Socket accept() throws IOException

等待传入的客户端,假定已使用setSoTimeout()方法设置了超时值,该方法将一直阻塞,直到客户端通过指定的端口连接到服务器或套接字超时为止。否则,此方法将无限期阻塞。

3

public void setSoTimeout(int timeout)

设置超时值,该值表示在accept()期间服务器套接字等待客户端的时间。

4

public void bind(SocketAddress host, int backlog)

将套接字绑定到SocketAddress对象中的指定服务器和端口。如果使用了无参数构造方法实例化了ServerSocket,请使用此方法。

当ServerSocket调用accept()时,该方法直到客户端连接后才返回。客户端连接后,ServerSocket在未指定的端口上创建一个新的Socket,并返回对该新Socket的引用。现在,客户端和服务器之间存在TCP连接,并且可以开始通信。

Socket类方法


java.net.Socket类表示客户端和服务器都用于相互通信的套接字。客户端通过实例化来获得一个Socket对象,而服务器从accept()方法的返回值中获得一个Socket对象。

Socket类具有五个构造方法,客户端可使用这些构造方法来连接服务器:

序号方法与说明
1

public Socket(String host, int port) throws UnknownHostException, IOException

此方法尝试在指定的端口连接到指定的服务器。如果此构造方法没有引发异常,则说明连接成功,并且客户端已连接到服务器。

2

public Socket(InetAddress host, int port) throws IOException

此方法与先前的构造方法相同,除了主机由InetAddress对象表示。

3

public Socket(String host, int port, InetAddress localAddress, int localPort) throws IOException

连接到指定的主机和端口,在本地主机上的指定地址和端口上创建一个套接字。

4

public Socket(InetAddress host, int port, InetAddress localAddress, int localPort) throws IOException

此方法与先前的构造方法相同,除了主机由InetAddress对象而不是String表示。

5

public Socket()

创建一个未连接的套接字。使用connect()方法将此套接字连接到服务器。

当Socket构造方法返回时,它不会简单地实例化Socket对象,而是尝试连接到指定的服务器和端口。

此处列出了Socket类中感兴趣的一些方法。注意,客户端和服务器都有一个Socket对象,因此客户端和服务器都可以调用这些方法。

序号方法与说明
1

public void connect(SocketAddress host, int timeout) throws IOException

此方法将套接字连接到指定的主机,仅当使用无参数构造方法实例化Socket时才需要此方法。

2

public InetAddress getInetAddress()

此方法返回此套接字连接到的另一台计算机的地址。

3

public int getPort()

返回套接字绑定到远程计算机上的端口。

4

public int getLocalPort()

返回套接字绑定到本地计算机上的端口。

5

public SocketAddress getRemoteSocketAddress()

返回远程套接字的地址。

6

public InputStream getInputStream() throws IOException

返回套接字的输入流,输入流连接到远程套接字的输出流。

7

public OutputStream getOutputStream() throws IOException

返回套接字的输出流,输出流连接到远程套接字的输入流。

8

public void close() throws IOException

关闭套接字,这使该Socket对象不再能够再次连接到任何服务器。

InetAddress类方法


此类表示Internet协议(IP)地址,以下是进行套接字编程时需要的以下有用方法:

序号方法与说明
1

static InetAddress getByAddress(byte [] addr)

给定原始IP地址,返回一个InetAddress对象。

2

static InetAddress getByAddress(String host, byte[] addr)

根据提供的主机名和IP地址创建一个InetAddress。

3

static InetAddress getByName(String host)

给定主机名,确定主机的IP地址。

4

String getHostAddress()

以文本形式返回IP地址字符串。

5

String getHostName()

获取此IP地址的主机名。

6

static InetAddress InetAddress getLocalHost()

返回本地主机。

7

String toString()

将此IP地址转换为字符串。

套接字客户端示例


下面的GreetingClient是一个客户端程序,该程序通过使用套接字连接到服务器并发送问候语,然后等待响应。

//文件名GreetingClient.java
import java.net.*;
import java.io.*;

public class GreetingClient {

    public static void main(String [] args) {
        String serverName = args[0];
        int port = Integer.parseInt(args[1]);
        try {
            System.out.println("Connecting to " + serverName + " on port " + port);
            Socket client = new Socket(serverName, port);
         
            System.out.println("Just connected to " + client.getRemoteSocketAddress());
            OutputStream outToServer = client.getOutputStream();
            DataOutputStream out = new DataOutputStream(outToServer);
         
            out.writeUTF("Hello from " + client.getLocalSocketAddress());
            InputStream inFromServer = client.getInputStream();
            DataInputStream in = new DataInputStream(inFromServer);
         
            System.out.println("Server says " + in.readUTF());
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

套接字服务器示例


下面的GreetingServer程序是一个服务器应用程序的示例,该程序使用Socket类在命令行参数指定的端口号上侦听客户端:

//文件名GreetingServer.java
import java.net.*;
import java.io.*;

public class GreetingServer extends Thread {
    private ServerSocket serverSocket;
   
    public GreetingServer(int port) throws IOException {
        serverSocket = new ServerSocket(port);
        serverSocket.setSoTimeout(10000);
    }

    public void run() {
        while(true) {
            try {
                System.out.println("Waiting for client on port " +
                    serverSocket.getLocalPort() + "...");
                Socket server = serverSocket.accept();
            
                System.out.println("Just connected to " + server.getRemoteSocketAddress());
                DataInputStream in = new DataInputStream(server.getInputStream());
            
                System.out.println(in.readUTF());
                DataOutputStream out = new DataOutputStream(server.getOutputStream());
                out.writeUTF("Thank you for connecting to " + server.getLocalSocketAddress()
                    + "\nGoodbye!");
                server.close();
            
            } catch (SocketTimeoutException s) {
                System.out.println("Socket timed out!");
                break;
            } catch (IOException e) {
                e.printStackTrace();
                break;
            }
        }
    }
   
    public static void main(String [] args) {
        int port = Integer.parseInt(args[0]);
        try {
            Thread t = new GreetingServer(port);
            t.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

编译客户端和服务器,然后启动服务器,如下所示:

$ java GreetingServer 6066
Waiting for client on port 6066...

检查客户端程序,如下所示:

$ java GreetingClient localhost 6066
Connecting to localhost on port 6066
Just connected to localhost/127.0.0.1:6066
Server says Thank you for connecting to /127.0.0.1:6066
Goodbye!