基于Dubbo+RocketMQ+Springboot实现的低成本埋点系统打造

2024-01-11 16:11:56

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kMNc7LSy-1676421348098)]

在数字化的今天，企业对用户行为数据需求越来越旺盛。埋点系统作为一种重要的数据采集工具，可以帮助企业轻松地跟踪用户行为、分析数据并优化产品体验。目前市面上有很多埋点系统，但很多系统都价格昂贵、搭建复杂。本文将介绍如何利用Dubbo+RocketMQ+Springboot来搭建一个低成本、高效的埋点系统。

整体架构流程

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-s5mZNi24-1676421348099)]

整体架构流程：用户行为通过埋点上报到RocketMQ，然后由消费者消费数据并存储到数据库。

目录详情

consumer：消息消费者项目
provider：方法提供者项目
mq：RocketMQ项目
point：打点接口项目

关键代码详解

mq项目

mq.properties：配置RocketMQ的属性

mq.namesrvAddr=127.0.0.1:9876
mq.topic=point-topic

MqConfig.java：RocketMQ的配置类

@Configuration
public class MqConfig {

    @Value("${mq.namesrvAddr}")
    private String nameSrvAddr;

    @Value("${mq.topic}")
    private String topic;

    @Bean
    public MQProducer mqProducer() {
        DefaultMQProducer producer = new DefaultMQProducer("producer-group");
        producer.setNamesrvAddr(nameSrvAddr);
        producer.setRetryTimesWhenSendFailed(3);
        try {
            producer.start();
        } catch (MQClientException e) {
            e.printStackTrace();
        }
        return producer;
    }

    @Bean
    public MQConsumer mqConsumer() {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer-group");
        consumer.setNamesrvAddr(nameSrvAddr);
        consumer.subscribe(topic, "*");
        consumer.registerMessageListener(new MessageListenerConcurrently() {
            @Override
            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages, ConsumeConcurrentlyContext context) {
                // 消费消息
                for (MessageExt message : messages) {
                    String body = new String(message.getBody());
                    System.out.println("收到消息：" + body);
                }
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });
        try {
            consumer.start();
        } catch (MQClientException e) {
            e.printStackTrace();
        }
        return consumer;
    }
}