大家好,今天小编来为大家解答售卖直充网站源码分享这个问题,在线充值源码很多人还不知道,现在让我们一起来看看吧!
课程目标
目标1:掌握SpringBoot框架的搭建方法
目标2:能够使用阿里大于发送短信
目标3:运用SpringBoot、阿里大于和ActiveMQ开发短信微服务
目标4:完成品优购用户注册功能(短信验证码认证)
1.SpringBoot入门
1.1什么是SpringBoot
Spring诞生时是Java企业版(JavaEnterpriseEdition,JEE,也称J2EE)的轻量级代替品。无需开发重量级的EnterpriseJavaBean(EJB),Spring为企业级Java开发提供了一种相对简单的方法,通过依赖注入和面向切面编程,用简单的Java对象(PlainOldJavaObject,POJO)实现了EJB的功能。
虽然Spring的组件代码是轻量级的,但它的配置却是重量级的。一开始,Spring用XML配置,而且是很多XML配置。Spring2.5引入了基于注解的组件扫描,这消除了大量针对应用程序自身组件的显式XML配置。Spring3.0引入了基于Java的配置,这是一种类型安全的可重构配置方式,可以代替XML。所有这些配置都代表了开发时的损耗。因为在思考Spring特性配置和解决业务问题之间需要进行思维切换,所以写配置挤占了写应用程序逻辑的时间。和所有框架一样,Spring实用,但与此同时它要求的回报也不少。
除此之外,项目的依赖管理也是件吃力不讨好的事情。决定项目里要用哪些库就已经够让人头痛的了,你还要知道这些库的哪个版本和其他库不会有冲突,这难题实在太棘手。并且,依赖管理也是一种损耗,添加依赖不是写应用程序代码。一旦选错了依赖的版本,随之而来的不兼容问题毫无疑问会是生产力杀手。
SpringBoot让这一切成为了过去。
SpringBoot是Spring社区较新的一个项目。该项目的目的是帮助开发者更容易的创建基于Spring的应用程序和服务,让更多人的人更快的对Spring进行入门体验,为Spring生态系统提供了一种固定的、约定优于配置风格的框架。
SpringBoot具有如下特性:
(1)为基于Spring的开发提供更快的入门体验
(2)开箱即用,没有代码生成,也无需XML配置。同时也可以修改默认值来满足特定的需求。
(3)提供了一些大型项目中常见的非功能性特性,如嵌入式服务器、安全、指标,健康检测、外部配置等。
(4)SpringBoot并不是不对Spring功能上的增强,而是提供了一种快速使用Spring的方式。
1.2SpringBoot入门小Demo
1.2.1起步依赖
创建Maven工程springboot_demo(打包方式jar)
在pom.xml中添加如下依赖
<parent>\n<groupId>org.springframework.boot</groupId>\n<artifactId>spring-boot-starter-parent</artifactId>\n<version>1.4.0.RELEASE</version>\n</parent>\n<dependencies>\n<dependency>\n<groupId>org.springframework.boot</groupId>\n<artifactId>spring-boot-starter-web</artifactId>\n</dependency>\n</dependencies>\n
我们会惊奇地发现,我们的工程自动添加了好多好多jar包
…
而这些jar包正式我们做开发时需要导入的jar包。因为这些jar包被我们刚才引入的spring-boot-starter-web所引用了,所以我们引用spring-boot-starter-web后会自动把依赖传递过来。
1.2.2变更JDK版本
我们发现默认情况下工程的JDK版本是1.6,而我们通常用使用1.7的版本,所以我们需要在pom.xml中添加以下配置
<properties>\n<java.version>1.7</java.version>\n</properties>\n
添加后更新工程,会发现版本已经变更为1.7
1.2.3引导类
只需要创建一个引导类.
packagecn.itcast.demo;\nimportorg.springframework.boot.SpringApplication;\nimportorg.springframework.boot.autoconfigure.SpringBootApplication;\n@SpringBootApplication\npublicclassApplication{\n\tpublicstaticvoidmain(String[]args){\n\t\tSpringApplication.run(Application.class,args);\n\t}\n}\n
简单解释一下,@SpringBootApplication其实就是以下三个注解的总和
@Configuration:用于定义一个配置类
@EnableAutoConfiguration:SpringBoot会自动根据你jar包的依赖来自动配置项目。
@ComponentScan:告诉Spring哪个packages的用注解标识的类会被spring自动扫描并且装入bean容器。
我们直接执行这个引导类,会发现控制台出现的这个标识
你能不能看出来上边这个图是什么东西?
1.2.4SpringMVC实现HelloWorld输出
我们现在开始使用springMVC框架,实现json数据的输出。如果按照我们原来的做法,需要在web.xml中添加一个DispatcherServlet的配置,再添加一个spring的配置文件,配置文件中需要添加如下配置
<!–使用组件扫描,不用将controller在spring中配置–>\n\t<context:component-scanbase-package=”cn.itcast.demo.controller”/>\n<!–使用注解驱动不用在下边定义映射器和适配置器–>\n\t<mvc:annotation-driven>\n\t<mvc:message-convertersregister-defaults=”true”>\n\t<beanclass=”com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter”>\n\t<propertyname=”supportedMediaTypes”value=”application/json”/>\n\t<propertyname=”features”>\n\t<array>\n\t<value>WriteMapNullValue</value>\n\t<value>WriteDateUseDateFormat</value>\n\t</array>\n\t</property>\n\t</bean>\n\t</mvc:message-converters>\n\t</mvc:annotation-driven>\n
但是我们用SpringBoot,这一切都省了。我们直接写Controller类
packagecn.itcast.demo.controller;\nimportorg.springframework.web.bind.annotation.RequestMapping;\nimportorg.springframework.web.bind.annotation.RestController;\n@RestController\npublicclassHelloWorldController{\n\t@RequestMapping(“/info”)\n\tpublicStringinfo(){\n\t\treturn”HelloWorld”;\t\t\n\t}\t\t\n}\n
我们运行启动类来运行程序
在浏览器地址栏输入http://localhost:8080/info即可看到运行结果
1.2.5修改tomcat启动端口
在src/main/resources下创建application.properties
server.port=8088\n
重新运行引导类。地址栏输入
http://localhost:8088/info
1.2.6读取配置文件信息
在src/main/resources下的application.properties增加配置
url=http://www.itcast.cn\n
我要在类中读取这个配置信息,修改HelloWorldController
\t@Autowired\n\tprivateEnvironmentenv;\n\t@RequestMapping(“/info”)\n\tpublicStringinfo(){\n\t\treturn”HelloWorld~~”+env.getProperty(“url”);\n\t}\n
1.2.7热部署
我们在开发中反复修改类、页面等资源,每次修改后都是需要重新启动才生效,这样每次启动都很麻烦,浪费了大量的时间,能不能在我修改代码后不重启就能生效呢?可以,在pom.xml中添加如下配置就可以实现这样的功能,我们称之为热部署。
\t<dependency>\n\t<groupId>org.springframework.boot</groupId>\n\t<artifactId>spring-boot-devtools</artifactId>\n\t</dependency>\n
赶快试试看吧,是不是很爽。
1.3SpringBoot与ActiveMQ整合
1.3.1使用内嵌服务
(1)在pom.xml中引入ActiveMQ起步依赖
<dependency>\n<groupId>org.springframework.boot</groupId>\n<artifactId>spring-boot-starter-activemq</artifactId>\n</dependency>\n
(2)创建消息生产者
/**\n*消息生产者\n*@authorAdministrator\n*/\n@RestController\npublicclassQueueController{\n\t@Autowired\n\tprivateJmsMessagingTemplatejmsMessagingTemplate;\n\t@RequestMapping(“/send”)\n\tpublicvoidsend(Stringtext){\n\t\tjmsMessagingTemplate.convertAndSend(“itcast”,text);\n\t}\n}\n
(3)创建消息消费者
@Component\npublicclassConsumer{\n\t@JmsListener(destination=”itcast”)\n\tpublicvoidreadMessage(Stringtext){\n\t\tSystem.out.println(“接收到消息:”+text);\n\t}\t\n}\n
测试:启动服务后,在浏览器执行
http://localhost:8088/send.do?text=aaaaa
即可看到控制台输出消息提示。SpringBoot内置了ActiveMQ的服务,所以我们不用单独启动也可以执行应用程序。
1.3.2使用外部服务
在src/main/resources下的application.properties增加配置,指定ActiveMQ的地址
spring.activemq.broker-url=tcp://192.168.25.135:61616\n
运行后,会在activeMQ中看到发送的queue
1.3.3发送Map信息
(1)修改QueueController.java
\t@RequestMapping(“/sendmap”)\n\tpublicvoidsendMap(){\n\t\tMapmap=newHashMap<>();\n\t\tmap.put(“mobile”,”13900001111″);\n\t\tmap.put(“content”,”恭喜获得10元代金券”);\t\t\n\t\tjmsMessagingTemplate.convertAndSend(“itcast_map”,map);\n\t}\n
(2)修改Consumer.java
\t@JmsListener(destination=”itcast_map”)\n\tpublicvoidreadMap(Mapmap){\n\t\tSystem.out.println(map);\t\t\n\t}\n
2.短信发送平台-阿里大于
2.1阿里大于简介
阿里大于是阿里云旗下产品,融合了三大运营商的通信能力,通过将传统通信业务和能力与互联网相结合,创新融合阿里巴巴生态内容,全力为中小企业和开发者提供优质服务阿里大于提供包括短信、语音、流量直充、私密专线、店铺手机号等个性化服务。通过阿里大于打通三大运营商通信能力,全面融合阿里巴巴生态,以开放API及SDK的方式向开发者提供通信和数据服务,更好地支撑企业业务发展和创新服务。\n
2.2准备工作
2.2.1注册账户
首先我们先进入“阿里大于”www.alidayu.com(https://dayu.aliyun.com/)
注册账号后,再在手机下载“阿里云”应用,登陆,然后进行在线实名认证。
2.2.2登陆系统
使用刚才注册的账号进行登陆。
点击进入控制台
点击使用短信服务
3.2.3申请签名
3.2.4申请模板
3.2.5创建accessKey
3.3SDK安装
从阿里云通信官网上下载Demo工程
解压后导入Eclipce
红线框起来的两个工程就是阿里云通信的依赖jar源码,我们将其安装到本地仓库
(删除aliyun-java-sdk-core的单元测试类)
本地jar包安装后alicom-dysms-api工程引入依赖
<dependencies>\n\t<dependency>\n\t\t<groupId>com.aliyun</groupId>\n\t\t<artifactId>aliyun-java-sdk-dysmsapi</artifactId>\n\t\t<version>1.0.0-SNAPSHOT</version>\n\t</dependency>\n\t<dependency>\n\t\t<groupId>com.aliyun</groupId>\n\t\t<artifactId>aliyun-java-sdk-core</artifactId>\n\t\t<version>3.2.5</version>\n\t</dependency>\n</dependencies>\n
红叉消失了
3.4发送短信测试
(1)打开SmsDemo
替换下列几处代码
这个accessKeyId和accessSecret到刚才申请过的
手机号,短信签名和模板号
模板参数
number是我们申请模板时写的参数
执行main方法我们就可以在手机收到短信啦
3.短信微服务
3.1需求分析
构建一个通用的短信发送服务(独立于品优购的单独工程),接收activeMQ的消息(MAP类型)消息包括手机号(mobile)、短信模板号(template_code)、签名(sign_name)、参数字符串(param)
3.2代码实现
3.2.1工程搭建
(1)创建工程itcast_sms(JAR工程),POM文件引入依赖
<properties>\n<java.version>1.7</java.version>\n</properties>\n<parent>\n<groupId>org.springframework.boot</groupId>\n<artifactId>spring-boot-starter-parent</artifactId>\n\t<version>1.4.0.RELEASE</version>\n</parent>\n<dependencies>\n<dependency>\n<groupId>org.springframework.boot</groupId>\n<artifactId>spring-boot-starter-web</artifactId>\n</dependency>\n<dependency>\n\t<groupId>org.springframework.boot</groupId>\n\t<artifactId>spring-boot-starter-activemq</artifactId>\n\t</dependency>\n<dependency>\n\t\t<groupId>com.aliyun</groupId>\n\t\t<artifactId>aliyun-java-sdk-dysmsapi</artifactId>\n\t\t<version>1.0.0-SNAPSHOT</version>\n\t</dependency>\n\t<dependency>\n\t\t<groupId>com.aliyun</groupId>\n\t\t<artifactId>aliyun-java-sdk-core</artifactId>\n\t\t<version>3.2.5</version>\n\t</dependency>\n</dependencies>\n
(2)创建引导类
packagecn.itcast.sms;\nimportorg.springframework.boot.SpringApplication;\nimportorg.springframework.boot.autoconfigure.SpringBootApplication;\n@SpringBootApplication\npublicclassApplication{\n\tpublicstaticvoidmain(String[]args){\n\t\tSpringApplication.run(Application.class,args);\n\t}\n}\n
(3)创建配置文件application.properties
server.port=9003\nspring.activemq.broker-url=tcp://192.168.25.135:61616\naccessKeyId=不告诉你\naccessKeySecret=不告诉你\n
3.2.2短信工具类
参照之前的短信demo创建短信工具类
packagecn.itcast.sms;\nimportcom.aliyuncs.DefaultAcsClient;\nimportcom.aliyuncs.IAcsClient;\nimportcom.aliyuncs.dysmsapi.model.v20170525.QuerySendDetailsRequest;\nimportcom.aliyuncs.dysmsapi.model.v20170525.QuerySendDetailsResponse;\nimportcom.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;\nimportcom.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;\nimportcom.aliyuncs.exceptions.ClientException;\nimportcom.aliyuncs.profile.DefaultProfile;\nimportcom.aliyuncs.profile.IClientProfile;\nimportjava.text.SimpleDateFormat;\nimportjava.util.Date;\nimportorg.springframework.beans.factory.annotation.Autowired;\nimportorg.springframework.core.env.Environment;\nimportorg.springframework.stereotype.Component;\n/**\n*短信工具类\n*@authorAdministrator\n*\n*/\n@Component\npublicclassSmsUtil{\n//产品名称:云通信短信API产品,开发者无需替换\nstaticfinalStringproduct=”Dysmsapi”;\n//产品域名,开发者无需替换\nstaticfinalStringdomain=”dysmsapi.aliyuncs.com”;\n\n@Autowired\nprivateEnvironmentenv;\n//TODO此处需要替换成开发者自己的AK(在阿里云访问控制台寻找)\n\n/**\n*发送短信\n*@parammobile手机号\n*@paramtemplate_code模板号\n*@paramsign_name签名\n*@paramparam参数\n*@return\n*@throwsClientException\n*/\npublicSendSmsResponsesendSms(Stringmobile,Stringtemplate_code,Stringsign_name,Stringparam)throwsClientException{\n\tStringaccessKeyId=env.getProperty(“accessKeyId”);\nStringaccessKeySecret=env.getProperty(“accessKeySecret”);\n\t\n//可自助调整超时时间\nSystem.setProperty(“sun.net.client.defaultConnectTimeout”,”10000″);\nSystem.setProperty(“sun.net.client.defaultReadTimeout”,”10000″);\n//初始化acsClient,暂不支持region化\nIClientProfileprofile=DefaultProfile.getProfile(“cn-hangzhou”,accessKeyId,accessKeySecret);\nDefaultProfile.addEndpoint(“cn-hangzhou”,”cn-hangzhou”,product,domain);\nIAcsClientacsClient=newDefaultAcsClient(profile);\n//组装请求对象-具体描述见控制台-文档部分内容\nSendSmsRequestrequest=newSendSmsRequest();\n//必填:待发送手机号\nrequest.setPhoneNumbers(mobile);\n//必填:短信签名-可在短信控制台中找到\nrequest.setSignName(sign_name);\n//必填:短信模板-可在短信控制台中找到\nrequest.setTemplateCode(template_code);\n//可选:模板中的变量替换JSON串,如模板内容为”亲爱的${name},您的验证码为${code}”时,此处的值为\nrequest.setTemplateParam(param);\n//选填-上行短信扩展码(无特殊需求用户请忽略此字段)\n//request.setSmsUpExtendCode(“90997”);\n//可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者\nrequest.setOutId(“yourOutId”);\n//hint此处可能会抛出异常,注意catch\nSendSmsResponsesendSmsResponse=acsClient.getAcsResponse(request);\nreturnsendSmsResponse;\n}\npublicQuerySendDetailsResponsequerySendDetails(Stringmobile,StringbizId)throwsClientException{\n\tStringaccessKeyId=env.getProperty(“accessKeyId”);\nStringaccessKeySecret=env.getProperty(“accessKeySecret”);\n//可自助调整超时时间\nSystem.setProperty(“sun.net.client.defaultConnectTimeout”,”10000″);\nSystem.setProperty(“sun.net.client.defaultReadTimeout”,”10000″);\n//初始化acsClient,暂不支持region化\nIClientProfileprofile=DefaultProfile.getProfile(“cn-hangzhou”,accessKeyId,accessKeySecret);\nDefaultProfile.addEndpoint(“cn-hangzhou”,”cn-hangzhou”,product,domain);\nIAcsClientacsClient=newDefaultAcsClient(profile);\n//组装请求对象\nQuerySendDetailsRequestrequest=newQuerySendDetailsRequest();\n//必填-号码\nrequest.setPhoneNumber(mobile);\n//可选-流水号\nrequest.setBizId(bizId);\n//必填-发送日期支持30天内记录查询,格式yyyyMMdd\nSimpleDateFormatft=newSimpleDateFormat(“yyyyMMdd”);\nrequest.setSendDate(ft.format(newDate()));\n//必填-页大小\nrequest.setPageSize(10L);\n//必填-当前页码从1开始计数\nrequest.setCurrentPage(1L);\n//hint此处可能会抛出异常,注意catch\nQuerySendDetailsResponsequerySendDetailsResponse=acsClient.getAcsResponse(request);\nreturnquerySendDetailsResponse;\n}\n}\n
3.2.3消息监听类
创建SmsListener.java
packagecn.itcast.sms;\nimportjava.util.Map;\nimportorg.springframework.beans.factory.annotation.Autowired;\nimportorg.springframework.jms.annotation.JmsListener;\nimportorg.springframework.stereotype.Component;\nimportcom.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;\nimportcom.aliyuncs.exceptions.ClientException;\n/**\n*消息监听类\n*@authorAdministrator\n*/\n@Component\npublicclassSmsListener{\n\t@Autowired\n\tprivateSmsUtilsmsUtil;\n\t\n\t@JmsListener(destination=”sms”)\n\tpublicvoidsendSms(Map<String,String>map){\t\t\n\t\ttry{\n\t\t\tSendSmsResponseresponse=smsUtil.sendSms(\n\t\t\t\t\tmap.get(“mobile”),\n\t\t\t\t\tmap.get(“template_code”),\n\t\t\t\t\tmap.get(“sign_name”),\n\t\t\t\t\tmap.get(“param”));\t\t\t\t\t\n\t\t\tSystem.out.println(“Code=”+response.getCode());\n\t\tSystem.out.println(“Message=”+response.getMessage());\n\t\tSystem.out.println(“RequestId=”+response.getRequestId());\n\t\tSystem.out.println(“BizId=”+response.getBizId());\t\t\t\n\t\t}catch(ClientExceptione){\n\t\t\te.printStackTrace();\t\t\t\n\t\t}\t\t\n\t}\n}\n
3.3代码测试
修改springboot-demo的QueueController.java
\t@RequestMapping(“/sendsms”)\n\tpublicvoidsendSms(){\n\t\tMapmap=newHashMap<>();\n\t\tmap.put(“mobile”,”13900001111″);\n\t\tmap.put(“template_code”,”SMS_85735065″);\t\n\t\tmap.put(“sign_name”,”黑马”);\n\t\tmap.put(“param”,”{\\”number\\”:\\”102931\\”}”);\n\t\tjmsMessagingTemplate.convertAndSend(“sms”,map);\n\t}\n
启动itcast_sms
启动springboot-demo
地址栏输入:http://localhost:8088/sendsms.do
观察控制台输出
随后短信也成功发送到你的手机上
4.用户注册
4.1需求分析
完成用户注册功能
4.2工程搭建
4.2.1用户服务接口层
(1)创建pinyougou-user-interface(jar)
(2)引入pojo依赖
4.2.2用户服务实现层
(1)创建pinyougou-user-service(war)
(2)引入springdubboxactiveMQ相关依赖,引入依赖(pinyougou-user-interfacepinyougou-daopinyougou-common),运行端口为9006
(3)添加web.xml
(4)创建Spring配置文件applicationContext-service.xml和applicationContent-tx.xml
<dubbo:protocolname=”dubbo”port=”20886″/>\n<dubbo:annotationpackage=”com.pinyougou.user.service.impl”/>\n\t<dubbo:applicationname=”pinyougou-user-service”/>\n<dubbo:registryaddress=”zookeeper://192.168.25.135:2181″/>\n
4.2.3用户中心WEB层
创建war工程pinyougou-user-web我们将注册功能放入此工程
(1)添加web.xml
(2)引入依赖pinyougou-user-interface、spring相关依赖(参照其它web工程),tomcat运行端口9106
(3)添加spring配置文件
(4)拷贝静态原型页面register.html及相关资源
4.3基本注册功能实现
4.3.1生成和拷贝代码
4.3.2后端服务实现层
修改pinyougou-user-service的UserServiceImpl.java
\t/**\n\t*增加\n\t*/\n\t@Override\n\tpublicvoidadd(TbUseruser){\n\t\tuser.setCreated(newDate());//创建日期\n\t\tuser.setUpdated(newDate());//修改日期\n\t\tStringpassword=DigestUtils.md5Hex(user.getPassword());//对密码加密\n\t\tuser.setPassword(password);\n\t\tuserMapper.insert(user);\t\t\n\t}\n
4.3.3前端控制层
修改userController.js
//控制层\napp.controller(‘userController’,function($scope,$controller,userService){\t\n\t//注册\n\t$scope.reg=function(){\t\t\n\tif($scope.entity.password!=$scope.password){\n\t\talert(“两次输入的密码不一致,请重新输入”);\t\t\t\n\t\treturn;\n\t}\t\t\n\t\tuserService.add($scope.entity).success(\n\t\t\tfunction(response){\n\t\t\t\talert(response.message);\n\t\t\t}\t\t\n\t\t);\t\t\t\t\n\t}\n});\t\n
4.3.4修改页面
修改页面register.html,引入js
<scripttype=”text/javascript”src=”plugins/angularjs/angular.min.js”></script>\n<scripttype=”text/javascript”src=”js/base.js”></script>\t\n<scripttype=”text/javascript”src=”js/service/userService.js”></script>\t\n<scripttype=”text/javascript”src=”js/controller/userController.js”></script>\n
指令
<bodyng-app=”pinyougou”ng-controller=”userController”>\n
绑定表单
<formclass=”sui-formform-horizontal”>\n\t\t<divclass=”control-group”>\n\t\t\t<labelclass=”control-label”>用户名:</label>\n\t\t\t<divclass=”controls”>\n\t\t\t\t<inputtype=”text”placeholder=”请输入你的用户名”ng-model=”entity.username”class=”input-xfatinput-xlarge”>\n\t\t\t</div>\n\t\t</div>\n\t\t<divclass=”control-group”>\n\t\t\t<labelfor=”inputPassword”class=”control-label”>登录密码:</label>\n\t\t\t<divclass=”controls”>\n\t\t\t\t<inputtype=”password”placeholder=”设置登录密码”ng-model=”entity.password”class=”input-xfatinput-xlarge”>\n\t\t\t</div>\n\t\t</div>\n\t\t<divclass=”control-group”>\n\t\t\t<labelfor=”inputPassword”class=”control-label”>确认密码:</label>\n\t\t\t<divclass=”controls”>\n\t\t\t\t\t\t\t<inputtype=”password”placeholder=”再次确认密码”ng-model=”password”class=”input-xfatinput-xlarge”>\n\t\t\t</div>\n\t\t</div>\n\t\t<divclass=”control-group”>\n\t\t\t\t<labelclass=”control-label”>手机号:</label>\n\t\t\t\t<divclass=”controls”>\n\t\t\t\t<inputtype=”text”placeholder=”请输入你的手机号”ng-model=”entity.phone”class=”input-xfatinput-xlarge”>\n\t\t\t\t</div>\n\t\t</div>\n\t\t<divclass=”control-group”>\n\t\t\t\t<labelfor=”inputPassword”class=”control-label”>短信验证码:</label>\n\t\t\t\t<divclass=”controls”>\n\t\t\t\t\t<inputtype=”text”placeholder=”短信验证码”class=”input-xfatinput-xlarge”><ahref=””ng-click=”sendCode()”>获取短信验证码</a>\n
4.4.4短信验证码发送到手机
(1)在pinyougou-user-service添加配置文件applicationContext-activemq.xml
<!–真正可以产生Connection的ConnectionFactory,由对应的JMS服务厂商提供–>\n\t<beanid=”targetConnectionFactory”class=”org.apache.activemq.ActiveMQConnectionFactory”>\n\t<propertyname=”brokerURL”value=”tcp://192.168.25.135:61616″/>\n\t</bean>\n<!–Spring用于管理真正的ConnectionFactory的ConnectionFactory–>\n\t<beanid=”connectionFactory”class=”org.springframework.jms.connection.SingleConnectionFactory”>\n\t<!–目标ConnectionFactory对应真实的可以产生JMSConnection的ConnectionFactory–>\n\t<propertyname=”targetConnectionFactory”ref=”targetConnectionFactory”/>\n\t</bean>\n<!–Spring提供的JMS工具类,它可以进行消息发送、接收等–>\n\t<beanid=”jmsTemplate”class=”org.springframework.jms.core.JmsTemplate”>\n\t<!–这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象–>\n\t<propertyname=”connectionFactory”ref=”connectionFactory”/>\n\t</bean>\n\t<!–这个是点对点消息–>\n\t<beanid=”smsDestination”class=”org.apache.activemq.command.ActiveMQQueue”>\n\t<constructor-argvalue=”sms”/>\n\t</bean>\n
(2)修改pinyougou-user-service的UserServiceImpl.java
\t@Autowired\n\tprivateJmsTemplatejmsTemplate;\t\n\t@Autowired\n\tprivateDestinationsmsDestination;\t\n\t@Value(“${template_code}”)\n\tprivateStringtemplate_code;\n\t\n\t@Value(“${sign_name}”)\n\tprivateStringsign_name;\n\t/**\n\t*生成短信验证码\n\t*/\n\tpublicvoidcreateSmsCode(finalStringphone){\t\t\n\t\t//生成6位随机数\n\t\tfinalStringcode=(long)(Math.random()*1000000)+””;\n\t\tSystem.out.println(“验证码:”+code);\n\t\t//存入缓存\n\t\tredisTemplate.boundHashOps(“smscode”).put(phone,code);\n\t\t//发送到activeMQ\t\t\n\t\tjmsTemplate.send(smsDestination,newMessageCreator(){\t\t\t\n\t\t\t@Override\n\t\t\tpublicMessagecreateMessage(Sessionsession)throwsJMSException{\t\n\t\t\t\tMapMessagemapMessage=session.createMapMessage();\t\t\t\n\t\t\t\tmapMessage.setString(“mobile”,phone);//手机号\n\t\t\t\tmapMessage.setString(“template_code”,”SMS_85735065″);//模板编号\n\t\t\t\tmapMessage.setString(“sign_name”,”黑马”);//签名\t\t\t\t\n\t\t\t\tMapm=newHashMap<>();\n\t\t\t\tm.put(“number”,code);\t\t\t\t\n\t\t\t\tmapMessage.setString(“param”,JSON.toJSONString(m));//参数\n\t\t\t\treturnmapMessage;\n\t\t\t}\n\t\t});\t\t\t\t\n\t}\n
(3)在pinyougou-common的properties目录下创建配置文件sms.properties
template_code=SMS_85735065\nsign_name=\\u9ED1\\u9A6C\n
关于本次售卖直充网站源码分享和在线充值源码的问题分享到这里就结束了,如果解决了您的问题,我们非常高兴。
