package foundation.send.sms;
|
|
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.ExecutionException;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.aliyun.auth.credentials.Credential;
|
import com.aliyun.auth.credentials.provider.StaticCredentialProvider;
|
import com.aliyun.sdk.service.dysmsapi20170525.AsyncClient;
|
import com.aliyun.sdk.service.dysmsapi20170525.models.SendSmsRequest;
|
import com.aliyun.sdk.service.dysmsapi20170525.models.SendSmsResponse;
|
import com.google.gson.Gson;
|
|
import darabonba.core.client.ClientOverrideConfiguration;
|
|
public class AliyunSMSProvider extends SmsProvider {
|
|
private static Logger logger;
|
private static AliyunSMSProvider instance;
|
|
static {
|
logger = LogManager.getLogger(AliyunSMSProvider.class);
|
}
|
|
public static synchronized AliyunSMSProvider getInstance() {
|
if (instance == null) {
|
instance = new AliyunSMSProvider();
|
}
|
|
return instance;
|
}
|
|
@Override
|
public String getName() {
|
logger.info("aliyun");
|
return "aliyun";
|
}
|
|
|
@Override
|
public void sendSms(SmsBuilder smsBuilder, SmsBuilderDetail smsBuilderDetail) throws Exception {
|
StaticCredentialProvider provider = StaticCredentialProvider.create(Credential.builder()
|
.accessKeyId(smsBuilder.getSmsConfig().getIdkey())
|
.accessKeySecret(smsBuilder.getSmsConfig().getSecretkey())
|
.build());
|
|
AsyncClient client = AsyncClient.builder()
|
.region(smsBuilder.getSmsConfig().getRegion())
|
.credentialsProvider(provider)
|
.overrideConfiguration(ClientOverrideConfiguration.create()
|
.setEndpointOverride(smsBuilder.getSmsConfig().getEndpoint()))
|
.build();
|
|
SendSmsRequest sendSmsRequest = SendSmsRequest.builder()
|
.signName(smsBuilderDetail.getSignName())
|
.templateCode(smsBuilderDetail.getTemplateCode())
|
.phoneNumbers(smsBuilder.getPhone())
|
.templateParam(smsBuilderDetail.getTemplateContent())
|
.build();
|
|
CompletableFuture<SendSmsResponse> response = client.sendSms(sendSmsRequest);
|
SendSmsResponse resp = response.get();
|
System.out.println(new Gson().toJson(resp));
|
client.close();
|
}
|
|
@Override
|
public void sendBatchSms(SmsBuilder smsBuilder, SmsBuilderDetail smsBuilderDetail) throws Exception {
|
|
}
|
|
public static void main(String[] args) throws InterruptedException, ExecutionException {
|
StaticCredentialProvider provider = StaticCredentialProvider.create(Credential.builder()
|
.accessKeyId("LTAI4G92tbAbpbN9eLbyFDdx")
|
.accessKeySecret("bbGYrr1oYQQf3MDA3yNOkZswxn8UBi")
|
.build());
|
|
AsyncClient client = AsyncClient.builder()
|
.region("cn-hangzhou")
|
.credentialsProvider(provider)
|
.overrideConfiguration(ClientOverrideConfiguration.create()
|
.setEndpointOverride("dysmsapi.aliyuncs.com"))
|
.build();
|
|
SendSmsRequest sendSmsRequest = SendSmsRequest.builder()
|
.signName("阿里云短信测试")
|
.templateCode("SMS_284995800")
|
.phoneNumbers("18350350522")
|
.templateParam("{\"code\":\"03521\"}")
|
.build();
|
|
CompletableFuture<SendSmsResponse> response = client.sendSms(sendSmsRequest);
|
SendSmsResponse resp = response.get();
|
System.out.println(new Gson().toJson(resp));
|
client.close();
|
}
|
|
|
|
|
}
|
