Comment utiliser Java pour développer la fonction de transfert de fichiers Websocket

Comment utiliser Java pour développer la fonction de transfert de fichiers Websocket

Avec le développement d'Internet, le transfert de fichiers est devenu un élément indispensable du travail et de la vie quotidienne. En tant que protocole de communication établissant une connexion persistante entre le navigateur et le serveur, Websocket présente les caractéristiques de transmission en temps réel et bidirectionnelle, ce qui en fait un choix idéal pour le transfert de fichiers. Cet article explique comment utiliser Java pour développer la fonction de transfert de fichiers Websocket et fournit des exemples de code spécifiques.

1. Créer un serveur Websocket

Pour implémenter la fonction de transfert de fichiers, vous devez d'abord créer un serveur Websocket pour recevoir et traiter les demandes des clients. Voici un exemple de code pour créer un serveur Websocket à l'aide du framework Java Tomcat :

@ServerEndpoint("/upload")
public class FileUploadServer {

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("Client connected: " + session.getId());
    }

    @OnMessage
    public void onMessage(ByteBuffer byteBuffer, Session session) throws IOException {
        Path path = Paths.get("uploads", session.getId() + ".jpg");
        Files.write(path, byteBuffer.array());
        System.out.println("File uploaded: " + path.toString());
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("Client disconnected: " + session.getId());
    }

    @OnError
    public void onError(Throwable e) {
        e.printStackTrace();
    }
}

Dans le code ci-dessus, nous utilisons l'annotation @ServerEndpoint pour annoter un serveur Websocket et spécifier l'URL à laquelle le client accède. comme /upload. Le côté serveur propose quatre méthodes pour gérer les connexions client, recevoir des données de fichiers, se déconnecter et gérer les exceptions respectivement. Parmi elles, la méthode onMessage est appelée lors de la réception des données du fichier, enregistre le fichier dans le dossier uploads et utilise l'ID du client comme nom de fichier. @ServerEndpoint注解标注了一个Websocket服务器端，并指定了客户端访问的URL为/upload。服务器端提供了四个方法，分别处理客户端连接、接收文件数据、断开连接和处理异常。其中，onMessage方法在接收到文件数据时调用，将文件保存到uploads文件夹中，并以客户端的ID作为文件名。

二、创建Websocket客户端

接下来，我们需要创建一个Websocket客户端来发送文件数据给服务器端。下面是使用Java的JavaFX框架创建Websocket客户端的示例代码：

public class FileUploadClient extends Application {

    private static final String SERVER_URI = "ws://localhost:8080/upload";

    private WebSocketClient client;

    public static void main(String[] args) {
        launch(args);
    }

    @Override
    public void start(Stage primaryStage) {
        try {
            URI uri = new URI(SERVER_URI);
            client = new WebSocketClient(uri) {
                @Override
                public void onOpen(ServerHandshake handshakedata) {
                    System.out.println("Connected to server");
                }

                @Override
                public void onMessage(String message) {
                    System.out.println("Received message: " + message);
                }

                @Override
                public void onClose(int code, String reason, boolean remote) {
                    System.out.println("Disconnected from server");
                }

                @Override
                public void onError(Exception ex) {
                    ex.printStackTrace();
                }
            };
            client.connect();
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
    }

    public void uploadFile(Path path) throws IOException {
        byte[] bytes = Files.readAllBytes(path);
        client.send(bytes);
        System.out.println("File uploaded: " + path.toString());
    }
}

在上述代码中，我们使用JavaFX创建了一个简单的界面，通过连接到服务器端的URL ws://localhost:8080/upload，并实现了客户端的四个方法，分别处理与服务器端通信的各个阶段。uploadFile

2. Créer un client Websocket

Ensuite, nous devons créer un client Websocket pour envoyer les données du fichier au serveur. Vous trouverez ci-dessous l'exemple de code pour créer un client Websocket à l'aide du framework JavaFX de Java :

rrreee

Dans le code ci-dessus, nous avons créé une interface simple utilisant JavaFX en nous connectant à l'URL côté serveur ws://localhost:8080/ upload et implémente quatre méthodes côté client pour gérer différentes étapes de communication avec le côté serveur. La méthode uploadFile est utilisée pour lire le fichier spécifié dans un tableau d'octets et l'envoyer au serveur via le client.

3. Démarrez le serveur et le client

Après avoir terminé le code du serveur et du client, nous devons les démarrer pour tester la fonction de transfert de fichiers. Tout d'abord, vous devez déployer le code côté serveur sur Tomcat ou un autre serveur prenant en charge les applications Web Java, puis démarrer le serveur. Vous pouvez ensuite exécuter le code client directement en lançant l'application JavaFX.

Une fois le programme exécuté, le client établira une connexion avec le serveur et le message d'invite « Connecté au serveur » sera imprimé sur la console. Ensuite, nous pouvons sélectionner le fichier à télécharger via le sélecteur de fichiers sur l'interface et cliquer sur le bouton "Télécharger". Le client enverra le fichier sélectionné au serveur et imprimera le message d'invite « Fichier téléchargé : chemin du fichier » sur la console. 🎜🎜4. Résumé🎜🎜Cet article explique comment utiliser Java pour développer la fonction de transfert de fichiers Websocket et fournit des exemples de code spécifiques pour le serveur et le client. Grâce à la communication bidirectionnelle et à la nature en temps réel du protocole Websocket, nous sommes en mesure de réaliser un transfert de fichiers rapide, efficace et sécurisé. Je pense que les lecteurs peuvent explorer et appliquer davantage la technologie de transfert de fichiers Websocket sur la base de l'exemple de code fourni dans cet article. 🎜

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!