springboot群聊推送消息

### 实现Spring Boot中的群聊消息推送

为了实现在Spring Boot应用程序中通过WebSocket进行群聊消息推送的功能，可以按照以下方式构建项目结构并编写相应代码。

#### 添加依赖项
首先，在`pom.xml`文件中加入必要的依赖来支持WebSocket通信：

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

此部分配置确保了项目的Maven环境能够识别并引入用于处理WebSocket连接所需的库[^3]。

#### 配置类定义
接着创建一个配置类以启用WebSocket的支持，并设置STOMP端点以及订阅目的地。这可以通过继承`WebSocketMessageBrokerConfigurerSupport`接口或使用`@Configuration`注解配合特定的方法实现。下面是一个简单的例子展示如何完成这些操作：

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 设置服务器前缀为"/topic"
        config.enableSimpleBroker("/topic");
        
        // 定义客户端发送的消息的目的地前缀为"/app"
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 注册stomp端点供前端连接
        registry.addEndpoint("/ws").withSockJS();
    }
}

这段代码实现了基本的WebSocket STOMP协议配置，允许客户端通过指定路径建立连接并向其广播信息[^2]。

#### 控制器开发
随后需要设计控制器用来接收来自用户的聊天请求并将它们转发给其他在线成员。这里给出了一种可能的方式来进行此类交互：

import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;

@Controller
public class ChatController {

    @MessageMapping("/chat.sendMessage")
    @SendTo("/topic/messages")
    public String sendMessage(String messageContent) throws Exception {
        return "【新消息】：" + messageContent;
    }
}

上述方法监听到了由客户端发出的目标地址为`/app/chat.sendMessage`的信息后会将其封装成新的字符串形式再推送给所有已订阅`/topic/messages`主题下的用户。

#### 启动类调整
最后回到启动类`ChatServiceApplication.java`，确认已经包含了使能WebSocket特性的相关注解：

@SpringBootApplication
@EnableWebSocket
@MapperScan("com.service.chat.dao")
public class ChatServiceApplication {
    
    public static void main(String[] args) {
        SpringApplication.run(ChatServiceApplication.class, args);
    }
}

这样就完成了整个基于Spring Boot框架下利用WebSocket技术实现群组即时通讯的基础搭建工作[^1]。