Heim > Java > javaLernprogramm > So erstellen Sie einen Java-Netzwerkprogrammierungs-Socket

So erstellen Sie einen Java-Netzwerkprogrammierungs-Socket

WBOY
Freigeben: 2023-05-14 16:52:06
nach vorne
1785 Leute haben es durchsucht

1|0 Socket erstellen

Im [Client/Server]-Kommunikationsmodus muss der Client den Socket aktiv erstellen, um eine Verbindung zum Server herzustellen. Die Konstruktionsmethode weist die folgenden überladenen Formen auf:

Socket()
Socket(InetAddress address, int port) throws UnknownHostException,IOException
Socket(InetAddress address, int port, InetAddress localAddr, int localPort) throws IOException
Socket(String host, int port) throws UnknownHostException,IOException
Socket(String host, int port, InetAddress localAddr, int localPort) throws IOException
Socket(Proxy proxy)
Nach dem Login kopieren

Mit Ausnahme der ersten, die Konstruktor nicht mit Parametern, andere Konstruktoren versuchen, eine Verbindung mit dem Server herzustellen. Sobald die Verbindung erfolgreich ist, wird das Socket-Objekt zurückgegeben, andernfalls wird eine Ausnahme ausgelöst

1

Wenn der Socket-Konstruktor des Clients eine Verbindung zum Server anfordert, kann es einige Zeit dauern. Standardmäßig wartet der Socket-Konstruktor, bis die Verbindung erfolgreich ist oder eine Ausnahme auftritt. Wenn die Socket-Konstruktionsmethode eine Verbindung anfordert, befindet sie sich aufgrund der Übertragungsgeschwindigkeit des zugrunde liegenden Netzwerks möglicherweise in einem langen Wartezustand. Wenn Sie die Wartezeit auf eine Verbindung begrenzen möchten, müssen Sie den ersten Konstruktor ohne Parameter verwenden

Socket socket = new Socket();
SocketAddress remoteAddr = new InetSocketAddress("1ocalhostn", 8000);
// 参数endpoint指定服务器的地址,参数timeout设定的超时时间(ms)
// 如果参数timeout被设为0则表示永远不会超时
socket.connect(remoteAddr, 60000);
Nach dem Login kopieren
Nach dem Login kopieren

Der obige Code wird verwendet, um eine Verbindung zum Serverprogramm herzustellen, das Port 8000 auf dem lokalen Computer überwacht. Die maximale Wartezeit für eine Verbindung beträgt eine Minute. Wenn die Verbindung innerhalb einer Minute erfolgreich ist, wird die Methode connect() erfolgreich zurückgegeben. Wenn innerhalb einer Minute eine Ausnahme auftritt, wird die Ausnahme ausgelöst. Es wird eine SocketTimeoutException ausgelöstconnect() 方法顺利返回,如果在一分钟内出现某种异常则抛出该异常,如果在一分钟后既没有连接成功,也没有出现异常,那么会抛出 SocketTimeoutException

2. 设定服务器的地址

除了不带参数的构造方法,其他构造方法都需要在参数中设定服务器的地城,包括服务器的 IP 或主机名,以及端口

Socket socket = new Socket();
SocketAddress remoteAddr = new InetSocketAddress("1ocalhostn", 8000);
// 参数endpoint指定服务器的地址,参数timeout设定的超时时间(ms)
// 如果参数timeout被设为0则表示永远不会超时
socket.connect(remoteAddr, 60000);
Nach dem Login kopieren
Nach dem Login kopieren

InetAddress 类表示主机的P地址,提供了一系列静态工厂方法用于构造自身实例

// 返回本地主机的IP地址、
InetAddress addr1 = inetAddress.getLocalHost();
// 返回代表 "222.34.57” 的 IPv4 地址
InetAddress addr2 = InetAddress.getByName("222.34.5.7");
// 返同代表 ”2001:DB8:2DE::E13" 的 IPv6 地址
InetAddress addr3 = InetAddress.getByName("2001:DB8:2DE::E13");
// 返回主机名为 "www.javathinker.net" 的 IP 地址
InetAddress addr4 = InetAddress.getByName ("www.javathinker.net");
Nach dem Login kopieren

3. 设定客户端的地址

在一个 Socket 对象中既包含远程服务器的 IP 地址和端口信息,也包含本地客户端的 IP 地址和端口信息。在默认情况下,客户端的 IP 地址来自客户程序所在的主机,客户端的端口则由操作系统随机分配。Socket 类还有两个构造方法允许显式地设置客户端的 IP 地址和端口

Socket(InetAddress address, int port, InetAddress localAddr, int localPort) throws IOException
Socket(String host, int port, InetAddress localAddr, int localPort) throws IOException
Nach dem Login kopieren

如果一个主机同时属于两个以上的网络,它就可能拥有两个以上 IP 地址,例如一个主机在 Internet 网络中的 IP 地址为 “222.67,1.34”,在一个局域网中的 IP 地址为 “1125.4.3",假定这个主机上的客户程序希望和同一个局城网上的一个地址为 “112.5.4.4:8000” 的服务器程序通信,客户端可按照如下方式构造 Socket 对象

InetAddress remoteAddr = InetAddress.getByName("112.5,4.45");
InetAddress localAddr = InetAddress.getByName("112.5.4.3");
//客户端使用口2345
Socket socket = new Socket(remoteAddr, 8000, localAddr, 2345);
Nach dem Login kopieren

4. 客户连接服务器时可能抛出的异常

当 Socket 的构造方法请求连接服务器时,可能会抛出以下异常:

  • UnknownHostException:无法识别主机的名字或 IP 地址

  • ConnectException:没有服务器进程监听指定的端口,或者服务器进程拒绝连接

  • SocketTimeoutException:等待连接超时

  • BindException:无法把Socket 对象与指定的本地 IP 地址或端口绑定

5. 使用代理服务器

在实际应用中,有的客户程序会通过代理服务器来访问远程服务器。代理服务器有许多功能,比如能作为防火墙进行安全防范,或者提高访问速度,或者具有访问特定远程服务器的权限

String proxyIP = "myproxy.abc.oom"; // 代理服务器地址
int proxyPort = 1080; // 代理服务器端口
// 创建代理对象
Proxy proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress(proxyIP, proxyPort));
Socket socket  new Socket(proxy);
//连接到远程服务器
socket.connect(new InetSocketAddress("www.javathinker.net", 80));
Nach dem Login kopieren

ProxyType 类表示代理服务器的类型,有以下可选值:

  • Proxy.Type.SOCKS:在分层的网络结构中,SOCKS 是位于会话层的代理类型

  • Proxy.Type.HTTP:在分层的网络结构中,HTTP 是位于应用层的代理类型

  • Proxy.Type.DIRECT:不使用代理,直接连接远程服务器

6. InetAddress 地址类的用法

InetAddress 类表示主机的IP 地址,InetAddress 类的静态工厂方法给 getByName() 用于构造自身的实例

// 返回代表 "222.34.5.7" 的 IPv4 地址
InetAddress addr2 = InetAddress,getByName("222.34.5.7");
// 返回主机名为 "www.javathinker.net" 的 IP 地址
InetAddress addr4 = InetAddress.getByName("www.javathinker.net");
Nach dem Login kopieren

InetAddress 还提供了获取相应的主机名的两种方法:

  • getHostname():首先从 DNS 缓存中查找与 IP 地址匹配的主机名,如果不存在,再通过 DNS 服务器查找,如果找到,则返回主机名,否则返回 IP 地址

  • getCanonicalHostName():通过 DNS 服务器查找与 IP 地址匹配的主机名,如果找到则返回主机名,否则返问 IP 地址

以上两种方法的区别在于 getHostname() 会先查找 DNS 缓存,减少查找 DNS 服务器的概率,提高查找性能。而 getCanonicalHostName()

2. Legen Sie die Serveradresse fest

Mit Ausnahme der Konstruktionsmethode ohne Parameter müssen bei anderen Konstruktionsmethoden die Serveradresse, einschließlich der IP-Adresse oder des Hostnamens, festgelegt werden

public boolean isReachable(int timeout) throws IOException
public boolean isReachable(NefworkInterface interface, int ttl, int timeout) throws IOException
Nach dem Login kopieren

Die InetAddress-Klasse stellt die P-Adresse des Hosts dar und bietet eine Reihe statischer Factory-Methoden zum Erstellen einer eigenen Instanz🎜
// 参数 name 指定网络接口的名字,如果不存在与名字对应的网络接口,就返回 null
getByName(String name)
// 参数 address 指定网络接口的 IP 地址,如果不存在与 IP 地址对应的网络接口,就返回 null
getByInetAddress(InetAddress address)
Nach dem Login kopieren
Nach dem Login kopieren
🎜3. Legen Sie die Adresse des Clients fest🎜🎜Ein Socket-Objekt enthält sowohl die IP-Adresse des Remote-Servers als auch Portinformationen die IP-Adresse und Portinformationen des lokalen Clients. Standardmäßig stammt die IP-Adresse des Clients vom Host, auf dem sich das Clientprogramm befindet, und der Port des Clients wird vom Betriebssystem zufällig zugewiesen. Die Socket-Klasse verfügt außerdem über zwei Konstruktoren, mit denen Sie die IP-Adresse und den Port des Clients explizit festlegen können Die IP-Adresse im Internet-Netzwerk lautet „222.67,1.34“ und die IP-Adresse in einem LAN lautet „1125.4.3“. Es wird davon ausgegangen, dass das Client-Programm auf diesem Host mit einer Adresse im selben Büronetzwerk kommunizieren möchte wie „ 112.5.4.4:8000" Für die Serverprogrammkommunikation kann der Client das Socket-Objekt wie folgt erstellen🎜
// 返回网络接口的名字
public String getName()
// 返回和网络接口绑定的所有 IP 地址,返回值为 Enumeration 类型,里面存放了表示 IP 地址的 InetAddress 对象
public Enumeration getInetAddresses()
Nach dem Login kopieren
Nach dem Login kopieren
🎜4. Ausnahmen, die ausgelöst werden können, wenn der Client eine Verbindung zum Server herstellt🎜🎜Wenn die Socket-Konstruktionsmethode eine Verbindung zum Server anfordert , können folgende Ausnahmen ausgelöst werden:🎜
  • 🎜UnknownHostException: Der Name oder die IP-Adresse des Hosts kann nicht erkannt werden🎜
  • 🎜ConnectException: There Hört kein Serverprozess auf den angegebenen Port oder lehnt der Serverprozess die Verbindung ab? die angegebene lokale IP-Adresse oder den angegebenen Port🎜
🎜5. Verwenden Sie einen Proxy-Server🎜🎜In tatsächlichen Anwendungen greifen einige Client-Programme über Proxy-Server auf Remote-Server zu. Der Proxyserver hat viele Funktionen, z. B. die Funktion als Firewall für die Sicherheit, die Verbesserung der Zugriffsgeschwindigkeit oder die Berechtigung zum Zugriff auf einen bestimmten Remote-Server🎜
// 获得远程被连接进程的IP地址
getInetAddress()
// 获得远程被连接进程的端口
getPort()
// 获得本地的IP地址
getLocalAddress()
// 获得本地的端口
getLocalPort()
// 获得输入流,如果Socket还没有连接,或者已经关团,或者已经通过shutdownInput()方法关闭输入流,那么此方法会抛出IOException
getInputStream()
// 获得输出流,如果Socket还没有连接,或者已经关闭,或者已经通过shutdownOutput()方法关闭输出流,那么此方法会抛出 IOException
getOutputStream()
Nach dem Login kopieren
Nach dem Login kopieren
🎜Die ProxyType-Klasse stellt den Typ des Proxyservers mit den folgenden optionalen Werten dar: 🎜
  • 🎜Proxy.Type.SOCKS: In der hierarchischen Netzwerkstruktur ist SOCKS der Proxy-Typ auf der Sitzungsebene🎜
  • 🎜Proxy.Type .HTTP: In der hierarchischen Netzwerkstruktur ist SOCKS der Proxy-Typ auf der Sitzungsebene. In der Netzwerkstruktur auf der Ebene ist HTTP ein Proxy-Typ auf der Anwendungsebene🎜
  • 🎜Proxy.Type.DIRECT : Stellt eine direkte Verbindung zum Remote-Server her, ohne einen Proxy zu verwenden🎜
🎜6. InetAddress-Verwendung der Adressklasse🎜🎜Die InetAddress-Klasse stellt die IP-Adresse des Hosts dar. Die statische Factory-Methode der InetAddress-Klasse wird verwendet, um eine eigene Instanz zu erstellen. 🎜
// 如果Socket没有关闭,则返回false,否则返回true
isClosed()
// 如果Socket曾经连接到远程主机,不管当前是否已经关闭,都返回true。如果Socket从未连接到远程主机,就返回false
isConnected()
// 如果Socket已经与一个本地端口绑定,则返回true,否则返回false
isBound()
Nach dem Login kopieren
Nach dem Login kopieren
🎜InetAddress bietet auch Methoden zum Abrufen des entsprechenden Hostnamens: 🎜
  • 🎜getHostname()</. Code>: Suchen Sie zuerst den Hostnamen, der mit der IP-Adresse übereinstimmt, aus dem DNS-Cache, falls dieser nicht vorhanden ist. Wenn er gefunden wird, geben Sie den Hostnamen zurück, andernfalls geben Sie die IP-Adresse zurück🎜</li><li >🎜<code>getCanonicalHostName(): Finden Sie den Hostnamen, der mit der IP-Adresse übereinstimmt, über den DNS-Server. Wenn gefunden, geben Sie den Hostnamen zurück, andernfalls geben Sie die IP-Adresse zurück🎜
🎜The Der Unterschied zwischen den beiden oben genannten Methoden besteht darin, dass getHostname() zuerst den DNS-Cache durchsucht, wodurch die Wahrscheinlichkeit verringert wird, dass der DNS-Server durchsucht wird, und die Suchleistung verbessert wird. Und getCanonicalHostName() sucht immer nach dem DNS-Server, um sicherzustellen, dass die neueste Version des Hostnamens abgerufen wird. Die InetAddress-Klasse bietet außerdem zwei Methoden zum Testen, ob Sie lokal eine Verbindung zu einem bestimmten Host herstellen können Host: 🎜
String isConnected = socket.isConnected() && !socket.isClosed();
Nach dem Login kopieren
Nach dem Login kopieren
🎜 Wenn der Remote-Host innerhalb der durch den Parameter timeout (ms) angegebenen Zeit antwortet, gibt die obige Methode true zurück, andernfalls false und löst eine IOException aus, wenn ein Netzwerkfehler auftritt. Die zweite Methode ermöglicht auch den Verbindungsaufbau über die durch die Parameter angegebene lokale Netzwerkschnittstelle sowie die TTL (wie lange ein IP-Paket leben darf, bevor es verworfen wird) 🎜

7. NetworkInterface 类的用法

NetworkInterfiace 类表示物理上的网络接口,它有两种构造自身实例的静态工厂方法,这两种方法都声明抛出 SocketException

// 参数 name 指定网络接口的名字,如果不存在与名字对应的网络接口,就返回 null
getByName(String name)
// 参数 address 指定网络接口的 IP 地址,如果不存在与 IP 地址对应的网络接口,就返回 null
getByInetAddress(InetAddress address)
Nach dem Login kopieren
Nach dem Login kopieren

NetworkInterface 类的以下方法用于获取网络接口的信息

// 返回网络接口的名字
public String getName()
// 返回和网络接口绑定的所有 IP 地址,返回值为 Enumeration 类型,里面存放了表示 IP 地址的 InetAddress 对象
public Enumeration getInetAddresses()
Nach dem Login kopieren
Nach dem Login kopieren

2|0获取 Socket 的信息

在一个 Socket 对象中同时包含了远程服务器的 IP 地址和端口信息,以及客户本地的 IP 地址和端口信息。此外,从 Socket 对象中还可以获得输出流和输入流,分别用于向服务器发送数据,以及接收从服务器端发来的数据

以下方法用于获取 Socket 的有关信息

// 获得远程被连接进程的IP地址
getInetAddress()
// 获得远程被连接进程的端口
getPort()
// 获得本地的IP地址
getLocalAddress()
// 获得本地的端口
getLocalPort()
// 获得输入流,如果Socket还没有连接,或者已经关团,或者已经通过shutdownInput()方法关闭输入流,那么此方法会抛出IOException
getInputStream()
// 获得输出流,如果Socket还没有连接,或者已经关闭,或者已经通过shutdownOutput()方法关闭输出流,那么此方法会抛出 IOException
getOutputStream()
Nach dem Login kopieren
Nach dem Login kopieren

3|0关闭 Socket

当客户与服务器的通信结束时,应该及时关闭 Socket,以释放 Socket 占用的包括端口在内的各种资源。Socket 的 close() 方法负责关闭 Socket,如果一个 socket 对象被关闭,就不能再通过它的输入流和输出流进行 IO 操作,否则会导致 IOException

Socket 类提供了三个状态测试方法

// 如果Socket没有关闭,则返回false,否则返回true
isClosed()
// 如果Socket曾经连接到远程主机,不管当前是否已经关闭,都返回true。如果Socket从未连接到远程主机,就返回false
isConnected()
// 如果Socket已经与一个本地端口绑定,则返回true,否则返回false
isBound()
Nach dem Login kopieren
Nach dem Login kopieren

如果要判断一个 Socket 对象当前是否处于连接状态,可采用以下方式

String isConnected = socket.isConnected() && !socket.isClosed();
Nach dem Login kopieren
Nach dem Login kopieren

4|0半关闭 Socket

进程 A 与进程 B 通过 Socket 通信,假定进程 A 输出数据,进程 B 读入数据,进程 A 如何告诉进程 B 所有数据已经输出完毕呢?有几种处理办法:

  • 如果进程 A 与进程 B 交换的是字符流,并且都一行一行地读写数据,那么可以事先约定以一个特殊的标志作为结束标志,例如以字符串 “bye” 作为结束标志,当进程 A 向进程 B 发送一行字符串 “bye”,进程 B 读到这一行数据后,就停止读取数据

  • 进程 A 先发送一个消息,告诉进程 B 所发送的正文的长度,然后发送正文。进程 B 先获知进程 A 将发送的正文的长度,接下来只要读取该长度的字符或者字节,就停止读取数据

进程 A 发完所有数据后,关闭 Socket,当进程 B 读入了进程 A 发送的所有数据后,再次执行输入流的 read() 方法时,该方法返回 “-1”,如果执行 BufferedReader 的 readLine() 方法,那么该方法返回 null

ByteArrayOutputstream bufferenew = ByteArrayOutputstream();
byte[] buff = new byte[1024);
int len = -1;
while((len = socketIn.read(buff)) != -1) {
    buffer.write(buff, 0, len);   
}
Nach dem Login kopieren
  • 当调用 Socke t的 close() 方法关闭 Socket 后,它的输出流和输入流也都被关闭。有的时候,可能仅仅希望关闭输出流或输入流之一,此时可以采用 Socket 类提供的半关闭方法

shutdownInput() // 关闭输入流
shutdownOutput() // 关团输出流
Nach dem Login kopieren

假定进程 A 执行以下代码,先向进程 B 发送一个字符串,等到进程 B 接收到这个字符串后,进程 A 再调用 Socket 的 shutdownOutput() 方法关闭输出流,接下来进程 A 不允许再输出数据,但是仍可以通过输入流读入数据

// 发出请求信息
String data = ...;
OutputStream socketOut = socket.getOutputStream();
socketOut.write(data.getBytes());
socketOut.flush();
// 读取响应
InputStream socketIn = socket.getInputStream();
if(服务器端返回提示信息,表明已经接收到客户端的所有请求数据)
    socket.shutdownOutput(); //关闭输出流
//继续通过socketIn读取数据
...
Nach dem Login kopieren

值得注意的是,先后调用 Socket 的 shutdownInput() 和 shutdownOutput() 方法,仅仅关闭了输入流和输出流,并不等价于调用 Socket 的 close() 方法。在通信结束后,仍然要调用 Socket 的 close() 方法,因为只有该方法才会释放 Socket 占用的资源,比如占用的本地端口等

Socket 类还提供了两种状态测试方法,用来判断输入流和输出流是否关闭

public boolean isInputShutdown() // 如果输入流关闭,则返回true,否则返回false
public boolean isOutputShutdown() // 如果输出流关闭,则返回true,否则返回false
Nach dem Login kopieren

5|0设置 Socket 的选项

1. TCP_NODELAY

表示立即发送数据。在默认情况,下发送数据采用 Negale 算法,发送方发送的数据不会立刻被发出,而是先放在缓冲区内,等缓冲区满了再发出。发送完一批数据后,会等待接收方对这批数据的回应,然后发送下一批数据。此算法法适用于发送方需要发送大批量数据并且接收方会及时做出回应的场合,这种算法通过减少传输数据的次数来提高通信效率

如巢发送方持续地发送小批量的数据。并且接收方不一定会立即发送响应数据,那么 Negale 算法会使发送方运行得很慢,对于GU程序,比如网络游戏程序(服务器需要实时跟踪客户端鼠标的移动),这个问题尤其突出

TCP_NODEALY 的默认值为 false,表示采用 Negale 算法,如果调用 setTcpNoDelay(true) 方法,就会关闭 Socket 的缓冲,确保数据被及时发送

if(!socket.getTcpNoDelay())
    socket.setTcpNoDelay(true);
Nach dem Login kopieren

2. SO_RESUSEADDR

表示是否允许重用 Socket 所绑定的本地地址。当接收方通过 Socket 的 close() 方法关闭 Socket 时,如果网络上还有发送到这个 Socket 的数据,那么底层的 Socket 不会立刻释放本地端口,而是会等待一段时间,确保接收到了网络上发送过来的延迟数据,再释放端口。Socket 接收到延迟数据后,不会对这些数据做任何处理。Socket 接收延迟数据的目的是,确保这些数据不会被其他碰巧绑定到同样端口的新进程接收到

客户程序一般采用随机端口,因此出现两个客户程序绑定到同样端口的可能性不大。许多服务器程序都使用固定的端口。当服务器程序被关闭后,有可能它的端口还会被占用一段时间,如果此时立刻在同一台主机上重启服务器程序,由于端口已经被占用,使得服务感程序无法绑定到该端口,导致启动失败

为了确保当一个进程关闭了 Socket 后,即便它还没释放端口,同一台主机上的其他进要也可以立刻重用该端口,可以调用 Socke 的 setResuseAddress(ture) 方法

if(!socket.getResuseAddress())
    socket.setResuseAddress(true);
Nach dem Login kopieren

值得注意的是 socket.setResuseAddress(true) 方法必须在 Socket 还没有被绑定到一个本地端口之前调用,否则执行无效

3. SO_TIMEOUT

表示接收数据时的等待超时时间。当通过 Socket 的输入流读数据时,如果还没有数据,就会等待。Socket 类的SO_TIMEOUT 选项用于设定接收数据的等待超时时间,单位为 ms,它的默认值为0,表示会无限等待,永远不会超时

以下代码把接收数据的等待超时时间设为三分钟

if(socket.getTimeout() == 0)
    socket.setTimeout(60000 * 3);
Nach dem Login kopieren

Socket 的 setTimeout() 方法必须在接收数据之前执行才有效

4. SO_LINGER

表示与执行 Socket 的 close() 方法时,是否立即关闭底层的 Socket。在默认情况下执行 Socket 的 close() 方法,该方法会立即返回,但底层的 Socket 实际上并不立即关闭,它会延迟一段时间,直到发送完所有剩余的数据,才会真正关闭 Socket

如果执行以下方法

socket.setSoLinger(true,0);
Nach dem Login kopieren

那么执行 Socket 的 close() 方法,该方法也会立即返回而且底层的 Socket 也会立即关闭,所有未发送完的数据被丢弃

如果执行以下方法

socket.setSoLinger(true,3600);
Nach dem Login kopieren

那么执行 Socket 的 close() 方法,该方法不会立即返回,而是进入阻塞状态,同时,底层的 Socket 会尝试发送剩余的数据。只有满足以下两个条件之一,close() 方法才返回:

  • 底层的 Socket 已经发送完所有的剩余数据

  • 尽管底层的 Socket 还没有发送完所有的剩余数据,但己经阻塞了 3600s,此时 close() 也会返回,未发送的数据被丢弃

5. SO_RCVBUF

表示接收数据的缓冲区的大小。一般说来,传输大的连续的数据块,比如基于 HTTP 或 FTP 的通信,可以使用较大的缓冲区,这可以减少传输数据的次数,提高传输数据的效率。而对于交互式的通信方式,比如 Telnet 和网络游戏,则应该采用小的缓冲区,确保小批量的数据能及时发送给对方

6. SO_SNDBUF

表示发送数据的缓冲区的大小

7. SO_KEEPALIVE

表示对于长时间处于空闲状态的 Socket,是否要自动把它关团。当 SO_KEEPALIVE 选项为 tue 时,表示底层的 TCP 实现会监视该连接是否有效连接处于空闲状态,即连接的两端没有互相传送数据超过了 2 小时,本地的 TCP 实现发送一个数据包给远程的 Socket,如果远程 Socke 没有返回响应,TCP 实现就会持续尝试发送 11 分钟,直到接收到响应为止。如果在 12 分钟内未收到响应,TCP 实现就会自动关闭本地 Socket,断开连接

SO_KEEPALIVE 选项的默认值为 false,表示 TCP 不会监视连接是否有效,不活动的客户端可能会永久存在下去,而不会注意到服务器已经崩溃

8. IP 服务类型选项

当用户通过邮局发送普通信、挂号信或者快件时,实际上选择了邮局提供的不同的服务。发送普通信的价格最低,但发送速度慢,并且可靠性没有保证。发送挂号信的价格稚高,但可靠性有保证。发送快件的价格最高,发送速度最快,并且可靠性有保证

在 Internet 上传输数据也分为不同的服务类型,它们有不同的定价。用户可以根据自己的需求,选择不同的服务类型。例如发送视频需要较高的带宽,快速到达目的地,以保证接收方看到连续的画面,而发送电子邮件可以使用较低的带宽,延迟几个小时到达目的地也没关系

IP 规定了一些服务类型,用来定性地描述服务的质量,举例如下:

  • 低成本:发送成本低

  • 高可靠性:保证把数据可靠地送达目的地

  • 最高吞吐量:一次可以接收或发送大批量的数据

  • 最小延迟:传输数据的速度快,把数据快速送达目的地

这些服务类型还可以进行组合,例如,可以同时要求获得高可靠性和最小延迟。服务类型存储在 IP 数据包头部的名为 IP_TOS 的 8 位字段中,Socket 类中提供了设置和读取服务类型的方法

// 设置服务类型
public void setTrafficClass(int trafficClass) throws SocketException
// 读取服务类型
public int getTrafficClass() throws SocketException
Nach dem Login kopieren

服务类型用 1 字节来表示,取值范围是 0 到 255 之间的整数。这个服务类型数据也会被复制到 TCP 数据包头部的 8 位字段中。,在目前的网络协议中,对这个表示服务类型的字节又做了进一步的细分:

  • 高六位:表示 DSCP 值,即表示不同的服务类型代码号。DSCP 允许最多有 64 种服务类型

  • 低两位:表示 ECN 值,即显式拥塞通知信息

64 个 DSCP 值到底表示什么含义,这是由具体的网络和路由器决定的。下面是比较常见的 DCSP 值:

  • 默认服务类型:000000

  • 加速转发类型:101110,特点是低损耗、低延迟、低抖动

  • 保证转发类型:共 12 个取值,保证以指定速率传送,见下表

类型

第1类(最低转发优先)第2类第3类第4类(最高转发优先)

低丢包率

001010010010011010100010

中丢包率

001100010100011100100100

高丢包率

001110010110011110100110

其中第 1 类有最低转发优先级,第 4 类有最高转发优先级。也就是说,当网络出现阻塞时,第 4 类的数据包被优先转发。每一类又包含了 3 个取值,其中低丢包率的服务类型丢弃数据包的概率小,而高丢包率的服务类型丢弃数据包的概率大

加速转发类型比其他服务类型有更高的优先级,例如以下代码使得 Socket 采用加速转发类型来收发数据:

Socket socket = new Socket("www.javathinker.net", 80);
// 0xB8 对应二进制数据 10111000
// 低两位表示显式拥塞通知,取值为 00
socket.setTrafficClass(0xB8);
Nach dem Login kopieren

值得注意的是,DCSP 值仅仅为底层的网络实现提供一个参考,有些底层 Socket 实现会忽略 DCSP 值,对它不进行任何处理

9. 设定连接时间、延迟和带宽的相对重要性

从 JDK1.5 开始,为 Socket 类提供了一个 setPerformancePreferences() 方法

public vold setPerformancePreferences (int connectionTime, int latency, int bandwidth)
Nach dem Login kopieren

以上方法的 3 个参数表示网络传输数据的 3 项指标:

  • connectionTime:表示用最少时间建立连接

  • latency:表示最小廷迟

  • bandwidth:表示最高带宽

setPerformancePreferences() 方法被用来设定这 3 项指标之间的相对要性。可以为这些参数赋予任意的整数。这些整数之间的相对大小就决定了相应参数的相对重要性。例如,如果参数 connectionTime 为 2,参数 latency 为 1,而参数 bandwidth 为 3,就表示最高带宽最重要,其次是最少连接时间,最后是最小延迟

值得注意的是 setPerformancePreferences() 方法所做的设置仅仅为底层的网络实现提供一个参考,有些底层 Socket 实现会忽略这一设置,对它不进行任何处理

Das obige ist der detaillierte Inhalt vonSo erstellen Sie einen Java-Netzwerkprogrammierungs-Socket. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Verwandte Etiketten:
Quelle:yisu.com
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage