万商超信
短信微服务设计（springcloud全家桶都有哪些）
2021-12-13 11:44
二.RabbitMQ的模式
1.直接模式:
直接模式（Direct）：消息队列中数据，只能有唯一消费者消费。[短信微服务设计（springcloud全家桶都有哪些）]。
**rabbitMQ自带的Exchange：“”，直接模式不需要创建
**“RouteKey”，可以简单的理解为要发送到的队列名字
1、在RabbitMQ服务器根据情况手动创建交换器/队列，完成交换器跟队列绑定
2、编写生产者代码-测试-在管理页面中查询队列中数据
3、编写消费者代码-测试-监听到队列中数据
生产者:
生产消息:
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = RabbitMQApplication.class)
public class DirectProductTest {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testsend(){
rabbitTemplate.convertAndSend("itcast-queue-1","收到红包了吗");
}
}
消费者:
编写启动类
编写监听类:
@Component
@RabbitListener(queues = "itcast-queue-1")//指定监听哪个队列
public class ConsumerDirectListner {
//处理数据业务方法 方法参数跟生产者发送数据类型一致
@RabbitHandler
public void getMsg(String msg){
System.out.println("从itcast-queue-1获取到数据："+msg);
}
}
2.分裂模式Fanout
任何发送到Fanout Exchange的消息都会被转发到与该Exchange绑定(Binding)的所有Queue上。
1.可以理解为路由表的模式
2.这种模式不需要RouteKey
3.这种模式需要提前将Exchange与Queue进行绑定，一个Exchange可以绑定多个Queue，一个Queue可以同多个Exchange进行绑定。
4.如果接受到消息的Exchange没有与任何Queue绑定，则消息会被抛弃。
绑定后的结果
代码:
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testsend(){
// rabbitTemplate.convertAndSend("itcast-queue-1","收到红包了吗");
User user = new User();
user.setId("1");
user.setTelephone("123456");
user.setEmail("itcast@qq.com");
rabbitTemplate.convertAndSend("exange-ab","",user);
}
消费者:
@Component
@RabbitListener(queues = "itcast-queue-a")//指定监听哪个队列
public class ConsumerDirectListnerA {
//处理数据业务方法 方法参数跟生产者发送数据类型一致
@RabbitHandler
public void getMsg(User user){
System.out.println("从itcast-queue-a获取到数据："+user.getTelephone());
}
}
b同样
效果图
3.主题模式Topic
任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue上如上图所示
创建队列和交换器:
1.创建队列
2.创建交换器
3.设置路由绑定
生产者:
rabbitTemplate.convertAndSend("exange-xyz","user.abc","这是user.abc的信息");
rabbitTemplate.convertAndSend("exange-xyz","user.log","这是user.log的信息");
rabbitTemplate.convertAndSend("exange-xyz","login.log","这是login.log的信息");
消费者:
@Component
@RabbitListener(queues = "itcast-queue-x")//指定监听哪个队列
public class ConsumerDirectListnerX {
//处理数据业务方法 方法参数跟生产者发送数据类型一致
@RabbitHandler
public void getMsg(String msg){
System.out.println("从itcast-queue-x获取到数据："+msg);
}
}
zy同样
结果:
三.用户微服务
需求分析:
通过这个实现,消息的生产者,生成验证码,存入到redis中并发送到rabbitMQ中
实现步骤:
1.首先我们在userService中是添加一个方法,用于发送消息
代码:
@Autowired
private RabbitTemplate rabbitTemplate;
@Autowired
private RedisTemplate redisTemplate;
/**
* 发送验证码
*/
public void sendSms(String mobile){
//TODO 生成验证码
String checkcode = RandomStringUtils.randomNumeric(4);
//输出
System.out.println("验证码为:"+checkcode);
//使用阿里云发送短信
Map<String ,String> map = new HashMap<>();
map.put("mobile",mobile);
map.put("templateCode","SMS_23423423");
//根据短信模板中的参数进行
Map<String,String> mapParams = new HashMap<>();
mapParams.put("code",checkcode);
//根据短信的动态参数,进行解析
String templateJsonParse = JSON.toJSONString(mapParams);
map.put("templateJsonParse",templateJsonParse);
rabbitTemplate.convertAndSend("","itcast-sms",map);
//将redis存储5分钟
redisTemplate.opsForValue().set(mobile,checkcode,5, TimeUnit.MINUTES);
}
编写用户的注册开发:
service层
/**
* 用户的注册
*/
public void register(User user,String code){
//首先我们判断验证码是否正确
String checkCode = (String) redisTemplate.opsForValue().get(user.getMobile());
//判断是否为空
if (checkCode==null){
throw new RuntimeException("验证码未发送或者已过期");
}
//判断输入的验证码是否与redis中验证码相同
if (!code.equals(checkCode)){
throw new RuntimeException("验证码填写不正确");
}
user.setId(idWorker.nextId()+"");//主键值
user.setFanscount(0);//粉丝数
user.setFollowcount(0);//关注数
user.setOnline(0L);//在线时长
user.setRegdate(new Date());//注册日期
user.setUpdatedate(new Date());//更新日期
userDao.save(user);
}
controller层:
/**
* 发送验证码
*/
@PostMapping("/sendsms/{mobile}")
public Result sendSms(@PathVariable String mobile){
userService.sendSms(mobile);
return new Result(true,StatusCode.OK,"发送验证码成功");
}
/**
* 用户的注册
*/
@PostMapping("/register/{code}")
public Result register(@PathVariable String code,@RequestBody User user){
userService.register(user,code);
return new Result(true,StatusCode.OK,"注册成功");
}
四.短信微服务开发
需求分析:
我们通过rabbitmq中提取消息,然后调用阿里大鱼短信接口,这里主要是消息的消费者
步骤:
1.创建tensquare_sms微服务工程,导入阿里云的依赖
2.编写配置文件,以及启动类
3.编写监听类
@Component
@RabbitListener(queues = "itcast-sms")
public class SmsListener {
@Autowired
private SmsUtil smsUtil;
/**
* 发送短信
*/
@RabbitHandler
public void sendSms(Map<String,String> message){
try {
//System.out.println("手机号:"+message.get("mobile"));
//System.out.println("验证码:"+message.get("code"));
String mobile = message.get("mobile");
String templateJsonParse = message.get("templateJsonParse");
String templateCode = message.get("templateCode");
System.out.println(mobile+" "+templateJsonParse+" "+ templateCode);
SendSmsResponse sendSmsResponse = smsUtil.sendSms(mobile, templateCode, templateJsonParse);
System.out.println(sendSmsResponse.getMessage());
} catch (ClientException e) {
e.printStackTrace();
}
}
}
sms工具类
package com.tensquare.sms.util;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
/**
* @program: tensquare-72
* @description:
**/
@Component
public class SmsUtil {
@Value("${aliyun.config.accessKeyId}")
private String accessKeyId;
@Value("${aliyun.config.accessKeySecret}")
private String accessKeySecret;
@Value("${aliyun.config.signName}")
private String signName;
//产品名称:云通信短信API产品,开发者无需替换
static final String product = "Dysmsapi";
//产品域名,开发者无需替换
static final String domain = "dysmsapi.aliyuncs.com";
/**
* 发送短信工具方法
*
* @return
* @throws ClientException
*/
public SendSmsResponse sendSms(String tel, String tempalteCode, String templateParamsJson) throws ClientException {
SendSmsResponse sendSmsResponse = null;
//可自助调整超时时间
System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
System.setProperty("sun.net.client.defaultReadTimeout", "10000");
//初始化acsClient,暂不支持region化
IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
IAcsClient acsClient = new DefaultAcsClient(profile);
//组装请求对象-具体描述见控制台-文档部分内容
SendSmsRequest request = new SendSmsRequest();
//TODO 必填:待发送手机号
request.setPhoneNumbers(tel);
//必填:短信签名-可在短信控制台中找到
request.setSignName(signName);
//TODO 必填:短信模板-可在短信控制台中找到
request.setTemplateCode(tempalteCode);
//TODO 可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
request.setTemplateParam(templateParamsJson);
//选填-上行短信扩展码(无特殊需求用户请忽略此字段)
//request.setSmsUpExtendCode("90997");
//可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
request.setOutId("yourOutId");
//hint 此处可能会抛出异常，注意catch
sendSmsResponse = acsClient.getAcsResponse(request);
System.out.println(sendSmsResponse.getMessage());
return sendSmsResponse;
}
}
