Code ví dụ WebSocket với client là Java

Code ví dụ WebSocket với client là Java.

(Xem lại: WebSocket là gì? Giới thiệu cấu trúc WebSocket)

(Xem lại: Code ví dụ WebSocket với client là JavaScript)

Các công nghệ sử dụng:

Tạo Dynamic Web Project

Code ví dụ WebSocket với client là Java

Lưu ý: thư viện tomcat-juli.jarcó sẵn trong folder bin của tomcat, nhưng vì lúc import tomcat nó không tự động import thư viện này nên mình copy nó vào folder lib để mọi người đỡ phải config.

Tạo Server WebSocket:

package stackjava.com.websocket4.server;

import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint(value = "/server1")
public class MyServerEndpoint {

  @OnOpen
  public void handleOpen() {
    System.out.println("Client is now connected!");
  }

  @OnMessage
  public String handleMessage(String message) {
    System.out.println("Receive from client: " + message);
    String responseMessage = "Echo " + message;
    System.out.println("Send to client: " + responseMessage);
    return responseMessage;
  }

  @OnClose
  public void handleClose() {
    System.out.println("Client is now disconnected!");
  }

  @OnError
  public void handleError(Throwable t) {
    t.printStackTrace();
  }

}

Tạo Client Java EndPoint: (Client bằng Java)

package stackjava.com.websocket4.client;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

import javax.websocket.ClientEndpoint;
import javax.websocket.ContainerProvider;
import javax.websocket.DeploymentException;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;

@ClientEndpoint
public class MyClientEndpoint {
  
  private Session session = null;

  public MyClientEndpoint() throws URISyntaxException, DeploymentException, IOException {
    URI uri = new URI("ws://localhost:8080/WebSocket4/server1");
    ContainerProvider.getWebSocketContainer().connectToServer(this, uri);
  }
  
  @OnOpen
  public void handleOpen(Session session) {
    this.session = session;
    System.out.println("Connected to Server!");
  }

  @OnMessage
  public void handleMessage(String message) {
    System.out.println("Response from Server: " + message);
  }

  @OnClose
  public void handleClose() {
    System.out.println("Disconnected to Server!");
  }

  @OnError
  public void handleError(Throwable t) {
    t.printStackTrace();
  }
  
  public void sendMessage(String message) throws IOException {
    this.session.getBasicRemote().sendText(message);
  }
  
  public void disconnect() throws IOException {
    this.session.close();
  }
  
}
  • Annotation @ClientEndpoint  định nghĩa đây là một ClientEndpoint
  • Để kết nối với Server WebSocket ta sử dụng ContainerProvider.getWebSocketContainer().connectToServer(this, uri);
  • Các annotation @OnOpen, @OnMessage, @OnClose, @OnError định nghĩa các method xử lý các sự kiện.

File view: (Client JavaScript + HTML)

<!DOCTYPE html>
<html>
<head>
<title>Demo websocket</title>
</head>
<body>	
    <h1>Demo WebSocket</h1>
    <input onclick="connect()" value="Connect" type="button" />
    <input onclick="disconnect()" value="Disconnect" type="button" /> <br/><br/>
    
    <input id="textMessage" type="text" />
    <input onclick="sendMessage()" value="Send Message" type="button" /> <br/><br/>
    
    <textarea id="textAreaMessage" rows="10" cols="50"></textarea>

    <script type="text/javascript">
      var websocket;

      function connect() {
        websocket = new WebSocket("ws://localhost:8080/WebSocket4/server1");
        websocket.onopen = function(message) {processOpen(message);};
        websocket.onmessage = function(message) {processMessage(message);};
        websocket.onclose = function(message) {processClose(message);};
        websocket.onerror = function(message) {processError(message);};
      }

      function disconnect() {
        websocket.close();
      }
      
      function processOpen(message) {
        textAreaMessage.value += "Server connect... \n";
      }
      function processMessage(message) {
        console.log(message);
        textAreaMessage.value += "Response From Server ==> " + message.data + " \n";
      }
      function processClose(message) {
        textAreaMessage.value += "Server Disconnect... \n";
      }
      function processError(message) {
        textAreaMessage.value += "Error... " + message +" \n";
      }

      function sendMessage() {
        if (typeof websocket != 'undefined' && websocket.readyState == WebSocket.OPEN) {
          websocket.send(textMessage.value);
          textAreaMessage.value += "Send to Server ==> " + textMessage.value + " \n";
          textMessage.value = "";
        }
      }

    </script>
</body>
</html>

File MainApp.java

Dùng để chạy client Java (bạn start project trên server để chạy server WebSocket + file view (JavaScript Client), còn để chạy client bằng Java bạn chạy file MainApp.java như một ứng dụng JavaDesktop).

Mọi người cũng có thể tách riêng file MyClientEndpoint.java và MainApp.java thành 1 project riêng rẽ để chạy phía client (nhớ copy các file api websocket vào nhé), thích chạy client ở máy nào, chỗ nào thì chạy project (file MainApp.java) lên là được.

(Bài sau mình sẽ tách client và server ra thành 2 project riêng để các bạn thấy rõ)

Khi nhập ‘close’ thì client sẽ ngắt kết nối với server websocket.

package stackjava.com.websocket4.mainapp;

import java.io.IOException;
import java.net.URISyntaxException;
import java.util.Scanner;

import javax.websocket.DeploymentException;

import stackjava.com.websocket4.client.MyClientEndpoint;

public class MainApp {
  public static void main(String[] args) throws URISyntaxException, DeploymentException, IOException {
    MyClientEndpoint client = new MyClientEndpoint();
    Scanner sc = new Scanner(System.in);
    System.out.println("Enter something to send to Server:");
    while(true) {
      String message = sc.nextLine();
      if (message.equals("close")) {
        client.disconnect();
        break;
      }
      client.sendMessage(message);
    }
    sc.close();
  }

}

Demo:

Đầu tiên chạy Project trên server tomcat và mở file view trên trình duyệt:

code-vi-du-websocket-voi-client-la-java

Mình sẽ không giải thích thêm về phần client bằng JavaScript nữa vì đã có hẳn một ví dụ về nó rồi.

Tiếp theo, chạy File MainApp.java (chuột phải vào file và chọn Run As Java Application:

Demo Code ví dụ WebSocket với client là Java

Code ví dụ WebSocket với client là Java stackjava.com

Okay, Done!

Download code ví dụ trên tại đây.

 

References:

http://www.zaneacademy.com/

Trả lời

Email của bạn sẽ không được hiển thị công khai. Các trường bắt buộc được đánh dấu *

DMCA.com Protection Status stackjava.com