SpringAOP+RabbitMQ+WebSocket实战详解

下面是SpringAOP+RabbitMQ+WebSocket实战详解的完整攻略，包含两个示例说明。

简介

本文将介绍如何使用SpringAOP、RabbitMQ和WebSocket实现一个简单的聊天室应用。在该应用中，用户可以通过浏览器访问前端页面，输入用户名后加入聊天室，发送消息并接收其他用户的消息。后端使用SpringAOP实现日志记录，RabbitMQ实现消息队列，WebSocket实现实时通信。

示例一：使用SpringAOP记录日志

1. 添加依赖

在pom.xml文件中添加以下依赖：

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

2. 创建切面

创建一个名为LogAspect的切面，用于记录日志。代码如下：

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

@Aspect
@Component
public class LogAspect {

    private Logger logger = LoggerFactory.getLogger(LogAspect.class);

    @Pointcut("execution(* com.example.chatroom.controller.*.*(..))")
    public void controllerLog() {}

    @AfterReturning(pointcut = "controllerLog()", returning = "result")
    public void log(JoinPoint joinPoint, Object result) {
        String className = joinPoint.getTarget().getClass().getSimpleName();
        String methodName = joinPoint.getSignature().getName();
        logger.info(className + "." + methodName + "() returned: " + result);
    }
}

在上面的代码中，我们定义了一个名为LogAspect的切面，用于记录控制器方法的返回值。在切面中，我们使用@Pointcut注解定义了一个切点，用于匹配所有控制器方法。在@AfterReturning注解中，我们指定了切点和返回值，并在方法中记录了控制器方法的返回值。

3. 测试

现在，我们可以启动应用程序，并访问控制器方法。在访问控制器方法时，切面将记录控制器方法的返回值。

示例二：使用RabbitMQ实现消息队列

1. 添加依赖

在pom.xml文件中添加以下依赖：

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

2. 配置RabbitMQ连接信息

在application.properties文件中添加以下配置：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建消息发送者

创建一个名为MessageSender的类，用于发送消息。代码如下：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);
    }
}

在上面的代码中，我们定义了一个名为MessageSender的类，用于发送消息。在类中，我们注入了AmqpTemplate，并定义了一个sendMessage方法，用于发送消息。

4. 创建消息接收者

创建一个名为MessageReceiver的类，用于接收消息。代码如下：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageReceiver {

    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的代码中，我们定义了一个名为MessageReceiver的类，用于接收消息。在类中，我们使用@RabbitListener注解定义了一个监听器，用于监听名为myQueue的队列，并在接收到消息时打印消息内容。

5. 测试

现在，我们可以启动应用程序，并调用MessageSender的sendMessage方法发送消息。在发送消息后，MessageReceiver将接收到消息并打印消息内容。

示例三：使用WebSocket实现实时通信

1. 添加依赖

在pom.xml文件中添加以下依赖：

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

2. 创建WebSocket配置

创建一个名为WebSocketConfig的类，用于配置WebSocket。代码如下：

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) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/chat").withSockJS();
    }
}

在上面的代码中，我们定义了一个名为WebSocketConfig的类，用于配置WebSocket。在类中，我们使用@EnableWebSocketMessageBroker注解启用WebSocket支持，并实现了WebSocketMessageBrokerConfigurer接口。在configureMessageBroker方法中，我们配置了消息代理和应用程序前缀。在registerStompEndpoints方法中，我们注册了一个名为/chat的端点，并启用SockJS支持。

3. 创建WebSocket控制器

创建一个名为WebSocketController的控制器，用于处理WebSocket请求。代码如下：

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

@Controller
public class WebSocketController {

    @MessageMapping("/chat")
    @SendTo("/topic/messages")
    public String sendMessage(String message) {
        return message;
    }
}

在上面的代码中，我们定义了一个名为WebSocketController的控制器，用于处理WebSocket请求。在控制器中，我们使用@MessageMapping注解定义了一个消息映射，用于处理名为/chat的端点的请求。在方法中，我们使用@SendTo注解定义了一个消息发送目的地，用于将消息发送到名为/topic/messages的主题。

4. 创建前端页面

创建一个名为index.html的前端页面，用于显示聊天室界面。代码如下：

<!DOCTYPE html>
<html>
<head>
    <title>Chat Room</title>
    <script src="https://code.jquery.com/jquery-3.5.1.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/css/splide.min.css">
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@splidejs/splide@2.4.12/dist/js/splide.min.js"></script>
    <script src="/webjars/sockjs-client/1.0.2/sockjs.min.js"></script>
    <script src="/webjars/stomp-websocket/2.3.3/dist/stomp.min.js"></script>
    <script>
        var stompClient = null;

        function connect() {
            var socket = new SockJS('/chat');
            stompClient = Stomp.over(socket);
            stompClient.connect({}, function(frame) {
                console.log('Connected: ' + frame);
                stompClient.subscribe('/topic/messages', function(message) {
                    showMessage(JSON.parse(message.body));
                });
            });
        }

        function disconnect() {
            if (stompClient !== null) {
                stompClient.disconnect();
            }
            console.log("Disconnected");
        }

        function sendMessage() {
            var message = $("#message").val();
            stompClient.send("/app/chat", {}, message);
            $("#message").val("");
        }

        function showMessage(message) {
            var html = "<div>" + message + "</div>";
            $("#messages").append(html);
        }

        $(function() {
            connect();
            $("#send").click(sendMessage);
            $("#disconnect").click(disconnect);
        });
    </script>
</head>
<body>
    <div id="messages"></div>
    <input type="text" id="message">
    <button id="send">Send</button>
    <button id="disconnect">Disconnect</button>
</body>
</html>

在上面的代码中，我们定义了一个名为index.html的前端页面，用于显示聊天室界面。在页面中，我们使用jQuery、SockJS和Stomp.js库实现了WebSocket通信。在页面中，我们定义了一个connect函数，用于连接WebSocket服务器。在函数中，我们使用Stomp.js库创建了一个Stomp客户端，并在连接成功后订阅了/topic/messages主题。在页面中，我们定义了一个sendMessage函数，用于发送消息。在函数中，我们使用Stomp客户端发送消息到/app/chat目的地。在页面中，我们定义了一个showMessage函数，用于显示接收到的消息。在函数中，我们将消息添加到页面中的messages元素中。在页面中，我们使用jQuery绑定了send和disconnect按钮的点击事件，并在事件中调用了sendMessage和disconnect函数。

5. 启动应用程序

现在，我们可以启动应用程序，并访问http://localhost:8080/index.html页面。在页面中，我们可以输入用户名后加入聊天室，发送消息并接收其他用户的消息。