Springboot项目中，如何使用rabbitmq 实现，点赞、评论、关注系统通知

在Spring Boot项目中使用RabbitMQ实现点赞、评论、关注系统通知，可以按照以下步骤进行：

1. 安装RabbitMQ，并启动RabbitMQ服务。

2. 在项目中引入RabbitMQ相关依赖，可以通过Maven或Gradle等构建工具来实现，例如：

<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
    <version>2.2.10.RELEASE</version>
</dependency>

3. 创建RabbitMQ配置类，配置RabbitMQ连接信息和交换机、队列等信息。例如：

@Configuration
public class RabbitMQConfig {
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost("localhost");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setVirtualHost("/");
        connectionFactory.setPort(5672);
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate() {
        return new RabbitTemplate(connectionFactory());
    }

    @Bean
    public DirectExchange directExchange() {
        return new DirectExchange("exchange");
    }

    @Bean
    public Queue likeQueue() {
        return new Queue("like.queue");
    }

    @Bean
    public Queue commentQueue() {
        return new Queue("comment.queue");
    }

    @Bean
    public Queue followQueue() {
        return new Queue("follow.queue");
    }

    @Bean
    public Binding likeBinding() {
        return BindingBuilder.bind(likeQueue()).to(directExchange()).with("like");
    }

    @Bean
    public Binding commentBinding() {
        return BindingBuilder.bind(commentQueue()).to(directExchange()).with("comment");
    }

    @Bean
    public Binding followBinding() {
        return BindingBuilder.bind(followQueue()).to(directExchange()).with("follow");
    }
}

4. 在需要发送消息的地方，使用RabbitTemplate来发送消息。例如：

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendLikeMessage(String message) {
    rabbitTemplate.convertAndSend("exchange", "like", message);
}

public void sendCommentMessage(String message) {
    rabbitTemplate.convertAndSend("exchange", "comment", message);
}

public void sendFollowMessage(String message) {
    rabbitTemplate.convertAndSend("exchange", "follow", message);
}

5. 在需要接收消息的地方，创建对应的消息监听器，并使用@RabbitListener注解来监听队列。例如：

@Component
public class LikeMessageListener {
    @RabbitListener(queues = "like.queue")
    public void receiveLikeMessage(String message) {
        System.out.println("收到点赞消息：" + message);
        // 处理点赞消息
    }
}

@Component
public class CommentMessageListener {
    @RabbitListener(queues = "comment.queue")
    public void receiveCommentMessage(String message) {
        System.out.println("收到评论消息：" + message);
        // 处理评论消息
    }
}

@Component
public class FollowMessageListener {
    @RabbitListener(queues = "follow.queue")
    public void receiveFollowMessage(String message) {
        System.out.println("收到关注消息：" + message);
        // 处理关注消息
    }
}

通过以上步骤，就可以在Spring Boot项目中使用RabbitMQ实现点赞、评论、关注系统通知了。