记录一次发送千万级别数量消息的定时任务优化
这样一来 for 循环中负责 1-5001 的那个线程其实只有一个用户任务需要处理,也就是说总共 4 个线程,1 个线程执行任务是 0.5 秒 ,其余三个线程可能要十几分钟。
图解 Kafka 源码实现机制之客户端缓存架构
一、总体概述通过场景驱动的方式,当被发送消息通过网络请求封装、NIO多路复用器监听网络读写事件并进行消息网络收发后,回头来看看消息是如何在客户端缓存的?大家都知道 Kafka 是一款超高吞吐量的消息系统,主要体现在「异步发送」、「批量发送」、「消息压缩」。
面试官:熟悉RocketMQ,那聊聊发送普通消息几种方式?3张图拿下
原理:同步发送是指消息发送方发出数据后,会在收到接收方发回响应之后才发下一个数据包的通讯方式。应用场景:此种方式应用场景非常广泛,例如重要通知邮件、报名短信通知、营销短信系统等。
springboot + rabbitmq发送邮件(保证消息100%投递成功并被消费)
一、先扔一张图image.png说明:本文涵盖了关于RabbitMQ很多方面的知识点,如:消息发送确认机制消费确认机制消息的重新投递消费幂等性, 等等这些都是围绕上面那张整体流程图展开的, 所以有必要先贴出来, 见图知意二、实现思路简略介绍163邮箱授权码的获取编写发送邮件工具类
javaMailSender发送邮件
javaMailSender发送邮件应用场景在一些项目中,可能要用到报警提醒。常见的报警提醒有发送短信和发送邮件,由于发送短信需要对接第三方api且需要付费,这篇文章将介绍如何使用java实现发送邮件,包括发送普通文本邮件、普通html格式的邮件、配置模板的html格式邮件。