代码详细点说明：java后端做一个运维监控，中台接口要能记录服务调用次数，服务调用来源 ，自定义注解，发送消息到MQ，数据交互平台从MQ消费消息，插入到数据库

好的，下面是一个简单的代码示例，用于说明如何实现一个基于Java后端的运维监控系统，它可以记录服务调用次数、调用来源等信息，并将这些信息发送到MQ，最后通过消费者程序将其插入到数据库中。

首先，我们定义一个注解@Monitor，用来标记需要进行监控的方法。在该注解中，我们可以定义一些属性，例如方法名称、调用来源等信息。

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface Monitor {
    String name(); // 方法名称
    String source() default "unknown"; // 调用来源
}

接下来，我们可以定义一个切面类，用来处理被@Monitor注解标记的方法。在该切面类中，我们可以使用AOP技术，在方法调用前后进行处理，记录相关信息。

@Aspect
@Component
public class MonitorAspect {
    private static final Logger logger = LoggerFactory.getLogger(MonitorAspect.class);

    @Autowired
    private AmqpTemplate amqpTemplate;

    @Pointcut("@annotation(com.example.monitor.annotation.Monitor)")
    public void monitorPointcut() {}

    @Around("monitorPointcut()")
    public Object monitorAround(ProceedingJoinPoint joinPoint) throws Throwable {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        Monitor monitor = method.getAnnotation(Monitor.class);

        // 记录调用次数、调用来源等信息
        String methodName = monitor.name();
        String source = monitor.source();
        logger.info("Method {} called from {}", methodName, source);

        // 发送消息到MQ
        Message message = MessageBuilder.withPayload(methodName)
                .setHeader("source", source)
                .build();
        amqpTemplate.convertAndSend("monitor-exchange", "monitor-routing-key", message);

        // 调用原始方法
        return joinPoint.proceed();
    }
}

在切面类中，我们使用了@Around注解来表示该方法会在被@Monitor注解标记的方法调用前后执行。在方法中，首先获取被@Monitor注解标记的方法的名称和调用来源等信息，然后记录这些信息并将它们发送到MQ中。

接下来，我们需要定义一个MQ消息的消费者，用来从MQ中消费消息并将它们插入到数据库中。在该消费者中，我们可以使用Spring AMQP框架来简化消息的处理过程。

@Component
public class MonitorConsumer {
    private static final Logger logger = LoggerFactory.getLogger(MonitorConsumer.class);

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @RabbitListener(queues = "monitor-queue")
    public void handleMessage(Message message) {
        String methodName = new String(message.getBody());
        String source = message.getMessageProperties().getHeader("source");

        // 将消息插入到数据库中
        String sql = "INSERT INTO monitor_log (method_name, source) VALUES (?, ?)";
        jdbcTemplate.update(sql, methodName, source);

        logger.info("Received message from MQ: method={}, source={}", methodName, source);
    }
}

在消费者中，我们使用了@RabbitListener注解来表示该方法会监听指定的MQ队列。当有消息到达时，该方法会被自动调用，我们可以在方法中获取消息的内容和相关信息，并将它们插入到数据库中。

最后，我们需要在应用程序中使用@Monitor注解来标记需要进行监控的方法。例如：

@Service
public class UserService {
    @Monitor(name = "getUser", source = "web")
    public User getUser(Long userId) {
        // ...
    }
}

通过以上步骤，我们就可以实现一个基于Java后端的运维监控系统，它可以记录服务调用次数、调用来源等信息，并将这些信息发送到MQ，最后通过消费者程序将其插入到数据库中。