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日

悬赏问题

  • ¥20 管道轴向耦合水击问题
  • ¥60 补全networkx TODO部分。
  • ¥15 有内推吗,云计算linux运维方向
  • ¥30 sort cuteSV.vcf by bcftools用IGV可视化出现报错
  • ¥100 SOS!对STK中导出的天体图像进行质心提取有没有人做过啊
  • ¥15 python 欧式距离
  • ¥15 运行qteasy报错
  • ¥15 遗传算法解决有工序顺序约束的大规模FJSP问题
  • ¥15 企业消防水炮塔设计方案
  • ¥20 WORKBENCH网格划分