Partage d'exemples de programmation Socket en Java (image)

Socket est très pratique pour nous. Vous trouverez ci-dessous les notes de cette étude. Il est principalement divisé en types d'exceptions, principes d'interaction, Socket, ServerSocket et multi-threading

Pour les applications en temps réel ou les jeux en temps réel, le protocole HTTP ne peut souvent pas répondre à nos besoins. En ce moment, Socket est très pratique pour nous. Vous trouverez ci-dessous les notes de cette étude. Il est principalement expliqué en termes de types d'exceptions, de principes d'interaction, de Socket, de ServerSocket et de multi-threading.

Types d'exceptions

Avant de comprendre le contenu de Socket, vous devez d'abord comprendre certains des types d'exceptions impliqués. Les quatre types suivants héritent tous de IOException, donc beaucoup d'entre eux peuvent afficher directement IOException.

UnkownHostException :  Nom d'hôte ou erreur IP
ConnectException :  Le serveur a refusé la connexion, le serveur n'a pas démarré, (le nombre de files d'attente a été dépassé, la connexion a été refusée)
SocketTimeoutException : La connexion a expiré
BindException :   L'objet Socket ne peut pas être connecté à l'adresse IP locale ou à la liaison de port spécifiée

Processus d'interaction

Interaction entre Socket et ServerSocket, je pense que l'image suivante a été très détaillée et claire.

Constructeur de socket

Socket()
Socket(Adresse InetAddress, int port) lève UnknownHostException, IOException
Socket (adresse InetAddress, port int, InetAddress localAddress, int localPort) lève IOException
Socket (hôte de chaîne, port int) lève UnknownHostException, IOException
Socket (hôte de chaîne, port int , InetAddress localAddress, int localPort)lance IOException

Sauf pour le premier sans paramètres, d'autres constructeurs tenteront d'établir une connexion avec le serveur. En cas d'échec, une erreur IOException sera générée. En cas de succès, l'objet Socket est renvoyé.

InetAddress est une classe utilisée pour enregistrer les hôtes. Son getHostByName(String msg) statique peut renvoyer une instance. Sa méthode statique getLocalHost() peut également obtenir l'adresse IP de l'hôte actuel et renvoyer une instance. Les paramètres du constructeur Socket(String host, int port, InetAddress localAddress, int localPort) sont respectivement l'adresse IP cible, le port cible, l'adresse IP locale liée et le port local lié.

Méthode Socket

getInetAddress(); L'adresse IP du serveur distant
getPort(); le serveur distant
getLocalAddress()  L'adresse IP du client local
getLocalPort()  Le port du client local
getInputStream();  Récupère le flux d'entrée
getOutStream(); Obtenez le flux de sortie

Il convient de noter que, parmi ces méthodes, les plus importantes sont getInputStream() et getOutputStream().

Statut du socket

isClosed(); //Si la connexion est fermée, si elle est fermée, renvoie true sinon renvoie false ;
isConnect(); //S'il a déjà été connecté, retournez true ; sinon, retournez false
isBound(); //Si le Socket a été lié à un port local, retournez true ; sinon, retournez false

Si vous souhaitez confirmer si l'état du Socket est connecté, la déclaration suivante est un bon moyen de juger.

boolean isConnection=socket.isConnected() && !socket.isClosed(); // Détermine si la connexion est actuellement connectée

Fermez à moitié le Socket

Souvent, nous ne savons pas combien de temps il faudra pour lire le flux d'entrée obtenu avant qu'il ne se termine. Voici quelques-unes des méthodes les plus courantes :

•  Identifiant personnalisé (comme dans l'exemple ci-dessous, lors de la réception de la chaîne "bye", fermez le Socket)

•  Informer la longueur de lecture (pour certains protocoles personnalisés, les premiers octets sont fixes pour indiquer la longueur de lecture)

•  Lire toutes les données

•  Lorsque le Socket est fermé lors de l'appel de close, fermez ses flux d'entrée et de sortie
  

Constructeur ServerSocket

ServerSocket()throws IOException
ServerSocket(int port)throws IOException
ServerSocket(int port, int backlog)throws IOException
ServerSocket(int port, int backlog, InetAddress bindAddr)throws IOException

Remarque :

1. par le serveur de port ; la longueur de la file d'attente de la demande de connexion du client en retard ; IP de liaison du serveur bindAddr

2 Si le port est occupé ou n'a pas l'autorisation d'utiliser certains ports, une erreur BindException sera générée. Par exemple, les ports 1 à 1023 nécessitent que les administrateurs aient l'autorisation de se lier.

3. Si le port est réglé sur 0, le système lui attribuera automatiquement un port

4. bindAddr用于绑定服务器IP，为什么会有这样的设置呢，譬如有些机器有多个网卡。

5. ServerSocket一旦绑定了监听端口，就无法更改。ServerSocket()可以实现在绑定端口前设置其他的参数。

单线程的ServerSocket例子

public void service(){
  while(true){
    Socket socket=null;
    try{
      socket=serverSocket.accept();//从连接队列中取出一个连接，如果没有则等待
      System.out.println("新增连接："+socket.getInetAddress()+":"+socket.getPort());
      ...//接收和发送数据
    }catch(IOException e){e.printStackTrace();}finally{
      try{
        if(socket!=null) socket.close();//与一个客户端通信结束后，要关闭Socket
      }catch(IOException e){e.printStackTrace();}
    }
  }
}

多线程的ServerSocket

多线程的好处不用多说，而且大多数的场景都是多线程的，无论是我们的即时类游戏还是IM，多线程的需求都是必须的。下面说说实现方式：

•  主线程会循环执行ServerSocket.accept()；

•  当拿到客户端连接请求的时候，就会将Socket对象传递给多线程，让多线程去执行具体的操作；

实现多线程的方法要么继承Thread类，要么实现Runnable接口。当然也可以使用线程池，但实现的本质都是差不多的。

这里举例：

下面代码为服务器的主线程。为每个客户分配一个工作线程：

public void service(){
  while(true){
    Socket socket=null;
    try{
      socket=serverSocket.accept();            //主线程获取客户端连接
      Thread workThread=new Thread(new Handler(socket));  //创建线程
      workThread.start();                  //启动线程
    }catch(Exception e){
      e.printStackTrace();
    }
  }
}

当然这里的重点在于如何实现Handler这个类。Handler需要实现Runnable接口：

class Handler implements Runnable{
  private Socket socket;
  public Handler(Socket socket){
    this.socket=socket;
  }
  
  public void run(){
    try{
      System.out.println("新连接:"+socket.getInetAddress()+":"+socket.getPort());
      Thread.sleep(10000);
    }catch(Exception e){e.printStackTrace();}finally{
      try{
        System.out.println("关闭连接:"+socket.getInetAddress()+":"+socket.getPort());
        if(socket!=null)socket.close();
      }catch(IOException e){
        e.printStackTrace();
      }
    }
  }
}

当然是先多线程还有其它的方式，譬如线程池，或者JVM自带的线程池都可以。这里就不说明了。

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!