diff --git a/msgpush-module-push/msgpush-module-push-server/pom.xml b/msgpush-module-push/msgpush-module-push-server/pom.xml index 3b52875..a393ced 100644 --- a/msgpush-module-push/msgpush-module-push-server/pom.xml +++ b/msgpush-module-push/msgpush-module-push-server/pom.xml @@ -18,10 +18,10 @@ - - - - + + com.njcn + msgpush-spring-boot-starter-env + diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/PushServerApplication.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/PushServerApplication.java index 0643662..8d34da9 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/PushServerApplication.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/PushServerApplication.java @@ -4,6 +4,7 @@ import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.ComponentScan; +import org.springframework.scheduling.annotation.EnableScheduling; /** * 项目的启动类 @@ -13,6 +14,7 @@ import org.springframework.context.annotation.ComponentScan; @ComponentScan(basePackages = {"com.njcn.msgpush.module.push", "com.njcn.msgpush.framework.mybatis"}) @MapperScan("com.njcn.msgpush.module.*.dal.mysql") @SpringBootApplication +@EnableScheduling public class PushServerApplication { public static void main(String[] args) { SpringApplication.run(PushServerApplication.class, args); diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/Sender.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/Sender.java index cb0d3c9..b78b884 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/Sender.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/Sender.java @@ -1,22 +1,12 @@ package com.njcn.msgpush.module.push.client.sender; -import cn.hutool.core.util.ObjectUtil; -import com.njcn.msgpush.module.push.client.factory.MessageProviderFactory; -import com.njcn.msgpush.module.push.constant.MessageStatusConstant; -import com.njcn.msgpush.module.push.constant.MsgPushConstant; -import com.njcn.msgpush.module.push.dal.dataobject.channel.ChannelProviderConfigDO; -import com.njcn.msgpush.module.push.dal.dataobject.message.MessageRecordDO; -import com.njcn.msgpush.module.push.dal.mysql.message.MessageRecordMapper; import com.njcn.msgpush.module.push.service.channel.ChannelProviderConfigService; import com.njcn.msgpush.module.push.service.channel.ProviderErrorCodeMappingService; import com.njcn.msgpush.module.push.service.retry.MessageRetryQueueService; import com.njcn.msgpush.module.push.util.RestTemplateUtil; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Component; -import java.util.HashMap; -import java.util.Map; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; @@ -36,7 +26,7 @@ public class Sender { @Autowired public RestTemplateUtil restTemplateUtil; - public final ThreadPoolExecutor THREAD_POOL_EXECUTOR = new ThreadPoolExecutor( + public final ThreadPoolExecutor MSG_PUSH_THREAD_POOL_EXECUTOR = new ThreadPoolExecutor( 5, 5, 1000, @@ -44,7 +34,7 @@ public class Sender { new java.util.concurrent.ArrayBlockingQueue<>(1000), r -> { Thread thread = new Thread(r); - thread.setName("threadName-" + thread.getId()); + thread.setName("msgPushThreadPool-" + thread.getId()); thread.setDaemon(false); return thread; }, diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/AliyunSmsSender.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/AliyunSmsSender.java index d5577aa..e882999 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/AliyunSmsSender.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/AliyunSmsSender.java @@ -35,21 +35,6 @@ public class AliyunSmsSender implements SmsSender { private Client smsClient; -// private final ThreadPoolExecutor THREAD_POOL_EXECUTOR = new ThreadPoolExecutor( -// 5, -// 5, -// 1000, -// TimeUnit.MILLISECONDS, -// new java.util.concurrent.ArrayBlockingQueue<>(1000), -// r -> { -// Thread thread = new Thread(r); -// thread.setName("AliyunSmsSender-Pool-" + thread.getId()); -// thread.setDaemon(false); -// return thread; -// }, -// new ThreadPoolExecutor.CallerRunsPolicy() -// ); - public AliyunSmsSender(AliYunMailSetting aliYunSmsSetting, Sender sender) { this.sender = sender; if (ObjectUtil.isNotNull(aliYunSmsSetting)) { @@ -70,7 +55,7 @@ public class AliyunSmsSender implements SmsSender { @Override public boolean sendSms(MessageRecordDO message) { - Future future = this.sender.THREAD_POOL_EXECUTOR.submit(() -> { + Future future = this.sender.MSG_PUSH_THREAD_POOL_EXECUTOR.submit(() -> { message.setStatus(MessageStatusConstant.SENDING); RuntimeOptions runtimeOptions = new RuntimeOptions(); // 设置自动重试，默认是不开启的。重试次数默认是3次 diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/TelecomSmsSender.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/TelecomSmsSender.java index 9408345..c643636 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/TelecomSmsSender.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/client/sender/impl/TelecomSmsSender.java @@ -1,5 +1,6 @@ package com.njcn.msgpush.module.push.client.sender.impl; +import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSON; import com.njcn.msgpush.module.push.client.sender.Sender; import com.njcn.msgpush.module.push.client.sender.SmsSender; @@ -15,10 +16,13 @@ import org.springframework.http.ResponseEntity; import java.time.LocalDateTime; import java.time.ZoneId; +import java.time.format.DateTimeFormatter; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.Executors; import java.util.concurrent.Future; +import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; /** @@ -35,15 +39,22 @@ public class TelecomSmsSender implements SmsSender { private TelecomSmsSetting telecomSmsSetting; private Sender sender; + /** + * 存放发送完成的消息。key为其返回的mid + */ + private Map completeSendMessageMap = new HashMap<>(); + + private ScheduledExecutorService scheduledExecutorService; + @Data - private static class TelecomSmsResponse { + private static class TelecomSmsSendResponse { private String status; private Double balance; - private List list; + private List list; } @Data - private static class TelecomSmsMessageRes { + private static class TelecomSmsSendDetailRes { //消息ID（用于状态报告匹配） private String mid; //手机号码 @@ -52,6 +63,22 @@ public class TelecomSmsSender implements SmsSender { private Integer result; } + @Data + private static class TelecomSmsSelectResponse { + private String status; + private Double balance; + private List list; + } + + @Data + private static class TelecomSmsSelectDetailRes { + private String apmid; + private String apSubmitTime; + private String mobile; + private Integer status; + private String stat; + private String deliverTime; + } public TelecomSmsSender(TelecomSmsSetting telecomSmsSetting, Sender sender) { this.telecomSmsSetting = telecomSmsSetting; @@ -60,7 +87,7 @@ public class TelecomSmsSender implements SmsSender { @Override public boolean sendSms(MessageRecordDO message) { - Future future = this.sender.THREAD_POOL_EXECUTOR.submit(() -> { + Future future = this.sender.MSG_PUSH_THREAD_POOL_EXECUTOR.submit(() -> { message.setStatus(MessageStatusConstant.SENDING); // 构建请求参数 Map request = new HashMap<>(); @@ -79,22 +106,32 @@ public class TelecomSmsSender implements SmsSender { long start = now.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli(); message.setSendTime(now); // 发送请求 - ResponseEntity response = this.sender.restTemplateUtil.post( + ResponseEntity response1 = this.sender.restTemplateUtil.post( telecomSmsSetting.getApiUrl(), request, headers, String.class ); - System.out.println(JSON.toJSONString(response)); LocalDateTime end = LocalDateTime.now(); message.setCostTime((int) (end.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli() - start)); - TelecomSmsResponse telecomSmsResponse = JSON.parseObject(response.getBody(), TelecomSmsResponse.class); + TelecomSmsSendResponse telecomSmsSendResponse = JSON.parseObject(response1.getBody(), TelecomSmsSendResponse.class); - if (response.getStatusCode() == HttpStatus.OK && telecomSmsResponse.list.get(0).result == 0) { + if (response1.getStatusCode() == HttpStatus.OK) { + String mid = telecomSmsSendResponse.list.get(0).mid; + completeSendMessageMap.put(mid, message); + // 定时任务，指定时间间隔后获取下行信息 + if (ObjectUtil.isNull(this.scheduledExecutorService)) { + this.scheduledExecutorService = Executors.newScheduledThreadPool(1); + } + this.scheduledExecutorService.schedule(() -> { + this.getDownInfo(mid); + this.scheduledExecutorService.shutdown(); + this.scheduledExecutorService = null; + }, 2, TimeUnit.SECONDS); return true; } else { - ProviderErrorCodeMappingDO providerErrorCodeMappingDO = this.sender.providerErrorCodeMappingService.getByProviderErrorCode(message.getProviderType(), message.getChannel(), telecomSmsResponse.list.get(0).result + ""); - message.setErrorCode(telecomSmsResponse.list.get(0).result + ""); + ProviderErrorCodeMappingDO providerErrorCodeMappingDO = this.sender.providerErrorCodeMappingService.getByProviderErrorCode(message.getProviderType(), message.getChannel(), telecomSmsSendResponse.list.get(0).result + ""); + message.setErrorCode(telecomSmsSendResponse.list.get(0).result + ""); message.setErrorMsg(providerErrorCodeMappingDO.getOriginalMessage()); this.sender.messageRetryQueueService.addRetryMessage(message, RetryStrategyEnum.EXPONENTIAL_BACKOFF); return false; @@ -144,11 +181,57 @@ public class TelecomSmsSender implements SmsSender { message.setSendTime(now); message.setCostTime((int) (end.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli() - start)); } - TelecomSmsResponse telecomSmsResponse = JSON.parseObject(response.getBody(), TelecomSmsResponse.class); + TelecomSmsSendResponse telecomSmsSendResponse = JSON.parseObject(response.getBody(), TelecomSmsSendResponse.class); boolean res = true; - for (TelecomSmsMessageRes telecomSmsMessageRes : telecomSmsResponse.list) { - res &= telecomSmsMessageRes.result == 0; + for (TelecomSmsSendDetailRes telecomSmsSendDetailRes : telecomSmsSendResponse.list) { + res &= telecomSmsSendDetailRes.result == 0; } return res; } + + /** + * 获取下行信息 + * + * @param mid + */ + private void getDownInfo(String mid) { + System.out.println("getDownInfo" + LocalDateTime.now()); + // 构建请求参数 + Map request = new HashMap<>(); + request.put("action", "select"); + request.put("account", telecomSmsSetting.getAccount()); + request.put("password", telecomSmsSetting.getPassword()); + request.put("date", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"))); + request.put("condition", "APMID"); + request.put("valueList", mid); +// request.put("condition", "MOBILE"); +// request.put("valueList", message.getReceiver()); + request.remove("mobile"); + request.remove("content"); + // 设置请求头 + HttpHeaders headers = new HttpHeaders(); + headers.set("Content-Type", CONTENT_TYPE); + ResponseEntity response = this.sender.restTemplateUtil.post( + telecomSmsSetting.getApiUrl(), + request, + headers, + String.class + ); + System.out.println(JSON.toJSONString(response.getBody())); + + if (response.getStatusCode() == HttpStatus.OK) { + TelecomSmsSelectResponse telecomSmsSelectResponse = JSON.parseObject(response.getBody(), TelecomSmsSelectResponse.class); + TelecomSmsSelectDetailRes telecomSmsSelectDetailRes = telecomSmsSelectResponse.list.get(0); + if (telecomSmsSelectDetailRes.getStatus() == 4) { + return; + } else if (telecomSmsSelectDetailRes.getStatus() == 5) { + MessageRecordDO message = completeSendMessageMap.get(mid); + ProviderErrorCodeMappingDO providerErrorCodeMappingDO = this.sender.providerErrorCodeMappingService.getByProviderErrorCode(message.getProviderType(), message.getChannel(), telecomSmsSelectDetailRes.getStat()); + message.setErrorCode(telecomSmsSelectDetailRes.getStat()); + message.setErrorMsg(providerErrorCodeMappingDO.getOriginalMessage()); + this.sender.messageRetryQueueService.addRetryMessage(message, RetryStrategyEnum.EXPONENTIAL_BACKOFF); + completeSendMessageMap.remove(mid); + } + } + } } diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/MessageRecordController.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/MessageRecordController.java index cfc0d19..a01f6d5 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/MessageRecordController.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/MessageRecordController.java @@ -10,6 +10,7 @@ import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.annotation.security.PermitAll; +import jakarta.validation.Valid; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.access.prepost.PreAuthorize; @@ -25,7 +26,6 @@ import static com.njcn.msgpush.framework.common.pojo.CommonResult.success; @Tag(name = "管理后台 - 消息") @Slf4j -@Validated @RestController @RequestMapping("/push/message") public class MessageRecordController { @@ -34,10 +34,10 @@ public class MessageRecordController { private MessageRecordService messageRecordService; @PermitAll - @PostMapping("send") + @PostMapping("/send") @Operation(summary = "消息推送") - @Parameter(name = "id", description = "编号", required = true, example = "1024") - public CommonResult send(@Validated @RequestBody List reqVOList) { + @Parameter(name = "reqVOList", description = "消息列表") + public CommonResult send(@Valid @RequestBody List reqVOList) { Boolean result = messageRecordService.send(reqVOList); return CommonResult.success(result); } diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/vo/MessageRecordReqVO.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/vo/MessageRecordReqVO.java index fdf8d20..9009bd5 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/vo/MessageRecordReqVO.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/vo/MessageRecordReqVO.java @@ -31,7 +31,7 @@ public class MessageRecordReqVO extends PageParam { @NotBlank(message = "消息类型不能为空") private String messageType; - @Schema(description = "接收者", requiredMode = Schema.RequiredMode.REQUIRED, example = "15601691300") + @Schema(description = "接收者", requiredMode = Schema.RequiredMode.REQUIRED) @NotBlank(message = "接收者不能为空") private String receiver; diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/job/MessageRetryJob.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/job/MessageRetryJob.java index 4c28081..8a74a99 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/job/MessageRetryJob.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/job/MessageRetryJob.java @@ -6,6 +6,8 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import java.time.LocalDateTime; + /** * @author caozehui * @date 2026-02-27 diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/channel/ChannelProviderConfigServiceImpl.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/channel/ChannelProviderConfigServiceImpl.java index d6494d7..99e3ffc 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/channel/ChannelProviderConfigServiceImpl.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/channel/ChannelProviderConfigServiceImpl.java @@ -8,6 +8,7 @@ import com.njcn.msgpush.module.push.controller.admin.channel.vo.ChannelProviderC import com.njcn.msgpush.module.push.dal.dataobject.channel.ChannelProviderConfigDO; import com.njcn.msgpush.module.push.dal.mysql.channel.ChannelProviderConfigMapper; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; import java.util.List; @@ -42,6 +43,7 @@ public class ChannelProviderConfigServiceImpl extends ServiceImpl(1000), + r -> { + Thread thread = new Thread(r); + thread.setName("msgRetryThreadPool-" + thread.getId()); + thread.setDaemon(false); + return thread; + }, + new ThreadPoolExecutor.CallerRunsPolicy() + ); + /** * 默认每次处理的消息数量 */ @@ -80,7 +99,6 @@ public class MessageRetryQueueServiceImpl extends ServiceImpl retryMessages = retryQueueMapper.selectNeedRetryMessages(LocalDateTime.now(), DEFAULT_BATCH_SIZE); @@ -149,20 +167,33 @@ public class MessageRetryQueueServiceImpl extends ServiceImpl sendFuture = CompletableFuture.supplyAsync(() -> + messageRecordService.processSendMsg(messageRecordDO), MSG_RETRY_THREAD_POOL_EXECUTOR + ); - if (sendResult) { - // 重试成功，删除重试记录 - super.baseMapper.deleteByMessageId(messageRecordDO.getMessageId()); - messageRetryRedisDAO.removeFromRetryQueue(messageRecordDO.getChannel(), messageRecordDO.getMessageId()); - - log.info("消息重试成功并已清除: messageId={}", messageRecordDO.getMessageId()); - } else { - // 重试失败，更新重试信息 - channelProviderConfigService.failureUpdate(messageRecordDO.getProviderType(), messageRecordDO.getChannel()); - handleRetryFailure(messageRecordDO); - } + sendFuture.orTimeout(5, TimeUnit.SECONDS) + .thenAccept(sendResult -> { + if (sendResult) { + log.info("处理消息重试成功逻辑：messageId={}", messageRecordDO.getMessageId()); + super.baseMapper.deleteByMessageId(messageRecordDO.getMessageId()); + messageRetryRedisDAO.removeFromRetryQueue(messageRecordDO.getChannel(), messageRecordDO.getMessageId()); + } else { + // 重试失败，更新重试信息 + log.error("处理消息重试失败逻辑：messageId={}", messageRecordDO.getMessageId()); + channelProviderConfigService.failureUpdate(messageRecordDO.getProviderType(), messageRecordDO.getChannel()); + handleRetryFailure(messageRecordDO); + } + }).exceptionally(ex -> { + log.error("异步执行消息重试发生异常：messageId={}", messageRecordDO.getMessageId(), ex); + // 发生异常时也尝试处理失败逻辑，避免消息丢失 + try { + handleRetryFailure(messageRecordDO); + } catch (Exception e) { + log.error("异常处理后再次失败：messageId={}", messageRecordDO.getMessageId(), e); + } + return null; + }); } /** diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/resources/application.yaml b/msgpush-module-push/msgpush-module-push-server/src/main/resources/application.yaml index 6358733..d578ffe 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/resources/application.yaml +++ b/msgpush-module-push/msgpush-module-push-server/src/main/resources/application.yaml @@ -106,20 +106,5 @@ msgpush: debug: false -aliyun: - sms: - access-key-id: LTAI4FxsR76x2dq3w9c5puUe - access-key-secret: GxkTR8fsrvHtixTlD9UPmOGli35tZs - regionId: cn-hangzhou - endpoint: dysmsapi.aliyuncs.com - mail: - access-key-id: LTAI4FxsR76x2dq3w9c5puUe - access-key-secret: GxkTR8fsrvHtixTlD9UPmOGli35tZs - regionId: cn-hangzhou - endpoint: dm.aliyuncs.com -telecom: - sms: - account: 925631 - password: AMW2pOVrdky diff --git a/msgpush-module-push/msgpush-module-push-server/src/test/java/com/njcn/msgpush/module/push/sms/MsgPushClientTest.java b/msgpush-module-push/msgpush-module-push-server/src/test/java/com/njcn/msgpush/module/push/sms/MsgPushClientTest.java index eaf5d31..87d84d0 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/test/java/com/njcn/msgpush/module/push/sms/MsgPushClientTest.java +++ b/msgpush-module-push/msgpush-module-push-server/src/test/java/com/njcn/msgpush/module/push/sms/MsgPushClientTest.java @@ -7,10 +7,12 @@ import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.scheduling.annotation.EnableScheduling; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.List; +import java.util.UUID; /** * @author caozehui @@ -18,13 +20,14 @@ import java.util.List; */ @Slf4j @SpringBootTest +@EnableScheduling public class MsgPushClientTest { @Autowired private MessageRecordService messageRecordService; @Test - public void testSend() { + public void testSend() throws InterruptedException { List messageIdList = new ArrayList<>(); // for (int i = 0; i < 5; i++) { // MessageRecordReqVO message = new MessageRecordReqVO(); @@ -40,7 +43,7 @@ public class MsgPushClientTest { // } for (int i = 0; i < 1; i++) { MessageRecordReqVO message = new MessageRecordReqVO(); - message.setMessageId(i + "2345dc"); + message.setMessageId(String.valueOf(UUID.randomUUID())); message.setAppName("NPQS-9000"); message.setChannel(MsgPushConstant.CHANNEL_SMS); message.setReceiver("18839431215"); @@ -49,11 +52,8 @@ public class MsgPushClientTest { messageIdList.add(message); } boolean sendResult = messageRecordService.send(messageIdList); + + Thread.sleep(9000); System.out.println(sendResult); } - - @Test - public void test() { - - } }