Java案例怎么推送站内消息？

wen java案例 2026-06-07 79

本文目录导读：

Java案例怎么推送站内消息？

📚 目录导读
什么是站内消息推送？业务场景与价值
Java实现站内消息的核心技术栈
案例1：基于消息队列的异步推送（RabbitMQ）
案例2：WebSocket实时推送 + Spring Boot整合
案例3：配合数据库轮询的离线消息补发
高频问答集锦（开发者必读）
SEO优化建议 & 总结

📚 目录导读

什么是站内消息推送？业务场景与价值
Java实现站内消息的核心技术栈
案例1：基于消息队列的异步推送（RabbitMQ/ Kafka）
案例2：WebSocket实时推送 + Spring Boot整合
案例3：配合数据库轮询的离线消息补发
高频问答集锦（开发者必读）
SEO优化建议 & 总结

什么是站内消息推送？业务场景与价值

站内消息推送，是指用户在登录系统后，在平台内收到的通知、公告、提醒等非邮件/非短信的即时或延迟消息,常见场景包括：

电商：订单状态更新、物流提醒、优惠券到账
社交：点赞评论、好友申请、系统公告
企业系统：审批进度、任务指派、告警通知

价值：提升用户活跃度、降低通知延迟、增强用户体验，Java作为后端主力语言,必须掌握高效推送方案。

Java实现站内消息的核心技术栈

组件	推荐技术	说明
后端框架	Spring Boot + Spring MVC	提供REST API和WebSocket支持
消息中间件	RabbitMQ / Apache Kafka	解耦生产与消费，保证消息不丢
实时通信	WebSocket / SSE	双向实时推送
数据库	MySQL + Redis	MySQL存储消息，Redis缓存未读数量
生命周期	生产者→消息队列→消费者→DB→推送

关键设计原则：异步、削峰、可靠、实时。

案例1：基于消息队列的异步推送（RabbitMQ）

场景

当用户完成支付后，系统需向用户推送“订单已支付”通知，若同步推送,高并发下可能阻塞下游服务。

实现步骤

引入依赖

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

配置队列

@Configuration
public class RabbitConfig {
    @Bean
    public Queue pushQueue() {
        return new Queue("user.push.queue", true);
    }
}

生产者（支付服务）

@Service
public class OrderService {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    public void paySuccess(Long userId, String orderNo) {
        // 业务逻辑 ...
        PushMessage msg = new PushMessage(userId, "您的订单 " + orderNo + " 已支付成功");
        rabbitTemplate.convertAndSend("user.push.queue", msg);
    }
}

消费者（推送服务）

@Component
@RabbitListener(queues = "user.push.queue")
public class PushConsumer {
    public void handlePush(PushMessage msg) {
        // 1. 存储到数据库（MySQL）
        pushMsgRepository.save(msg);
        // 2. 通过WebSocket实时推送
        webSocketService.sendToUser(msg.getUserId(), msg.getContent());
    }
}

优势：解耦、抗压、支持失败重试。

案例2：WebSocket实时推送 + Spring Boot整合

场景

用户在线时，需立刻收到消息,而非HTTP轮询。

实现步骤

WebSocket配置

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(chatHandler(), "/ws/push")
                .setAllowedOrigins("*");
    }
}

处理器逻辑

public class PushWebSocketHandler extends TextWebSocketHandler {
    private static final Map<Long, WebSocketSession> sessions = new ConcurrentHashMap<>();
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        Long userId = extractUserId(session); // 从token获取
        sessions.put(userId, session);
    }
    public void sendToUser(Long userId, String message) {
        WebSocketSession session = sessions.get(userId);
        if (session != null && session.isOpen()) {
            session.sendMessage(new TextMessage(message));
        }
    }
}

前端连接

let ws = new WebSocket("wss://your-domain.com/ws/push?token=xxx");
ws.onmessage = (event) => {
    // 更新通知栏
};

注意：需配合Spring Security拦截器做权限校验。

案例3：配合数据库轮询的离线消息补发

场景

用户离线期间，WebSocket无法推送，需在用户重新上线时,通过数据库轮询补发。

实现方案

消息表设计

CREATE TABLE `user_push` (
`id` bigint PRIMARY KEY,
`user_id` bigint,
`content` varchar(500),
`status` tinyint DEFAULT 0, -- 0未读1已读
`created_at` datetime
);

上线时批量拉取

@EventListener
public void onUserOnline(UserOnlineEvent event) {
 List<PushMessage> unread = pushMsgRepository.findByUserIdAndStatus(
     event.getUserId(), 0);
 for (PushMessage msg : unread) {
     webSocketService.sendToUser(msg.getUserId(), msg.getContent());
 }
 // 标记已读
 pushMsgRepository.updateStatusByUserId(event.getUserId(), 1);
}

优化：使用Redis做未读计数热数据,减轻DB压力。