Introduction à la programmation Socket en Java-javaDidacticiel-php.cn

Cet article présente principalement les connaissances pertinentes de Java SocketProgrammation Introduction Il est très bon et a une valeur de référence. Les amis qui en ont besoin peuvent s'y référer

pour En termes de programmation Java Socket, il existe deux concepts, l'un est ServerSocket et l'autre est Socket. Une connexion est établie entre le serveur et le client via Socket, puis ils peuvent communiquer. Tout d'abord, ServerSocket écoutera un certain port côté serveur. Lorsqu'il constatera que le client dispose d'un Socket et essaiera de s'y connecter, il acceptera la demande de connexion du Socket et établira un Socket correspondant côté serveur pour communiquer. avec ça. De cette façon, il existe deux Sockets, un pour le client et un pour le serveur.

La communication entre les Sockets est en fait très simple. Le serveur écrit des éléments dans le flux de sortie du Socket, et le client peut lire le contenu correspondant via le flux d'entrée du Socket. Il existe une connexion bidirectionnelle entre Socket et Socket, de sorte que le client peut également écrire des éléments dans le flux de sortie Socket correspondant, puis le flux d'entrée Socket correspondant sur le serveur peut lire le contenu correspondant. Regardons quelques exemples de communication entre le serveur et le client :

1. Le client écrit et le serveur lit

Code du serveur

Code Java

 public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
 Socket socket = server.accept(); 
 //跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了。 
 Reader reader = new InputStreamReader(socket.getInputStream()); 
 char chars[] = new char[64]; 
 int len; 
 StringBuilder sb = new StringBuilder(); 
 while ((len=reader.read(chars)) != -1) { 
  sb.append(new String(chars, 0, len)); 
 } 
 System.out.println("from client: " + sb); 
 reader.close(); 
 socket.close(); 
 server.close(); 
 } 
 }

Copier après la connexion

Le fonctionnement du serveur lisant les données de l'InputStream du Socket est également bloquant. Si aucune donnée n'est lue à partir du flux d'entrée, le programme le fera toujours. Il ne bouge pas jusqu'à ce que le client écrive des données dans le flux de sortie du Socket ou ferme le flux de sortie du Socket. Bien entendu, il en va de même pour le Socket du client. Une fois l'opération terminée, n'oubliez pas de fermer les ressources correspondantes avant la fin de l'ensemble du programme, c'est-à-dire de fermer le flux IO et le Socket correspondants.

Code client

Code Java

public class Client { 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream()); 
 writer.write("Hello Server."); 
 writer.flush();//写完后要记得flush 
 writer.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

Il y a une chose à noter à propos du client qui écrit des données dans le flux de sortie du Socket et les transmet à le serveur.Si vous écrivez Après l'opération, le programme ne correspond pas à la fermeture du flux de sortie, mais effectue d'autres opérations de blocage (telles que la lecture des données du flux d'entrée). Ce n'est qu'ainsi que le serveur peut recevoir. les données envoyées par le client, sinon cela pourrait amener les deux parties à s'attendre sans fin. Ce problème sera abordé plus tard lorsque le client et le serveur lisent et écrivent en même temps.

out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out out ' ‐ ‐ ‐‐‐‐‐ jusqu'à 2. Il peut à la fois recevoir et envoyer des données en même temps.

Code du serveur Code Java

Dans le code ci-dessus, nous lisons d'abord les données envoyées par le client à partir du flux d'entrée, puis nous puis écrivez les données dans le flux de sortie vers le client, puis fermez le fichier de ressources correspondant. En fait, le code ci-dessus peut ne pas fonctionner comme prévu, car la lecture des données du flux d'entrée est une opération bloquante. Lorsque les données sont lues dans la

boucle while
ci-dessus, le corps de la boucle sera exécuté, sinon il sera exécuté. bloquera, de sorte que les opérations d'écriture ultérieures ne seront jamais exécutées. Le blocage ne s'arrêtera que si le Socket correspondant du client est fermé, et la boucle while sautera également. La solution à cette situation qui pourrait ne jamais être exécutée est que la boucle while doit en sortir conditionnellement. En regardant le code ci-dessus, les seules choses qui changent constamment sont la longueur récupérée len et les données lues len. ne peut plus être utilisé. La seule chose qui peut être utilisée est les données lues. En réponse à cette situation, nous nous accordons généralement sur une balise de fin. Lorsque les données envoyées par le client contiennent une balise de fin, cela signifie que les données actuelles ont été envoyées. À ce moment-là, nous pouvons sortir de la boucle. Ensuite le code amélioré ressemblera à ceci :

Code Java

public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
 Socket socket = server.accept(); 
 //跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了。 
 Reader reader = new InputStreamReader(socket.getInputStream()); 
 char chars[] = new char[64]; 
 int len; 
 StringBuilder sb = new StringBuilder(); 
 while ((len=reader.read(chars)) != -1) { 
  sb.append(new String(chars, 0, len)); 
 } 
 System.out.println("from client: " + sb); 
 //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream()); 
 writer.write("Hello Client."); 
 writer.flush(); 
 writer.close(); 
 reader.close(); 
 socket.close(); 
 server.close(); 
 } 
 }

Copier après la connexion

Dans le code ci-dessus, lorsque le serveur lit la balise de fin envoyée par le client, soit "eof" Le la réception des données se terminera et la boucle sera terminée, afin que le code suivant puisse continuer.

Code client

Code Java

 public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
 Socket socket = server.accept(); 
 //跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了。 
 Reader reader = new InputStreamReader(socket.getInputStream()); 
 char chars[] = new char[64]; 
 int len; 
 StringBuilder sb = new StringBuilder(); 
 String temp; 
 int index; 
 while ((len=reader.read(chars)) != -1) { 
  temp = new String(chars, 0, len); 
  if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 
  sb.append(temp.substring(0, index)); 
  break; 
  } 
  sb.append(temp); 
 } 
 System.out.println("from client: " + sb); 
 //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream()); 
 writer.write("Hello Client."); 
 writer.flush(); 
 writer.close(); 
 reader.close(); 
 socket.close(); 
 server.close(); 
 } 
 }

Copier après la connexion

public class Client { 
 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream()); 
 writer.write("Hello Server."); 
 writer.flush(); 
 //写完以后进行读操作 
 Reader reader = new InputStreamReader(client.getInputStream()); 
 char chars[] = new char[64]; 
 int len; 
 StringBuffer sb = new StringBuffer(); 
 while ((len=reader.read(chars)) != -1) { 
  sb.append(new String(chars, 0, len)); 
 } 
 System.out.println("from server: " + sb); 
 writer.close(); 
 reader.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

在上述代码中我们先是给服务端发送了一段数据，之后读取服务端返回来的数据，跟之前的服务端一样在读的过程中有可能导致程序一直挂在那里，永远跳不出while循环。这段代码配合服务端的第一段代码就正好让我们分析服务端永远在那里接收数据，永远跳不出while循环，也就没有之后的服务端返回数据给客户端，客户端也就不可能接收到服务端返回的数据。解决方法如服务端第二段代码所示，在客户端发送数据完毕后，往输出流里面写入结束标记告诉服务端数据已经发送完毕了，同样服务端返回数据完毕后也发一个标记告诉客户端。那么修改后的客户端代码就应该是这个样子：

Java代码

public class Client { 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream()); 
 writer.write("Hello Server."); 
 writer.write("eof"); 
 writer.flush(); 
 //写完以后进行读操作 
 Reader reader = new InputStreamReader(client.getInputStream()); 
 char chars[] = new char[64]; 
 int len; 
 StringBuffer sb = new StringBuffer(); 
 String temp; 
 int index; 
 while ((len=reader.read(chars)) != -1) { 
  temp = new String(chars, 0, len); 
  if ((index = temp.indexOf("eof")) != -1) { 
  sb.append(temp.substring(0, index)); 
  break; 
  } 
  sb.append(new String(chars, 0, len)); 
 } 
 System.out.println("from server: " + sb); 
 writer.close(); 
 reader.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

我们日常使用的比较多的都是这种客户端发送数据给服务端，服务端接收数据后再返回相应的结果给客户端这种形式。只是客户端和服务端之间不再是这种一对一的关系，而是下面要讲到的多个客户端对应同一个服务端的情况。

3、多个客户端连接同一个服务端

像前面讲的两个例子都是服务端接收一个客户端的请求之后就结束了，不能再接收其他客户端的请求了，这往往是不能满足我们的要求的。通常我们会这样做：

Java代码

public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 while (true) { 
  //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
 Socket socket = server.accept(); 
  //跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了。 
 Reader reader = new InputStreamReader(socket.getInputStream()); 
  char chars[] = new char[64]; 
  int len; 
  StringBuilder sb = new StringBuilder(); 
  String temp; 
  int index; 
  while ((len=reader.read(chars)) != -1) { 
  temp = new String(chars, 0, len); 
  if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 
   sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
  System.out.println("from client: " + sb); 
  //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream()); 
  writer.write("Hello Client."); 
  writer.flush(); 
  writer.close(); 
  reader.close(); 
  socket.close(); 
 } 
 } 
 }

Copier après la connexion

在上面代码中我们用了一个死循环，在循环体里面ServerSocket调用其accept方法试图接收来自客户端的连接请求。当没有接收到请求的时候，程序会在这里阻塞直到接收到来自客户端的连接请求，之后会跟当前建立好连接的客户端进行通信，完了后会接着执行循环体再次尝试接收新的连接请求。这样我们的ServerSocket就能接收来自所有客户端的连接请求了，并且与它们进行通信了。这就实现了一个简单的一个服务端与多个客户端进行通信的模式。

上述例子中虽然实现了一个服务端跟多个客户端进行通信，但是还存在一个问题。在上述例子中，我们的服务端处理客户端的连接请求是同步进行的，每次接收到来自客户端的连接请求后，都要先跟当前的客户端通信完之后才能再处理下一个连接请求。这在并发比较多的情况下会严重影响程序的性能，为此，我们可以把它改为如下这种异步处理与客户端通信的方式：

Java代码

public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 while (true) { 
  //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
  Socket socket = server.accept(); 
  //每接收到一个Socket就建立一个新的线程来处理它 
  new Thread(new Task(socket)).start(); 
 } 
 } 
 /** 
 * 用来处理Socket请求的 
 */ 
 static class Task implements Runnable { 
 private Socket socket; 
 public Task(Socket socket) { 
  this.socket = socket; 
 } 
 public void run() { 
  try { 
  handleSocket(); 
  } catch (Exception e) { 
  e.printStackTrace(); 
  } 
 } 
 /** 
 * 跟客户端Socket进行通信 
 * @throws Exception 
 */ 
 private void handleSocket() throws Exception { 
  Reader reader = new InputStreamReader(socket.getInputStream()); 
  char chars[] = new char[64]; 
  int len; 
  StringBuilder sb = new StringBuilder(); 
  String temp; 
  int index; 
  while ((len=reader.read(chars)) != -1) { 
  temp = new String(chars, 0, len); 
  if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 
  sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
  System.out.println("from client: " + sb); 
  //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream()); 
  writer.write("Hello Client."); 
  writer.flush(); 
  writer.close(); 
  reader.close(); 
  socket.close(); 
 } 
 } 
 }

Copier après la connexion

在上面代码中，每次ServerSocket接收到一个新的Socket连接请求后都会新起一个线程来跟当前Socket进行通信，这样就达到了异步处理与客户端Socket进行通信的情况。

在从Socket的InputStream中接收数据时，像上面那样一点点的读就太复杂了，有时候我们就会换成使用BufferedReader来一次读一行，如：

Java代码

 public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 while (true) { 
  //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
  Socket socket = server.accept(); 
  //每接收到一个Socket就建立一个新的线程来处理它 
  new Thread(new Task(socket)).start(); 
 } 
 } 
 /** 
 * 用来处理Socket请求的 
 */ 
 static class Task implements Runnable { 
 private Socket socket; 
 public Task(Socket socket) { 
  this.socket = socket; 
 } 
 public void run() { 
  try { 
  handleSocket(); 
  } catch (Exception e) { 
  e.printStackTrace(); 
  } 
 } 
 /** 
 * 跟客户端Socket进行通信 
 * @throws Exception 
 */ 
 private void handleSocket() throws Exception { 
  BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
  StringBuilder sb = new StringBuilder(); 
  String temp; 
  int index; 
  while ((temp=br.readLine()) != null) { 
  System.out.println(temp); 
  if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 
  sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
  System.out.println("from client: " + sb); 
  //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream()); 
  writer.write("Hello Client."); 
  writer.write("eof\n"); 
  writer.flush(); 
  writer.close(); 
  br.close(); 
  socket.close(); 
 } 
 } 
 }

Copier après la connexion

这个时候需要注意的是，BufferedReader的readLine方法是一次读一行的，这个方法是阻塞的，直到它读到了一行数据为止程序才会继续往下执行，那么readLine什么时候才会读到一行呢？直到程序遇到了换行符或者是对应流的结束符readLine方法才会认为读到了一行，才会结束其阻塞，让程序继续往下执行。所以我们在使用BufferedReader的readLine读取数据的时候一定要记得在对应的输出流里面一定要写入换行符（流结束之后会自动标记为结束，readLine可以识别），写入换行符之后一定记得如果输出流不是马上关闭的情况下记得flush一下，这样数据才会真正的从缓冲区里面写入。对应上面的代码我们的客户端程序应该这样写：

Java代码

 public class Client { 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream()); 
 writer.write("Hello Server."); 
 writer.write("eof\n"); 
 writer.flush(); 
 //写完以后进行读操作 
 BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream())); 
 StringBuffer sb = new StringBuffer(); 
 String temp; 
 int index; 
 while ((temp=br.readLine()) != null) { 
  if ((index = temp.indexOf("eof")) != -1) { 
  sb.append(temp.substring(0, index)); 
  break; 
  } 
  sb.append(temp); 
 } 
 System.out.println("from server: " + sb); 
 writer.close(); 
 br.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

4、设置超时时间

假设有这样一种需求，我们的客户端需要通过Socket从服务端获取到XX信息，然后给用户展示在页面上。我们知道Socket在读数据的时候是阻塞式的，如果没有读到数据程序会一直阻塞在那里。在同步请求的时候我们肯定是不能允许这样的情况发生的，这就需要我们在请求达到一定的时间后控制阻塞的中断，让程序得以继续运行。Socket为我们提供了一个setSoTimeout()方法来设置接收数据的超时时间，单位是毫秒。当设置的超时时间大于0，并且超过了这一时间Socket还没有接收到返回的数据的话，Socket就会抛出一个SocketTimeoutException。

假设我们需要控制我们的客户端在开始读取数据10秒后还没有读到数据就中断阻塞的话我们可以这样做：

Java代码

public class Client { 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream()); 
 writer.write("Hello Server."); 
 writer.write("eof\n"); 
 writer.flush(); 
 //写完以后进行读操作 
 BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream())); 
 //设置超时间为10秒 
 client.setSoTimeout(10*1000); 
 StringBuffer sb = new StringBuffer(); 
 String temp; 
 int index; 
 try { 
  while ((temp=br.readLine()) != null) { 
  if ((index = temp.indexOf("eof")) != -1) { 
   sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
 } catch (SocketTimeoutException e) { 
  System.out.println("数据读取超时。"); 
 } 
 System.out.println("from server: " + sb); 
 writer.close(); 
 br.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

5、接收数据乱码

对于这种服务端或客户端接收中文乱码的情况通常是因为数据发送时使用的编码跟接收时候使用的编码不一致。比如有下面这样一段服务端代码：

Java代码

 public class Server { 
 public static void main(String args[]) throws IOException { 
 //为了简单起见，所有的异常信息都往外抛 
 int port = 8899; 
 //定义一个ServerSocket监听在端口8899上 
 ServerSocket server = new ServerSocket(port); 
 while (true) { 
  //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
  Socket socket = server.accept(); 
  //每接收到一个Socket就建立一个新的线程来处理它 
  new Thread(new Task(socket)).start(); 
 } 
 } 
 /** 
 * 用来处理Socket请求的 
 */ 
 static class Task implements Runnable { 
 private Socket socket; 
 public Task(Socket socket) { 
  this.socket = socket; 
 } 
 public void run() { 
  try { 
  handleSocket(); 
  } catch (Exception e) { 
  e.printStackTrace(); 
  } 
 } 
 /** 
 * 跟客户端Socket进行通信 
 * @throws Exception 
 */ 
 private void handleSocket() throws Exception { 
  BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK")); 
  StringBuilder sb = new StringBuilder(); 
  String temp; 
  int index; 
  while ((temp=br.readLine()) != null) { 
  System.out.println(temp); 
  if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 
  sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
  System.out.println("客户端: " + sb); 
  //读完后写一句 
 Writer writer = new OutputStreamWriter(socket.getOutputStream(), "UTF-8"); 
  writer.write("你好，客户端。"); 
  writer.write("eof\n"); 
  writer.flush(); 
  writer.close(); 
  br.close(); 
  socket.close(); 
 } 
 } 
 }

Copier après la connexion

这里用来测试我就弄的混乱了一点。在上面服务端代码中我们在定义输入流的时候明确定义了使用GBK编码来读取数据，而在定义输出流的时候明确指定了将使用UTF-8编码来发送数据。如果客户端上送数据的时候不以GBK编码来发送的话服务端接收的数据就很有可能会乱码；同样如果客户端接收数据的时候不以服务端发送数据的编码，即UTF-8编码来接收数据的话也极有可能会出现数据乱码的情况。所以，对于上述服务端代码，为使我们的程序能够读取对方发送过来的数据，而不出现乱码情况，我们的客户端应该是这样的：

Java代码

public class Client { 
 public static void main(String args[]) throws Exception { 
 //为了简单起见，所有的异常都直接往外抛 
 String host = "127.0.0.1"; //要连接的服务端IP地址 
 int port = 8899; //要连接的服务端对应的监听端口 
 //与服务端建立连接 
 Socket client = new Socket(host, port); 
 //建立连接后就可以往服务端写数据了 
 Writer writer = new OutputStreamWriter(client.getOutputStream(), "GBK"); 
 writer.write("你好，服务端。"); 
 writer.write("eof\n"); 
 writer.flush(); 
 //写完以后进行读操作 
 BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream(), "UTF-8")); 
 //设置超时间为10秒 
 client.setSoTimeout(10*1000); 
 StringBuffer sb = new StringBuffer(); 
 String temp; 
 int index; 
 try { 
  while ((temp=br.readLine()) != null) { 
  if ((index = temp.indexOf("eof")) != -1) { 
   sb.append(temp.substring(0, index)); 
   break; 
  } 
  sb.append(temp); 
  } 
 } catch (SocketTimeoutException e) { 
  System.out.println("数据读取超时。"); 
 } 
 System.out.println("服务端: " + sb); 
 writer.close(); 
 br.close(); 
 client.close(); 
 } 
 }

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!