SpringCloud Nacos Gateway 网关集成 Netty的Websocket不成功问题记录,以及解决思路记录 【以及websocket代码例子】
目前项目由于导入导出业务处理时间过长;很容易连接超时,用户等待过长,体验感不佳相关业务使用http短连接请求,无法满足某些特定的业务场景,如消息通知弹窗、扫码登录故需要引入websocket因为原有项目网关是使用【springCloud-nacos-gateWay】,所以先项目websocket项目需要使用网关进行统一转发(便于管理)gateway连接不上websocket服务,转发失败我通过ne
·
文章目录
前言
- 目前项目由于导入导出业务处理时间过长;很容易连接超时,用户等待过长,体验感不佳
- 相关业务使用http短连接请求,无法满足某些特定的业务场景,如消息通知弹窗、扫码登录
- 故需要引入websocket
- 因为原有项目网关是使用【springCloud-nacos-gateWay】,所以先项目websocket项目需要使用网关进行统一转发(便于管理)
websocket项目创建
有时间出个demo项目(下次一定) gitee代码仅供参考
gateWay的ws协议配置
spring:
cloud:
gateway:
routes:
- id: dh-web-socket-service
uri: lb:ws://dh-web-socket-service:30229
predicates:
- Path=/CYHLW/ws/**
filters:
- StripPrefix=2
- lb:是负载均衡
- ws:代表通过websocket长连接协议,其他是gateway的常规配置
说说遇到的问题过程和解决思路
1. 启动getaway服务和socket服务接口调用并没有成功;
1. ws升级成功
2. 但是连接服务失败了
2. 排查1002原因,询问chatgpt
3. 百度、cv 最后排查到原因分析:
- gateway连接不上websocket服务,转发失败
- 我通过netty搭建websocket服务,所以项目中有两个端口,一个服务端口,一个netty端口
- nacos注册只注册上服务端口,netty端口没有注册上。需要手动注册
4. 手动将netty服务注册到nacos上:
package com.dh.websocket.core.configuration;
import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.nacos.api.naming.NamingFactory;
import com.alibaba.nacos.api.naming.NamingService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import java.net.InetAddress;
import java.util.Properties;
/**
* web socket寄存器nacos配置
*
* @author yolo
* @date 2024/3/18 14:58
*/
@Configuration
public class WebSocketRegisterNacosConfiguration {
@Value("${netty.socket.application-name}")
private String applicationName;
@Value("${netty.socket.port}")
private int port;
@Autowired
private NacosDiscoveryProperties nacosDiscoveryProperties;
@PostConstruct
public void start() {
// 注册到Nacos里
registerNamingService(applicationName, port);
}
/**
* 注册到 nacos 服务中
*
* @param nettyName netty服务名称
* @param nettyPort netty服务端口
*/
private void registerNamingService(String nettyName, int nettyPort) {
try {
NamingService namingService = NamingFactory.createNamingService(nacosDiscoveryProperties.getNacosProperties());
InetAddress address = InetAddress.getLocalHost();
namingService.registerInstance(nettyName, address.getHostAddress(), nettyPort);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
}
5. nacos服务列表出现对应的配置信息
6. 调整gateway网关配置
spring:
cloud:
gateway:
routes:
- id: dh-web-socket-service
uri: lb://dh-web-socket-service
predicates:
- Path=/dh/wsocket-service/**
filters:
- StripPrefix=2
- id: dh-web-socket
uri: lb:ws://dh-web-socket
predicates:
- Path=/dh/wsocket/**
filters:
- StripPrefix=2
7. 请求成功
总结:
- 后续将着手攻克Netty集群Channel共享的问题!
- 有什么问题的话,留言讨论(看到就回),或者可以通过公众号后台留言交流
- chatgpt相关了解可以通过关注公众号回复【chatgpt】即可获得 【科学上网12一年,目前使用正常,多用一天算一天】
更多推荐
已为社区贡献1条内容
所有评论(0)