Lukas00990 2021-10-22 00:46 采纳率: 40.8%
浏览 81
已结题

java WebSocket, 如何只发一个信息,就停止。

用JAVA websocket 发信息,用的是tyrus 工具包。 client 端代码如下:

package websockets;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.CountDownLatch;
import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.DeploymentException;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import org.glassfish.tyrus.client.ClientManager;

@ClientEndpoint
public class ChatClientEndpoint {

    private static CountDownLatch latch;

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("--- Connected " + session.getId());
        try {
            session.getBasicRemote().sendText("Sk_execute");
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @OnMessage
    public String onMessage(String message, Session session) {
        BufferedReader bufferRead = new BufferedReader(new InputStreamReader(System.in));
        try {
            System.out.println("--- Received: " + message);
            String userInput = bufferRead.readLine();
               CloseReason closeReason = null;
                this.onClose(session, closeReason);
                session.close();

            }
            return userInput;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        System.out.println("Session " + session.getId()
                + " closed because " + closeReason);
        //latch.countDown();
    }

    public static void main(String[] args) {
        latch = new CountDownLatch(1);
        ClientManager client = ClientManager.createClient();
        try {
            URI uri = new URI("ws://192.168.1.10:3000/");
            client.connectToServer(ChatClientEndpoint.class, uri);

            latch.await();

        } catch (DeploymentException | URISyntaxException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

我现在想实现,我client 发一个信号后,关闭线程。如何操作?现阶段的代码是 信息一直在发送。除此之外, @OnMessage 这个方法中的下面两行用不了。
this.onClose(session, closeReason);
session.close();

我想实现的是,client 收到一个信息后,关闭线程。

  • 写回答

2条回答 默认 最新

  • 急速光粒 2021-10-22 06:54
    关注
    @OnMessage
        public String onMessage(String message, Session session) {
            BufferedReader bufferRead = new BufferedReader(new InputStreamReader(System.in));
            try {
                System.out.println("--- Received: " + message);
                String userInput = bufferRead.readLine();
                   CloseReason closeReason = null;
                    this.onClose(session, closeReason);
                    session.close();
     
                }
                return userInput;
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    
    

    问题在这里,你把
    CloseReason closeReason = null;
    this.onClose(session, closeReason);
    这两句去掉,这是close事件,只要调用close方法就行,而且你把 CloseReason closeReason = null;可能会引起onClose中执行代码异常,导致真正的连接关闭代码close不被执行,所以结果就是没关闭。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 11月1日
  • 已采纳回答 10月24日
  • 创建了问题 10月22日

悬赏问题

  • ¥15 爬取网页信息并附加完整代码
  • ¥15 CST2023安装报错
  • ¥15 使用diffusionbert生成文字 结果是PAD和UNK怎么办
  • ¥15 有人懂怎么做大模型的客服系统吗?卡住了卡住了
  • ¥20 firefly-rk3399上启动卡住了
  • ¥15 如何删除这个虚拟音频
  • ¥50 hyper默认的default switch
  • ¥15 网站打不开,提示502 Bad Gateway
  • ¥20 基于MATLAB的绝热压缩空气储能系统代码咨询
  • ¥15 R语言建立随机森林模型出现的问题