一、Maven依賴引入

1. Netty-WebSocket-Spring-Boot-Starter

<dependency>
    <groupId>org.yeauty</groupId>
    <artifactId>netty-websocket-spring-boot-starter</artifactId>
    <version>0.13.0</version> <!-- 請使用最新版本 -->
</dependency>

2. Spring官方WebSocket Starter

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

二、核心差異對比

三、使用場景決策指南

✅ 選擇 Netty-WebSocket 當：

• 需要處理高頻實時數據：金融行情推送、物聯網傳感器數據
• 使用自定義二進制協議：遊戲數據包、音視頻流傳輸
• 追求極致性能：要求1萬+併發連接，低延遲響應
• 脱離Servlet容器：希望WebSocket服務獨立部署

✅ 選擇 Spring官方Starter 當：

• 開發企業級消息系統：聊天應用、實時通知系統
• 需要完整STOMP支持：利用消息代理和訂閲機制
• 快速集成Spring生態：與Security、Data等組件協作
• 兼容舊瀏覽器：需要SockJS回退支持

四、核心代碼實現對比

方案1：Netty-WebSocket實現（實時數據推送）

@SpringBootApplication
@EnableNettyWebSocket // 啓用Netty WebSocket服務器
public class DataPushApplication {
    public static void main(String[] args) {
        SpringApplication.run(DataPushApplication.class, args);
    }
}

/**
 * 實時數據推送處理器
 * 特點：直接操作Session，手動管理連接
 */
@ServerEndpoint(host = "0.0.0.0", port = "8080", path = "/realtime")
public class DataPushHandler {
    
    // 存儲所有活動會話
    private static final Set<Session> sessions = ConcurrentHashMap.newKeySet();

    @OnOpen
    public void onOpen(Session session) {
        sessions.add(session);
        session.sendText("CONNECTED|" + LocalTime.now());
    }

    @OnText
    public void onText(Session session, String message) {
        // 處理文本消息（如控制指令）
        String response = processCommand(message);
        session.sendText(response);
    }

    @OnBinary
    public void onBinary(Session session, byte[] bytes) {
        // 解析二進制數據（如傳感器數據）
        SensorData data = SensorDecoder.decode(bytes);
        // 處理數據邏輯...
        byte[] response = SensorEncoder.encode(data);
        session.sendBinary(response);
    }

    @OnClose
    public void onClose(Session session, CloseReason reason) {
        sessions.remove(session);
    }
    
    // 廣播數據給所有客户端
    public static void broadcast(byte[] data) {
        sessions.forEach(session -> {
            if (session.isOpen()) {
                session.sendBinary(data);
            }
        });
    }
}

方案2：Spring官方Starter實現（完整聊天室）

/**
 * WebSocket配置類
 * 特點：使用STOMP協議，配置消息代理
 */
@Configuration
@EnableWebSocketMessageBroker
public class ChatConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 客户端連接端點
        registry.addEndpoint("/chat-ws")
                .setAllowedOriginPatterns("*")
                .withSockJS(); // 瀏覽器兼容支持
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        // 啓用內存消息代理
        registry.enableSimpleBroker("/topic", "/queue");
        
        // 設置應用消息前綴
        registry.setApplicationDestinationPrefixes("/app");
        
        // 設置用户私有隊列前綴
        registry.setUserDestinationPrefix("/user");
    }
}

/**
 * 聊天控制器
 * 特點：使用高級消息抽象，自動處理訂閲
 */
@Controller
public class ChatController {
    
    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    // 處理公共聊天消息
    @MessageMapping("/chat")
    @SendTo("/topic/messages")
    public ChatMessage handlePublicMessage(@Payload ChatMessage message, 
                                        Principal principal) {
        message.setSender(principal.getName());
        message.setTimestamp(LocalDateTime.now());
        return message;
    }

    // 處理私有消息
    @MessageMapping("/private")
    public void handlePrivateMessage(@Payload ChatMessage message, 
                                   Principal principal) {
        message.setSender(principal.getName());
        message.setTimestamp(LocalDateTime.now());
        
        // 定向發送給接收者
        messagingTemplate.convertAndSendToUser(
            message.getRecipient(), 
            "/queue/private", 
            message
        );
    }
    
    // 用户上線處理
    @EventListener
    public void handleConnect(SessionConnectedEvent event) {
        String username = event.getUser().getName();
        // 通知所有用户更新在線列表
        messagingTemplate.convertAndSend("/topic/onlineUsers", 
            userService.getOnlineUsers());
    }
}

/**
 * 消息實體類
 */
public class ChatMessage {
    private String sender;      // 發送者
    private String recipient;   // 接收者（私聊使用）
    private String content;     // 消息內容
    private LocalDateTime timestamp; // 時間戳
    
    // getters & setters
}

五、關鍵差異解析

1. 連接管理方式

   • Netty：手動維護Session集合，直接操作連接
   • Spring：自動管理連接，通過SimpMessagingTemplate發送消息

2. 消息處理模式

   graph LR A[客户端] --> B{Netty方案} B --> C[直接處理二進制數據] B --> D[自定義協議解析] A --> E{Spring方案} E --> F[STOMP消息代理] E --> G[發佈/訂閲模式]

3. 異常處理機制

   • Netty：通過@OnError捕獲異常，需手動關閉問題會話
   • Spring：全局異常處理器@MessageExceptionHandler統一處理

4. 集羣支持

   • Netty：需自行實現分佈式會話管理（如Redis）
   • Spring：天然支持通過消息代理（RabbitMQ/Redis）實現集羣

六、選型建議總結

黃金實踐法則：
新項目若不需要處理二進制協議，優先選擇Spring官方方案；
現有系統需添加高性能實時通道，引入Netty作為獨立服務模塊；
關鍵業務系統建議同時實現兩種方案，Netty處理實時數據流，Spring處理業務消息。