首页 > 其他分享 >websocket客户端类,工具类中调用到service层去

websocket客户端类,工具类中调用到service层去

时间:2024-01-29 21:48:46浏览次数:27  
标签:info websocket log service void Override 层去 public paramString

maven

<dependency>
    <groupId>org.java-websocket</groupId>
    <artifactId>Java-WebSocket</artifactId>
    <version>1.3.5</version>
</dependency>

代码

@Slf4j
@Component
public class WESWebSocketClient extends WebSocketClient {

    @Autowired
    private WebSocketProcessor webSocketProcessorFor;

    private static WebSocketProcessor webSocketProcessor;

    @PostConstruct
    public void init() {
        webSocketProcessor = webSocketProcessorFor;
    }

    public WESWebSocketClient() throws URISyntaxException {
        super(new URI("ws://127.0.0.1:9102/ws"));
    }
public WESWebSocketClient(String url) throws URISyntaxException {
    super(new URI(url));
}

@Override
public void onOpen(ServerHandshake shake) {
    log.info("握手...");
}

@Override
public void onMessage(String paramString) {
    PbStationExtendInfo pbStationExtendInfo = JSONUtil.toBean(paramString, PbStationExtendInfo.class);
    log.info("接收到消息:"+paramString);
    webSocketProcessor.processor(pbStationExtendInfo);
}

@Override
public void onMessage(ByteBuffer bytes) {
    log.info("ByteBuffer 接收到消息:"+bytes);
    super.onMessage(bytes);
}

@Override
public void onClose(int paramInt, String paramString, boolean paramBoolean) {
    log.info("关闭...paramInt:"+paramInt+" paramString:"+paramString+" paramBoolean:"+paramBoolean);
}

@Override
public void one rror(Exception e) {
    log.info("异常"+e);

}

public void sendMsg(String msg) throws InterruptedException {
    this.send(msg);
}

}

标签:info,websocket,log,service,void,Override,层去,public,paramString
From: https://www.cnblogs.com/daleyzou/p/17995381/useWebsocket

相关文章

  • WebSocket和RESTful API区别
    1.WebSocket和RESTfulAPI区别WebSocket和RESTfulAPI是用于在客户端和服务器之间进行通信的不同协议。RESTfulAPI(RepresentationalStateTransfer)是一种使用HTTP协议进行通信的架构风格。它基于客户端-服务器模型,通过使用不同的HTTP动词(GET、POST、PUT、DELETE等)对资源进行......
  • 如何修改Azure Kubernetes Services节点池VM Size
    如何修改AzureKubernetesServices节点池大小今天和大家聊聊AzureKubernetesServices(AKS)修改节点池VMSize的问题。这也是很多客户在使用AKS的过程中都会遇到的一个问题。随着AKS群集使用时间的增长,很多客户都会面临扩展或修改AKS节点池VMSize的问题,具体的原因大致如下:性能优化......
  • Websocket 简单使用
    vue3  <scriptsetup>import{reactive,ref,onMounted,onBeforeMount,onUnmounted}from'vue'onMounted(()=>{initWebsocket()})onUnmounted(()=>{WebSocketonclose()})constws=reactive({socket:null,})constini......
  • k8s集群断电后 机器不能启动问题--- Centos 服务器 无法启动 Failed to start Login S
    参考文档:https://blog.csdn.net/hedao0515/article/details/129718094先说下主要原因,是因为断电后有些文件没有完整写入,导致文件系统错误,需要借助原生工具修复文件系统。重启机器,进入linux选择内核页面,按ctrl+x进入引导页面,在linux16这一行最后填上init=/bin/bash有可能......
  • Spring WebSocket实现实时通信的详细教程
    简介WebSocket是基于TCP/IP协议,独立于HTTP协议的通信协议。WebSocket连接允许客户端和服务器之间的全双工通信,以便任何一方都可以通过已建立的连接将数据推送到另一方。我们常用的HTTP是客户端通过「请求-响应」的方式与服务器建立通信的,必须是客户端主动触发的行为,服务端只是......
  • HTML5 WebSocket 详解及使用
    WebSocket没用过的同学,听上去,可能觉得很难,其实很简单,本章讲解了WebSocket基本信息,以及附有代码例子WebSocket是什么?WebSocket是HTML5提供的一种在单个TCP连接上进行全双工通讯的协议。(双向通信协议)WebSocket的作用?实现客户端与服务器之间的双向通信,允许服务端主动......
  • 在K8S中,Service类型有哪些?
    在Kubernetes(简称K8s)中,Service是定义访问Pod的一种抽象方法,它提供了负载均衡和网络代理功能。以下是KubernetesService的几种主要类型:ClusterIP(默认类型)创建一个仅集群内部可以访问的虚拟IP。通过这个IP地址,Kubernetes会将流量路由到与Service关联的一组Pod。这种类型......
  • APISIX同时代理websocket和http请求 websocket无法正常工作
    1.配置了一个路由同时代理websocket和http请求 2.打开了websocket支持,websocket还是无法工作  3.定位3.1通过postman分别走apisix和不经过apisix建立websocet连接,发现经过apisix也能成功建立连接,但是10秒左右就自己断开了。  3.2思考3.3决定试一下是否和超时配置有关,改一下改......
  • Android系统开发之TimeZoneDetectorService浅析--下
    TimeZoneDetectorService类图可以看出TimeZoneDetectorService类,其具体实现是由TimeZoneDetectorStrategy类完成的。在TimeZoneDetectorService类中,三种更新时区的接口分别为:suggestGeolocationTimeZone()//更新时区主要有三种方式,这是Geolocation方式+booleansuggestManualT......
  • TimeZoneDetectorService浅析--上
    一:问题描述:客户有一个关闭通话功能的需求,根据MTK的配置方法关闭了大概8个宏开关后,实现通话功能,但是导致插好sim卡开机后,时间和时区不能更新的问题。二:问题分析:(1).MTK的日志分析,可以确认为时间已经更新,但是时区确实是没有更新//收到NITZAT:[0]AT<+CTZEU:"+32",0,"2024/01......