Android 和 Java Ping/Pong Web Socket 功能

Question

我已经开发了 Android 应用程序，正在连接到 JAVA Web Socket，基本上它运行得很好。 问题是，有时客户端断开连接，但服务器端的连接似乎已连接。

我尝试调查它发生的时间和原因，但不幸的是我找不到导致此问题的特定场景。

我想过在服务器和所有客户端之间实现 Ping/Pong 消息传递，如果客户端没有答复，则关闭服务器端的连接。

我可以轻松实现这样的私有机制，但我已经阅读了周围的内容，并且了解 Java 和 Android 内置了 Ping/Pong 消息传递机制，但我无法找到任何示例。

无论如何，可以提供一个简单的示例如何使用内置工具实现 Ping/Pong 消息传递功能吗？

Answer 1

我已经成功实现了 EE JAVA WebSocket 和 android 应用程序之间的 Ping/Pong 功能。服务器每 5 分钟向客户端发送一次 Ping 消息。如果服务器在 5 秒内没有收到 Pong 消息，则服务器正在关闭客户端连接。

如果有人需要的话，这是我的解决方案：

WebSocket 端：

public class User {
    public ScheduledExecutorService pingExecutorService;
    public Timer disconnectTimer;
    private Session userSession;
    private String userName;

    public User(Session userSession) {
        this.userSession = userSession;
    }

    public Session getUserSession() {
        return userSession;
    }

    public void setUserSession(Session userSession) {
        this.userSession = userSession;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }
}

@OnOpen
public void onOpen(Session session) {
    User newUserConnection = new User(session);
    connections.getConnections().put(session.getId(), newUserConnection);
    schedulePingMessages(newUserConnection);
}

@OnClose
public void onClose(Session session) {
    handleOnClose(session);
}

@OnMessage
public void onMessage(String message, Session session) {
    messageHandler.handleMessage(message, session);
}

@OnMessage
public void onPong(PongMessage pongMessage, Session session) {
    String sourceSessionId = session.getId();
    User user = connections.getConnections().get(sourceSessionId);
    user.disconnectTimer.cancel();
    user.disconnectTimer.purge();
}

@OnError
public void onError(Throwable t) {
    System.out.println(new Date() + "onError::" + t.getMessage());
    t.printStackTrace();
}

private void schedulePingMessages(User newUserConnection) {
    newUserConnection.pingExecutorService = Executors.newScheduledThreadPool(1);
    newUserConnection.pingExecutorService.scheduleAtFixedRate(() -> {
        scheduleDiconnection(newUserConnection);
        try {
            String data = "Ping";
            ByteBuffer payload = ByteBuffer.wrap(data.getBytes());
            newUserConnection.getUserSession().getBasicRemote().sendPing(payload);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }, 300, 300, TimeUnit.SECONDS);
}

private void scheduleDiconnection(User user) {
    user.disconnectTimer = new Timer();
    user.disconnectTimer.schedule(new TimerTask() {
        @Override
        public void run() {
            try {
                user.getUserSession().close(new CloseReason(CloseCodes.UNEXPECTED_CONDITION," Client does not response"));
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }, 5000);
}

android端只需要添加如下override方法即可：

    @Override
    public void onWebsocketPing(WebSocket conn, Framedata f) {
        Log.i("ZCF","got Ping !");
        super.onWebsocketPing(conn, f);
    }

Answer 2

我不久前开发了一个java WebsocketPingerService（在mavencentral中可用），它使用专用线程自动向注册连接发送ping并处理生成的pong。
它通常可以在客户端和服务器端使用，但由于它创建了一个后台线程（使用

Executors.newSingleThreadScheduledExecutor()

），因此将其集成到标准 Android 客户端应用程序中可能并不容易（我还没有进行任何 Android 开发）虽然已经很多年了，所以我在这里可能是错的）。