一、手机发送验证码流程：

image.png

二、定义用户服务，完成短信发送：

2.1 zyg-user-service工程添加如下依赖：

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter-web</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>com.zelin</groupId>
  8.             <artifactId>zyg-user-interface</artifactId>
  9.             <version>2.0</version>
  10.         </dependency>
  11.         <dependency>
  12.             <groupId>com.zelin</groupId>
  13.             <artifactId>zyg-dao</artifactId>
  14.             <version>2.0</version>
  15.         </dependency>
  16.         <dependency>
  17.             <groupId>org.springframework.boot</groupId>
  18.             <artifactId>spring-boot-starter-data-redis</artifactId>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-activemq</artifactId>
  23.         </dependency>
  24.     </dependencies>

2.2 zyg-user-service工程application.yml文件：

  1. server:
  2.   port: 7005
  4. spring:
  5.   dubbo:
  6.     protocol:
  7.       name: dubbo
  8.       port: 20885
  9.     registry:
  10.       address: zookeeper://192.168.56.10:2181
  11.     base-package: com.zelin.user.service.impl
  12.     application:
  13.       name: zyg-user-service
  14.   redis:
  15.     host: 192.168.56.10
  16.   activemq:
  17.     broker-url: tcp://192.168.56.10:61616
  18.     packages:
  19.       trust-all: true
  20. logging:
  21.   level:
  22.     com.zelin: debug

2.3 生成验证码并发送信息给activemq：

  1. @Service
  2. public class UserServiceImpl implements UserService {
  3.     @Autowired
  4.     private StringRedisTemplate redisTemplate;
  5.     @Autowired
  6.     private JmsMessagingTemplate jmsMessagingTemplate;
  8.     //1. 生成验证码并发送消息
  9.     @Override
  10.     public void getCode(String phone) {
  12.         //1.1 生成六位数的验证码
  13.         String code =  (long) (Math.random()*1000000)+"";
  14.         System.out.println("验证码："+code);
  16.         //1.2 将验证码存放到redis中
  17.         redisTemplate.opsForValue().set(phone,code,200, TimeUnit.MINUTES);
  19.         //1.3 将验证码信息发送给springboot-sms-service这个工程（它将监听我们发的信息）
  20.         //1.3.1 重新组织数据（阿里云后台需要两个参数：手机号，验证号）
  21.         Map<String,String> params = new HashMap<>();
  22.         params.put("phone",phone);
  23.         params.put("code",code);
  24.         //1.3.2 将手机号及验证码发送出去
  25.         jmsMessagingTemplate.convertAndSend("sms", params);
  26.     }
  27. }

三、定义短信服务的监听方springboot-sms-service

3.1 添加依赖：

  1.  <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter-web</artifactId>
  5.         </dependency>
  7.         <dependency>
  8.             <groupId>com.alibaba</groupId>
  9.             <artifactId>fastjson</artifactId>
  10.             <version>1.2.15</version>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>org.apache.httpcomponents</groupId>
  14.             <artifactId>httpclient</artifactId>
  15.             <version>4.2.1</version>
  16.         </dependency>
  17.         <dependency>
  18.             <groupId>org.apache.httpcomponents</groupId>
  19.             <artifactId>httpcore</artifactId>
  20.             <version>4.2.1</version>
  21.         </dependency>
  22.         <dependency>
  23.             <groupId>commons-lang</groupId>
  24.             <artifactId>commons-lang</artifactId>
  25.             <version>2.6</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.eclipse.jetty</groupId>
  29.             <artifactId>jetty-util</artifactId>
  30.             <version>9.3.7.v20160115</version>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>junit</groupId>
  34.             <artifactId>junit</artifactId>
  35.             <version>4.5</version>
  36.             <scope>test</scope>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>org.springframework.boot</groupId>
  40.             <artifactId>spring-boot-starter-activemq</artifactId>
  41.         </dependency>
  42.     </dependencies>
  43. </project>

3.2 引入工具类HttpUtils,用于发送http请求：

  1. public class HttpUtils {
  3.     /**
  4.      * get
  5.      * 
  6.      * @param host
  7.      * @param path
  8.      * @param method
  9.      * @param headers
  10.      * @param querys
  11.      * @return
  12.      * @throws Exception
  13.      */
  14.     public static HttpResponse doGet(String host, String path, String method,
  15.                                      Map<String, String> headers,
  16.                                      Map<String, String> querys)
  17.             throws Exception {        
  18.         HttpClient httpClient = wrapClient(host);
  19.         HttpGet request = new HttpGet(buildUrl(host, path, querys));
  20.         for (Map.Entry<String, String> e : headers.entrySet()) {
  21.             request.addHeader(e.getKey(), e.getValue());
  22.         }
  24.         return httpClient.execute(request);
  25.     }
  27.     /**
  28.      * post form
  29.      * 
  30.      * @param host
  31.      * @param path
  32.      * @param method
  33.      * @param headers
  34.      * @param querys
  35.      * @param bodys
  36.      * @return
  37.      * @throws Exception
  38.      */
  39.     public static HttpResponse doPost(String host, String path, String method, 
  40.             Map<String, String> headers, 
  41.             Map<String, String> querys, 
  42.             Map<String, String> bodys)
  43.             throws Exception {        
  44.         HttpClient httpClient = wrapClient(host);
  46.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  47.         for (Map.Entry<String, String> e : headers.entrySet()) {
  48.             request.addHeader(e.getKey(), e.getValue());
  49.         }
  51.         if (bodys != null) {
  52.             List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
  54.             for (String key : bodys.keySet()) {
  55.                 nameValuePairList.add(new BasicNameValuePair(key, bodys.get(key)));
  56.             }
  57.             UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
  58.             formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
  59.             request.setEntity(formEntity);
  60.         }
  62.         return httpClient.execute(request);
  63.     }    
  65.     /**
  66.      * Post String
  67.      * 
  68.      * @param host
  69.      * @param path
  70.      * @param method
  71.      * @param headers
  72.      * @param querys
  73.      * @param body
  74.      * @return
  75.      * @throws Exception
  76.      */
  77.     public static HttpResponse doPost(String host, String path, String method, 
  78.             Map<String, String> headers, 
  79.             Map<String, String> querys, 
  80.             String body)
  81.             throws Exception {        
  82.         HttpClient httpClient = wrapClient(host);
  84.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  85.         for (Map.Entry<String, String> e : headers.entrySet()) {
  86.             request.addHeader(e.getKey(), e.getValue());
  87.         }
  89.         if (StringUtils.isNotBlank(body)) {
  90.             request.setEntity(new StringEntity(body, "utf-8"));
  91.         }
  93.         return httpClient.execute(request);
  94.     }
  96.     /**
  97.      * Post stream
  98.      * 
  99.      * @param host
  100.      * @param path
  101.      * @param method
  102.      * @param headers
  103.      * @param querys
  104.      * @param body
  105.      * @return
  106.      * @throws Exception
  107.      */
  108.     public static HttpResponse doPost(String host, String path, String method, 
  109.             Map<String, String> headers, 
  110.             Map<String, String> querys, 
  111.             byte[] body)
  112.             throws Exception {        
  113.         HttpClient httpClient = wrapClient(host);
  115.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  116.         for (Map.Entry<String, String> e : headers.entrySet()) {
  117.             request.addHeader(e.getKey(), e.getValue());
  118.         }
  120.         if (body != null) {
  121.             request.setEntity(new ByteArrayEntity(body));
  122.         }
  124.         return httpClient.execute(request);
  125.     }
  127.     /**
  128.      * Put String
  129.      * @param host
  130.      * @param path
  131.      * @param method
  132.      * @param headers
  133.      * @param querys
  134.      * @param body
  135.      * @return
  136.      * @throws Exception
  137.      */
  138.     public static HttpResponse doPut(String host, String path, String method, 
  139.             Map<String, String> headers, 
  140.             Map<String, String> querys, 
  141.             String body)
  142.             throws Exception {        
  143.         HttpClient httpClient = wrapClient(host);
  145.         HttpPut request = new HttpPut(buildUrl(host, path, querys));
  146.         for (Map.Entry<String, String> e : headers.entrySet()) {
  147.             request.addHeader(e.getKey(), e.getValue());
  148.         }
  150.         if (StringUtils.isNotBlank(body)) {
  151.             request.setEntity(new StringEntity(body, "utf-8"));
  152.         }
  154.         return httpClient.execute(request);
  155.     }
  157.     /**
  158.      * Put stream
  159.      * @param host
  160.      * @param path
  161.      * @param method
  162.      * @param headers
  163.      * @param querys
  164.      * @param body
  165.      * @return
  166.      * @throws Exception
  167.      */
  168.     public static HttpResponse doPut(String host, String path, String method, 
  169.             Map<String, String> headers, 
  170.             Map<String, String> querys, 
  171.             byte[] body)
  172.             throws Exception {        
  173.         HttpClient httpClient = wrapClient(host);
  175.         HttpPut request = new HttpPut(buildUrl(host, path, querys));
  176.         for (Map.Entry<String, String> e : headers.entrySet()) {
  177.             request.addHeader(e.getKey(), e.getValue());
  178.         }
  180.         if (body != null) {
  181.             request.setEntity(new ByteArrayEntity(body));
  182.         }
  184.         return httpClient.execute(request);
  185.     }
  187.     /**
  188.      * Delete
  189.      *  
  190.      * @param host
  191.      * @param path
  192.      * @param method
  193.      * @param headers
  194.      * @param querys
  195.      * @return
  196.      * @throws Exception
  197.      */
  198.     public static HttpResponse doDelete(String host, String path, String method, 
  199.             Map<String, String> headers, 
  200.             Map<String, String> querys)
  201.             throws Exception {        
  202.         HttpClient httpClient = wrapClient(host);
  204.         HttpDelete request = new HttpDelete(buildUrl(host, path, querys));
  205.         for (Map.Entry<String, String> e : headers.entrySet()) {
  206.             request.addHeader(e.getKey(), e.getValue());
  207.         }
  209.         return httpClient.execute(request);
  210.     }
  212.     private static String buildUrl(String host, String path, Map<String, String> querys) throws UnsupportedEncodingException {
  213.         StringBuilder sbUrl = new StringBuilder();
  214.         sbUrl.append(host);
  215.         if (!StringUtils.isBlank(path)) {
  216.             sbUrl.append(path);
  217.         }
  218.         if (null != querys) {
  219.             StringBuilder sbQuery = new StringBuilder();
  220.             for (Map.Entry<String, String> query : querys.entrySet()) {
  221.                 if (0 < sbQuery.length()) {
  222.                     sbQuery.append("&");
  223.                 }
  224.                 if (StringUtils.isBlank(query.getKey()) && !StringUtils.isBlank(query.getValue())) {
  225.                     sbQuery.append(query.getValue());
  226.                 }
  227.                 if (!StringUtils.isBlank(query.getKey())) {
  228.                     sbQuery.append(query.getKey());
  229.                     if (!StringUtils.isBlank(query.getValue())) {
  230.                         sbQuery.append("=");
  231.                         sbQuery.append(URLEncoder.encode(query.getValue(), "utf-8"));
  232.                     }                    
  233.                 }
  234.             }
  235.             if (0 < sbQuery.length()) {
  236.                 sbUrl.append("?").append(sbQuery);
  237.             }
  238.         }
  240.         return sbUrl.toString();
  241.     }
  243.     private static HttpClient wrapClient(String host) {
  244.         HttpClient httpClient = new DefaultHttpClient();
  245.         if (host.startsWith("https://")) {
  246.             sslClient(httpClient);
  247.         }
  249.         return httpClient;
  250.     }
  252.     private static void sslClient(HttpClient httpClient) {
  253.         try {
  254.             SSLContext ctx = SSLContext.getInstance("TLS");
  255.             X509TrustManager tm = new X509TrustManager() {
  256.                 public X509Certificate[] getAcceptedIssuers() {
  257.                     return null;
  258.                 }
  259.                 public void checkClientTrusted(X509Certificate[] xcs, String str) {
  261.                 }
  262.                 public void checkServerTrusted(X509Certificate[] xcs, String str) {
  264.                 }
  265.             };
  266.             ctx.init(null, new TrustManager[] { tm }, null);
  267.             SSLSocketFactory ssf = new SSLSocketFactory(ctx);
  268.             ssf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
  269.             ClientConnectionManager ccm = httpClient.getConnectionManager();
  270.             SchemeRegistry registry = ccm.getSchemeRegistry();
  271.             registry.register(new Scheme("https", 443, ssf));
  272.         } catch (KeyManagementException ex) {
  273.             throw new RuntimeException(ex);
  274.         } catch (NoSuchAlgorithmException ex) {
  275.             throw new RuntimeException(ex);
  276.         }
  277.     }
  278. }

3.3 监听我们发送的消息

  1. /**
  2.  * ------------------------------
  3.  * 功能：
  4.  * 作者：WF
  5.  * 微信：hbxfwf13590332912
  6.  * 创建时间：2021/8/10-16:37
  7.  * ------------------------------
  8.  */
  9. @Component
  10. public class MyMessageListener {
  12.     @JmsListener(destination = "sms")
  13.     public void getMessage(Map<String,String> params){
  14.         //1. 获取手机号
  15.         String phone = params.get("phone");
  16.         //2. 获取验证码
  17.         String code = params.get("code");
  19.         System.out.println("code = " + code);
  20.         //3. 使用工具类发送信息给阿里云
  21.         sendMessage(phone,code);
  23.     }
  25.     private void sendMessage(String phone,String code){
  26.         String host = "http://dingxin.market.alicloudapi.com";
  27.         String path = "/dx/sendSms";
  28.         String method = "POST";
  29.         String appcode = "7ba36df9be9e4518bda04ba2702b8fb0";
  30.         Map<String, String> headers = new HashMap<String, String>();
  31.         //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
  32.         headers.put("Authorization", "APPCODE " + appcode);
  33.         Map<String, String> querys = new HashMap<String, String>();
  34.         querys.put("mobile",phone);
  35.         querys.put("param", "code:" + code);
  36.         querys.put("tpl_id", "TP1711063");
  37.         Map<String, String> bodys = new HashMap<String, String>();
  39.         try {
  40.             /**
  41.              * 重要提示如下:
  42.              * HttpUtils请从
  43.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java
  44.              * 下载
  45.              *
  46.              * 相应的依赖请参照
  47.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml
  48.              */
  49.             HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
  50.             System.out.println(response.toString());
  51.             //获取response的body
  52.             //System.out.println(EntityUtils.toString(response.getEntity()));
  53.         } catch (Exception e) {
  54.             e.printStackTrace();
  55.         }
  56.     }
  57. }

3.4 前端页面编写：

3.4.1 在docker下nginx服务器中配置user静态资源：

image.png

3.4.2 配置nginx服务器：

第1步：在/mydata/nginx/conf/nginx.conf下添加上服务器：

  1.  upstream user{
  2.     server 192.168.56.1:9005;
  3. }

第2步：在/mydata/nginx/conf/conf.d/zeyigou.conf配置自己的反向代理服务器

  1. server {
  2.     listen       80;
  3.     server_name  user.zeyigou.com;
  5.     location / {
  6.     proxy_pass http://user;
  7.     proxy_set_header Host $host:$server_port;
  8.     }
  10.     include /etc/nginx/static.conf;
  11. }

第3步：重启nginx服务器：

  1. docker restart nginx

第4步：修改zyg-user-web中的静态页面，将其中的静态路径前添加：/static/user/
第5步：在swithHost中配置域名服务器：
image.png

四、注册用户：

4.1 在前端register.html中提交表单 ：

image.png

4.2 在zyg-user-web中添加注册方法：

  1.   //3. 添加用户
  2.     @RequestMapping("user/add")
  3.     public String add(UserEntity userEntity,String validCode){
  4.         //3.1 比较用户输入的验证码与redis中的验证码是否一致
  5.         boolean b = userService.purdgeCode(validCode,userEntity.getPhone());
  6.         //3.2 如果比较相等，就添加用户
  7.         if(b){
  8.             userService.add(userEntity);
  9.         }
  10.         return "register";
  11.     }

4.3 在zyg-user-service模块完成验证码比较及用户添加

  1. /**
  2.      * 功能: 比较验证码是否相等
  3.      * 参数:
  4.      * 返回值: boolean
  5.      * 时间: 2021/8/11 14:32
  6.      */
  7.     @Override
  8.     public boolean purdgeCode(String validCode, String phone) {
  9.         //1. 根据手机号得到原来的验证码
  10.         String code = redisTemplate.opsForValue().get(phone);
  11.         //2. 判断是否存在
  12.         if(StringUtils.isNotBlank(validCode) && StringUtils.isNotBlank(code) && validCode.equals(code)){
  13.             return true;
  14.         }
  15.         return false;
  16.     }
  18.     /**
  19.      * 功能: 注册新用户
  20.      * 参数:
  21.      * 返回值: void
  22.      * 时间: 2021/8/11 14:33
  23.      */
  24.     @Override
  25.     public void add(UserEntity userEntity) {
  26.         userEntity.setCreated(new Date());
  27.         userEntity.setStatus("y");
  28.         //1. 将原来的密码进行加密
  29.         BCryptPasswordEncoder encoder = new BCryptPasswordEncoder();
  30.         String pwd = encoder.encode(userEntity.getPassword());
  31.         //2. 重新保存到数据库中
  32.         userEntity.setPassword(pwd);
  33.         this.save(userEntity);
  34.     }

4.4 数据库中查看添加的用户结果 ：

image.png