前言:
学习B站UP主狂神说视频笔记整理视频链接
异步任务
在很多实际业务场景中,需要先一步响应用户,再通过异步任务做后续处理,保证了用户的体验!
测试环境搭建:
业务层:
@Service
public class AsyncService {
public void hello(){
try {
Thread.sleep(3000); //影响用户体验
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("数据正在在处理");
}
}
controller层:
@RestController
public class AsyncController {
@Autowired
AsyncService asyncService;
@RequestMapping("/hello")
public String hello(){
asyncService.hello(); //停止三秒 转圈
return "ok";
}
}
此时访问hello会转圈三秒,极其影响用户体验
开启异步任务:
1.在需要进行异步的方法上添加注解@Async
2.在spring里使用注解@EnableAsync
开启异步任务
@Service
public class AsyncService {
@Async //告诉Springboot这是一个异步任务
public void hello(){
try {
Thread.sleep(3000); //影响用户体验
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("数据正在在处理");
}
}
@EnableAsync //开启异步任务
@SpringBootApplication
public class SpringbootMailApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootMailApplication.class, args);
}
}
邮件任务
导入依赖
在pom.xml中导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
配置mail
如果使用QQ邮箱,需要在QQ邮箱中开启服务
之后会得到一个QQ邮箱授权码
现在就可以来配置邮件啦~
在spring配置文件中进行配置:
# 邮件配置
spring.mail.username=[email protected]
spring.mail.password=wbbnxcvaxwewewea
# 配置主机名
spring.mail.host=smtp.qq.com
# 使用QQ邮箱还需要配置 加密验证 如果使用网易的163就不需要
spring.mail.properties.mail.smtp.ssl.enable=true
测试使用
从源码上可以看出spring自动帮我们进行了配置,我们只需要调用它即可!
简单邮件:
@Autowired
JavaMailSenderImpl mailSender;
//发送邮件需要时间 ,可以做成异步任务
public void contextLoads(){
//简单的邮件对象
SimpleMailMessage message = new SimpleMailMessage();
message.setSubject("你好世界");//邮件主题
message.setText("学习SpringBoot邮件发送");//邮件正文
message.setTo("[email protected]");//发送给哪个邮箱?
message.setFrom("[email protected]");//发送者
//发送邮件
mailSender.send(message);
}
复杂邮件:
@Async
public void contextLoads1() throws MessagingException {
//复杂邮件对象
MimeMessage message = mailSender.createMimeMessage();
//组装
MimeMessageHelper helper = new MimeMessageHelper(message,true,"UTF-8");//true 是否是多文本上传 设置UTF-8编码
//正文
helper.setSubject("你好世界");
helper.setText("<p>这是一个复杂的邮件对象</p>",true); //开启true就会解析超文本html
//附件
helper.addAttachment("1.png",new File("D:\\test\\1.png"));
helper.setTo("[email protected]");
helper.setFrom("[email protected]");
//发送邮件
mailSender.send(message);
}
定时任务
定时任务需要了解两个接口:
Taskscheduler #任务调度程序
TaskExecutor #任务执行者
使用
步骤一:
@EnableScheduling //标注在启动类上 开启定时任务
@SpringBootApplication
public class ShiroAdminApplication {
public static void main(String[] args) {
SpringApplication.run(ShiroAdminApplication.class, args);
}
}
步骤二:
在方法上标注注解@Scheduled
// cron表达式
//秒 分 时 日 月 周几
@Scheduled(cron = "0 * * * * ?")
public void hello(){
System.out.println("hello,定时任务被执行了");
}
分布式
什么是分布式?
在《分布式系统原理与范型》一书中有如下定义:“分布式系统是若干独立计算机的集合,这些计算机对于用户来说就像单个相关系统”;
分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。分布式系统的出现是为了用廉价的、普通的机器完成单个计算机无法完成的计算、存储任务。其目的是利用更多的机器,处理更多的数据。
分布式系统(distributed system)是建立在网络之上的软件系统。
首先需要明确的是,只有当单个节点的处理能力无法满足日益增长的计算、存储任务的时候,且硬件的提升(加内存、加磁盘、使用更好的CPU)高昂到得不偿失的时候,应用程序也不能进一步优化的时候,我们才需要考虑分布式系统。因为,分布式系统要解决的问题本身就是和单机系统一样的,而由于分布式系统多节点、通过网络通信的拓扑结构,会引入很多单机系统没有的问题,为了解决这些问题又会引入更多的机制、协议,带来更多的问题.
什么是RPC?
RPC【Remote Procedure Call】是指远程过程调用,是一种进程间通信方式,他是一种技术的思想,
而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数,而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数,本质上编写的调用代码基本相同。
也就是说两台服务器A,B,一个应用部署在A服务器上,想要调用B服务器上应用提供的函数/方法,由于不在一个内存空间,不能直接调用,需要通过网络来表达调用的语义和传达调用的数据。为什么要用RPC呢?就是无法在一个进程内,甚至一个计算机内通过本地调用的方式完成的需求,比如不同的系统间的通讯,甚至不同的组织间的通讯,由于计算能力需要横向扩展,需要在多台机器组成的集群上部署应用。RPC就是要像调用本地的函数一样去调远程函数;
Dubbo及zookeeper安装
zookeeper
zookeeper下载:Apache下载地址
解压bin目录下运行:
可能会遇到闪退情况!
编辑zkServer.cmd
,加入以下代码
再次运行可以看到完整报错
conf/zoo.cfg
目录下缺少以下文件
进入conf
目录
再次启动即可!!
使用zkCli.cmd
测试
ls:/ 列出zookeeper下所有节点
create -e /kuangshen 123
创建一个节点
get /kuangshen
查看内容
Dubbo
dubbo本身并不是一个服务软件。它其实就是一个jar包,能够帮你的java程序连接到zookeeper,并利用zookeeper消费、提供服务。
但是为了让用户更好的管理监控众多的dubbo服务,官方提供了一个可视化的监控程序dubbo-admin,不过这个监控即使不装也不影响使用。
Dubbo下载地址:Gitub下载
解压完在目录下
# CMD执行 打成jar包
mvn clean package -Dmaven.test.skip=true
服务注册发现
创建springBoot项目-服务提供者
编写接口
public interface TicketService {
public String getTicket();
}
编写实现类
@Service
public class TicketServiceImpl implements TicketService {
@Override
public String getTicket() {
return "狂神";
}
}
创建springBoot项目-服务消费者
public interface UserService {
//拿到另外一个项目的数据
}
在两个项目中导入依赖
<!-- dubbo- Springboot整合 -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.8</version>
</dependency>
<!-- zookeeper 客户端 -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
新版的坑:zookeeper及其依赖包,解决日志冲突,还需要剔除日志依赖;
<!--引入zookeeper-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
配置Dubbo
# 服务应用名
dubbo.application.name=provider-server
# 注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 哪些服务要被注册
dubbo.scan.base-packages=com.tony.bubbo1.service
我们需要更改一下service
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
@Service //不要使用spring service注解 service注解应该使用dubbo包下 这样项目启动就可以自动注册到注册中心
@Component //使用Dubbo后 service层使用此注解注册到容器
public class TicketServiceImpl implements TicketService{
@Override
public String getTicket() {
return "狂神";
}
}