From 0b854ceb7d843476c3902eecd13495fffc0c5aaf Mon Sep 17 00:00:00 2001 From: msb_221930 <65ddd7e7> Date: Thu, 28 Mar 2024 18:23:35 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=8F=E9=99=A2=203.26=2018:22?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mashibing/cache/config/RedisConfig.java | 4 +- .../cache/controller/CacheController.java | 13 +++ beacon-monitor/pom.xml | 62 +++++++++++++ .../mashibing/monitor/MonitorStarterApp.java | 21 +++++ .../mashibing/monitor/client/CacheClient.java | 23 +++++ .../monitor/config/XxlJobConfig.java | 56 ++++++++++++ .../task/MonitorClientBalanceTask.java | 54 +++++++++++ .../task/MonitorQueueMessageCountTask.java | 90 +++++++++++++++++++ .../com/mashibing/monitor/task/TestTask.java | 20 +++++ .../com/mashibing/monitor/util/MailUtil.java | 63 +++++++++++++ .../src/main/resources/bootstrap.yml | 17 ++++ 11 files changed, 422 insertions(+), 1 deletion(-) create mode 100644 beacon-monitor/pom.xml create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/MonitorStarterApp.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/client/CacheClient.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/config/XxlJobConfig.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorClientBalanceTask.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorQueueMessageCountTask.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/task/TestTask.java create mode 100644 beacon-monitor/src/main/java/com/mashibing/monitor/util/MailUtil.java create mode 100644 beacon-monitor/src/main/resources/bootstrap.yml diff --git a/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java b/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java index 80a136c..296e0f4 100644 --- a/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java +++ b/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java @@ -23,6 +23,7 @@ import java.time.format.DateTimeFormatter; * @author zjw * @description */ + /* @Configuration @@ -77,4 +78,5 @@ public class RedisConfig { } -}*/ +} +*/ diff --git a/beacon-cache/src/main/java/com/mashibing/cache/controller/CacheController.java b/beacon-cache/src/main/java/com/mashibing/cache/controller/CacheController.java index 59bc159..57b0cc9 100644 --- a/beacon-cache/src/main/java/com/mashibing/cache/controller/CacheController.java +++ b/beacon-cache/src/main/java/com/mashibing/cache/controller/CacheController.java @@ -3,6 +3,7 @@ package com.mashibing.cache.controller; import com.msb.framework.redis.RedisClient; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ZSetOperations; import org.springframework.web.bind.annotation.*; @@ -19,6 +20,9 @@ public class CacheController { @Autowired private RedisClient redisClient; + @Autowired + private RedisTemplate redisTemplate; + @PostMapping(value = "/cache/hmset/{key}") public void hmset(@PathVariable(value = "key") String key, @RequestBody Map map) { @@ -146,4 +150,13 @@ public class CacheController { return result; } + @PostMapping(value = "/cache/keys/{pattern}") + public Set keys(@PathVariable(value = "pattern") String pattern) { + log.info("【缓存模块】 keys方法，根据pattren查询key的信息 pattern = {}", pattern); + Set keys = redisTemplate.keys(pattern); + log.info("【缓存模块】 keys方法，根据pattren查询key的信息 pattern = {},查询出全部的key信息 keys = {}", pattern, keys); + return keys; + } + + } diff --git a/beacon-monitor/pom.xml b/beacon-monitor/pom.xml new file mode 100644 index 0000000..ac20d2e --- /dev/null +++ b/beacon-monitor/pom.xml @@ -0,0 +1,62 @@ + + + + beacon-cloud + com.mashibing + 1.0-SNAPSHOT + + 4.0.0 + + beacon-monitor + + + + + org.springframework.boot + spring-boot-starter-web + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + com.mashibing + beacon-common + 1.0-SNAPSHOT + + + + + com.xuxueli + xxl-job-core + 2.3.1 + + + + + org.springframework.boot + spring-boot-starter-amqp + + + + org.springframework.cloud + spring-cloud-starter-openfeign + + + + org.springframework.boot + spring-boot-starter-mail + + + + + diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/MonitorStarterApp.java b/beacon-monitor/src/main/java/com/mashibing/monitor/MonitorStarterApp.java new file mode 100644 index 0000000..6679529 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/MonitorStarterApp.java @@ -0,0 +1,21 @@ +package com.mashibing.monitor; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.cloud.openfeign.EnableFeignClients; + +/** + * @author dch + * @create 2024-03-28 10:20 + */ +@SpringBootApplication +@EnableDiscoveryClient +@EnableFeignClients +public class MonitorStarterApp { + + public static void main(String[] args) { + SpringApplication.run(MonitorStarterApp.class,args); + } + +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/client/CacheClient.java b/beacon-monitor/src/main/java/com/mashibing/monitor/client/CacheClient.java new file mode 100644 index 0000000..a48bd91 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/client/CacheClient.java @@ -0,0 +1,23 @@ +package com.mashibing.monitor.client; + +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; + +import java.util.Map; +import java.util.Set; + +/** + * @author dch + * @create 2024-03-20 11:54 + */ +@FeignClient("beacon-cache") +public interface CacheClient { + + @PostMapping(value = "/cache/keys/{pattern}") + Set keys(@PathVariable(value = "pattern") String pattern); + + @GetMapping("/cache/hgetall/{key}") + Map hGetAll(@PathVariable(value = "key") String key); +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/config/XxlJobConfig.java b/beacon-monitor/src/main/java/com/mashibing/monitor/config/XxlJobConfig.java new file mode 100644 index 0000000..5cdd406 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/config/XxlJobConfig.java @@ -0,0 +1,56 @@ +package com.mashibing.monitor.config; + +import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @author dch + * @create 2024-03-28 11:08 + */ +@Configuration +@Slf4j +public class XxlJobConfig { + + + @Value("${xxl.job.admin.addresses}") + private String adminAddresses; + + @Value("${xxl.job.accessToken}") + private String accessToken; + + @Value("${xxl.job.executor.appname}") + private String appname; + + @Value("${xxl.job.executor.address}") + private String address; + + @Value("${xxl.job.executor.ip}") + private String ip; + + @Value("${xxl.job.executor.port}") + private int port; + + @Value("${xxl.job.executor.logpath}") + private String logPath; + + @Value("${xxl.job.executor.logretentiondays}") + private int logRetentionDays; + + + @Bean + public XxlJobSpringExecutor xxlJobExecutor() { + log.info(">>>>>>>>>>> xxl-job config init."); + XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); + xxlJobSpringExecutor.setAdminAddresses(adminAddresses); + xxlJobSpringExecutor.setAppname(appname); + xxlJobSpringExecutor.setIp(ip); + xxlJobSpringExecutor.setPort(port); + xxlJobSpringExecutor.setAccessToken(accessToken); + xxlJobSpringExecutor.setLogPath(logPath); + xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); + return xxlJobSpringExecutor; + } +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorClientBalanceTask.java b/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorClientBalanceTask.java new file mode 100644 index 0000000..5b5df86 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorClientBalanceTask.java @@ -0,0 +1,54 @@ +package com.mashibing.monitor.task; + +import com.mashibing.monitor.client.CacheClient; +import com.mashibing.monitor.util.MailUtil; +import com.xxl.job.core.handler.annotation.XxlJob; +import org.springframework.beans.factory.annotation.Autowired; + +import javax.mail.MessagingException; +import java.util.Map; +import java.util.Set; + +/** + * @author dch + * @create 2024-03-28 17:41 + */ +public class MonitorClientBalanceTask { + + //客户余额限制 小于500直接发送信息 + private final long balanceLimit = 500000; + + private final String CLIENT_BALANCE_PATTERN = "client_balance:*"; + + private final String BALANCE = "balance"; + + private final String EMAIL = "extend1"; + + private String text = "客户您好，您在【风火云短信平台】的短信余额仅剩%s元"; + + @Autowired + private CacheClient cacheClient; + + @Autowired + private MailUtil mailUtil; + + @XxlJob("monitorClientBalanceTask") + public void monitor() throws MessagingException { + //1.查询用户余额 + Set keys = cacheClient.keys(CLIENT_BALANCE_PATTERN); + + for (String key : keys) { + Map map = cacheClient.hGetAll(key); + Long balance = Long.parseLong(map.get(BALANCE)+""); + String email = (String) map.get(EMAIL); + //2.判断是否小于500，发送邮件 + if (balance < balanceLimit) { + mailUtil.sendEmail(email,"【风火云短信平台】提醒您余额不足",String.format(text,balance/1000)); + } + + } + + } + + +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorQueueMessageCountTask.java b/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorQueueMessageCountTask.java new file mode 100644 index 0000000..543a955 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/task/MonitorQueueMessageCountTask.java @@ -0,0 +1,90 @@ +package com.mashibing.monitor.task; + +import com.mashibing.common.constant.RabbitMQConstants; +import com.mashibing.monitor.client.CacheClient; +import com.mashibing.monitor.util.MailUtil; +import com.rabbitmq.client.Channel; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.rabbit.connection.Connection; +import org.springframework.amqp.rabbit.connection.ConnectionFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.mail.MessagingException; +import java.io.IOException; +import java.util.Set; + +/** + * 监控队列中的消息个数，如果队列消息超过10000条，直接发送短信，通知。 + * + * @author dch + * @create 2024-03-28 16:17 + */ +@Component +@Slf4j +public class MonitorQueueMessageCountTask { + + String text = "

您的队列消息队列堆积了，队名为%s，消息个数为%s"; + + // 队列消息限制 + private final long MESSAGE_COUNT_LIMIT = 10000; + + // 查询队列名称的固定pattern + private final String QUEUE_PATTERN = "channel:*"; + + // 得到需要截取channelID的索引地址 + private final int CHANNEL_ID_INDEX = QUEUE_PATTERN.indexOf("*"); + + // 注入RabbitMQ的ConnectionFactory + @Autowired + private ConnectionFactory connectionFactory; + + @Autowired + private CacheClient cacheClient; + + @Autowired + private MailUtil mailUtil; + + @XxlJob("monitorQueueMessageCountTask") + public void monitor() throws MessagingException { + //1、拿到所有的队列名称 + Set keys = cacheClient.keys(QUEUE_PATTERN); + + + //2、需要基于channel去操作 + Connection connection = connectionFactory.createConnection(); + Channel channel = connection.createChannel(false); + listenQueueAndSendEmail(channel, RabbitMQConstants.SMS_PRE_SEND); + for (String key : keys) { + // 封装队列名称 + String queueName = RabbitMQConstants.SMS_GATEWAY + key.substring(CHANNEL_ID_INDEX); + + listenQueueAndSendEmail(channel, queueName); + } + + } + + private void listenQueueAndSendEmail(Channel channel, String queueName) throws MessagingException { + // 队列不存在，直接构建，如果已经存在，直接忽略 + try { + channel.queueDeclare(queueName, true, false, false, null); + } catch (IOException e) { + e.printStackTrace(); + } + //3、拿到对应队列的消息，确认消息数量，超过限制，及时通知 + + long count = 0; + try { + count = channel.messageCount(queueName); + } catch (IOException e) { + e.printStackTrace(); + } + if (count > MESSAGE_COUNT_LIMIT) { + //4、通知的方式就是发送短信。 + mailUtil.sendEmail(queueName + "队列消息堆积", String.format(text, queueName, count)); + } + } + + +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/task/TestTask.java b/beacon-monitor/src/main/java/com/mashibing/monitor/task/TestTask.java new file mode 100644 index 0000000..5e0e6e9 --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/task/TestTask.java @@ -0,0 +1,20 @@ +package com.mashibing.monitor.task; + +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * @author dch + * @create 2024-03-28 15:57 + */ +@Component +@Slf4j +public class TestTask { + + @XxlJob("test") + public void test(){ + // 编写任务逻辑 + log.info("Hello World!"); + } +} diff --git a/beacon-monitor/src/main/java/com/mashibing/monitor/util/MailUtil.java b/beacon-monitor/src/main/java/com/mashibing/monitor/util/MailUtil.java new file mode 100644 index 0000000..60b23de --- /dev/null +++ b/beacon-monitor/src/main/java/com/mashibing/monitor/util/MailUtil.java @@ -0,0 +1,63 @@ +package com.mashibing.monitor.util; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.mail.javamail.JavaMailSender; +import org.springframework.mail.javamail.MimeMessageHelper; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import javax.mail.MessagingException; +import javax.mail.internet.MimeMessage; + +/** + * @author dch + * @create 2024-03-28 17:05 + */ +@Component +@RefreshScope +public class MailUtil { + + @Value("${spring.mail.username}") + private String from; + + @Value("${spring.mail.tos}") + private String tos; + +// @Autowired + @Resource + private JavaMailSender javaMailSender; + + + public void sendEmail(String subject,String text) throws MessagingException { + // 构建MimeMessage对象 + MimeMessage mimeMessage = javaMailSender.createMimeMessage(); + + // 给邮件指定信息 + MimeMessageHelper helper = new MimeMessageHelper(mimeMessage); + helper.setFrom(from); + helper.setTo(tos.split(",")); + helper.setSubject(subject); + helper.setText(text); + + // 发送邮件 + javaMailSender.send(mimeMessage); + } + + + public void sendEmail(String to, String subject, String text) throws MessagingException { + // 构建MimeMessage对象 + MimeMessage mimeMessage = javaMailSender.createMimeMessage(); + + // 给邮件指定信息 + MimeMessageHelper helper = new MimeMessageHelper(mimeMessage); + helper.setFrom(from); + helper.setTo(to); + helper.setSubject(subject); + helper.setText(text); + + // 发送邮件 + javaMailSender.send(mimeMessage); + } +} diff --git a/beacon-monitor/src/main/resources/bootstrap.yml b/beacon-monitor/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..de1397a --- /dev/null +++ b/beacon-monitor/src/main/resources/bootstrap.yml @@ -0,0 +1,17 @@ +# 服务名称 +spring: + application: + name: beacon-monitor + # 多环境 + profiles: + active: dev + # nacos注册中心地址 + cloud: + nacos: + discovery: + server-addr: 192.168.1.127:8848 + # nacos配置中心地址: + config: + server-addr: 192.168.1.127:8848 + file-extension: yml + # beacon-monitor-dev.yml