SpringCloud Nacos Gateway 网关集成 Netty的Websocket不成功问题记录，以及解决思路记录 【以及websocket代码例子】_gateway websocket

前言

• 目前项目由于导入导出业务处理时间过长；很容易连接超时，用户等待过长,体验感不佳
• 相关业务使用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
1
2
3
4
5
6
7
8
9
10

• lb：是负载均衡
• ws：代表通过websocket长连接协议，其他是gateway的常规配置

说说遇到的问题过程和解决思路

1. 启动getaway服务和socket服务接口调用并没有成功；

  1. ws升级成功
  2. 但是连接服务失败了
1
2

2. 排查1002原因，询问chatgpt

3. 百度、cv 最后排查到原因分析：

1. gateway连接不上websocket服务，转发失败
2. 我通过netty搭建websocket服务，所以项目中有两个端口，一个服务端口，一个netty端口
3. 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);
        }

    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

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            
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

7. 请求成功

总结：

• 后续将着手攻克Netty集群Channel共享的问题！
  
  
• 有什么问题的话，留言讨论（看到就回），或者可以通过公众号后台留言交流
• chatgpt相关了解可以通过关注公众号回复【chatgpt】即可获得 【科学上网12一年，目前使用正常，多用一天算一天】