- Dubbo
=========
1.1 Dubbo介绍
Apache Dubbo |db| 是一款高性能、轻量级的开源Java RPC框架，它提供了三大外围能力：面向接口的近程办法调用，智能容错和负载平衡，以及服务主动注册和发现。
1.2 Dubbo特点
2 Dubbo入门案例
2.1 定义公共接口我的项目
阐明:接口我的项目个别定义公共的局部,并且被第三方依赖.
2.2 服务提供者介绍
2.2.1 提供者代码构造
2.2.2 编辑实现类
`package com.jt.dubbo.service;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import com.alibaba.dubbo.config.annotation.Service;import com.jt.dubbo.mapper.UserMapper;import com.jt.dubbo.pojo.User;@Service(timeout=3000) //3秒超时 外部实现了rpc//@org.springframework.stereotype.Service//将对象交给spring容器治理public class UserServiceImpl implements UserService { @Autowired private UserMapper userMapper; @Override public List<User> findAll() { System.out.println("我是第一个服务的提供者"); return userMapper.selectList(null); } @Override public void saveUser(User user) { userMapper.insert(user); }}` 2.2.3 编辑提供者配置文件
`server: port: 9000 #定义端口spring: datasource: #引入druid数据源 type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://127.0.0.1:3306/jtdb?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true username: root password: root#对于Dubbo配置 dubbo: scan: basePackages: com.jt #指定dubbo的包门路 扫描dubbo注解 application: #利用名称 name: provider-user #一个接口对应一个服务名称 一个接口能够有多个实现 registry: #注册核心 用户获取数据从机中获取 主机只负责监控整个集群 实现数据同步 address: zookeeper://192.168.126.129:2181?backup=192.168.126.129:2182,192.168.126.129:2183 protocol: #指定协定 name: dubbo #应用dubbo协定(tcp-ip) web-controller间接调用sso-Service port: 20880 #每一个服务都有本人特定的端口 不能反复. mybatis-plus: type-aliases-package: com.jt.dubbo.pojo #配置别名包门路 mapper-locations: classpath:/mybatis/mappers/*.xml #增加mapper映射文件 configuration: map-underscore-to-camel-case: true #开启驼峰映射规定` 2.3 服务消费者介绍
2.3.1 编辑Controller
`package com.jt.dubbo.controller;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import com.alibaba.dubbo.config.annotation.Reference;import com.jt.dubbo.pojo.User;import com.jt.dubbo.service.UserService;@RestControllerpublic class UserController { //利用dubbo的形式为接口创立代理对象 利用rpc调用 @Reference private UserService userService; /** * Dubbo框架调用特点:近程RPC调用就像调用本人本地服务一样简略 * @return */ @RequestMapping("/findAll") public List<User> findAll(){ //近程调用时传递的对象数据必须序列化. return userService.findAll(); } @RequestMapping("/saveUser/{name}/{age}/{sex}") public String saveUser(User user) { userService.saveUser(user); return "用户入库胜利!!!"; }}` 2.3.2 编辑YML配置文件
`server: port: 9001dubbo: scan: basePackages: com.jt application: name: consumer-user #定义消费者名称 registry: #注册核心地址 address: zookeeper://192.168.126.129:2181?backup=192.168.126.129:2182,192.168.126.129:2183` 2.3.3 Dubbo入门案例测试
2.4 对于Dubbo框架知识点
2.4.1 问题1:如果其中一个服务器宕机 用户拜访是否受限?
答:因为zk的帮忙,使得程序永远能够拜访正确的服务器.并且当服务重启时,duboo有服务的主动发现性能,消费者不须要重启即能够拜访新的服务.
2.4.2 问题2:如果ZK集群短时间宕机,用户拜访是否受限?
答: 用户的拜访不受影响,因为消费者在本地存储服务列表信息,当拜访故障机时,主动的将标识信息改为down属性.
2.5 Dubbo负载平衡策略
2.5.1 负载平衡品种
1.客户端负载平衡
Dubbo/SpringCloud等微服务框架
2.服务端负载平衡
阐明:客户端发动申请之后,必须由对立的服务器进行负载平衡,所有的压力都在服务器中.
NGINX
2.5.2 Dubbo负载平衡形式
`@RestControllerpublic class UserController { //利用dubbo的形式为接口创立代理对象 利用rpc调用 //@Reference(loadbalance = "random") //默认策略 负载平衡随机策略 //@Reference(loadbalance = "roundrobin") //轮询形式 //@Reference(loadbalance = "consistenthash") //一致性hash 消费者绑定服务器提供者 @Reference(loadbalance = "leastactive") //筛选以后负载小的服务器进行拜访 private UserService userService; }` 3 京淘我的项目Dubbo革新
3.1 革新JT-SSO
3.1.1 增加jar包文件
`<!--引入dubbo配置 --> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>0.2.0</version> </dependency>` 3.1.2 创立DubboUserService接口
3.1.3 创立提供者实现类
3.1.3 编辑提供者YML配置文件
`server: port: 8093 servlet: context-path: /spring: datasource: #引入druid数据源 #type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://127.0.0.1:3306/jtdb?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true username: root password: root mvc: view: prefix: /WEB-INF/views/ suffix: .jsp#mybatis-plush配置mybatis-plus: type-aliases-package: com.jt.pojo mapper-locations: classpath:/mybatis/mappers/*.xml configuration: map-underscore-to-camel-case: truelogging: level: com.jt.mapper: debug#对于Dubbo配置dubbo: scan: basePackages: com.jt #指定dubbo的包门路 扫描dubbo注解 application: #利用名称 name: provider-user #一个接口对应一个服务名称 一个接口能够有多个实现 registry: #注册核心 用户获取数据从机中获取 主机只负责监控整个集群 实现数据同步 address: zookeeper://192.168.126.129:2181?backup=192.168.126.129:2182,192.168.126.129:2183 protocol: #指定协定 name: dubbo #应用dubbo协定(tcp-ip) web-controller间接调用sso-Service port: 20880 #每一个服务都有本人特定的端口 不能反复.` 3.1.4 启动服务提供者
测试Dubbo服务器启动是否失常.
3.2 革新服务消费者JT-WEB
3.2.1 注入Service接口
3.2.2 编辑消费者配置文件
`server: port: 8092 spring: #定义springmvc视图解析器 mvc: view: prefix: /WEB-INF/views/ suffix: .jspdubbo: scan: basePackages: com.jt application: name: consumer-web #定义消费者名称 registry: #注册核心地址 address: zookeeper://192.168.126.129:2181?backup=192.168.126.129:2182,192.168.126.129:2183` 3.2.3 启动成果测试
4.用户模块实现
4.1 用戶注册
4.1.1 URL剖析
依据url地址阐明申请为同域申请.
参数信息:
4.1.2 页面JS剖析
阐明:依据剖析获取返回值数据信息应该为SysResult对象
4.1.3 编辑UserController
`/** * 需要: 实现用户信息注册 * 1.url申请地址: http://www.jt.com/user/doRegister * 2.申请参数: {password:_password,username:_username,phone:_phone}, * 3.返回值后果: SysResult对象 */ @RequestMapping("/doRegister") @ResponseBody //将数据转化为JSON public SysResult saveUser(User user){ //消费者给予dubbo协定将user对象进行近程网络数据传输. userService.saveUser(user); return SysResult.success(); }` 4.1.4 编辑UserService
`/** * 注意事项: * 1.临时应用电话号码代替邮箱 * 2.明码进行md5加密. * 3.入库操作留神事务管制 * @param user */ @Override public void saveUser(User user) { String md5Pass = DigestUtils.md5DigestAsHex(user.getPassword().getBytes()); user.setEmail(user.getPhone()) .setPassword(md5Pass); userMapper.insert(user); }` 4.1.5 页面成果展示
4.2 对于ZK数据存储构造
阐明:在zk中数据的存储采纳树形构造的形式保留
命令: [root@localhost bin]# sh zkCli.sh
查问命令: ls /…
4.3 用户单点登录原理介绍
4.3.1 传统形式登录存在的问题
阐明: 如果采纳SESSION的形式实现用户的登录操作,因为nginx负载平衡的策略,用户能够拜访不同的服务器.然而Session不能共享,所以导致用户频繁的登录. 用户的体验不好.
4.3.2 SSO
单点登录(SingleSignOn，SSO)，就是通过用户的一次性甄别登录。当用户在身份认证服务器上登录一次当前，即可取得拜访单点登录零碎中其余关联系统和应用软件的权限，同时这种实现是不须要管理员对用户的登录状态或其余信息进行批改的，这意味着在多个利用零碎中，用户只需一次登录就能够拜访所有相互信任的利用零碎。这种形式缩小了由登录产生的工夫耗费，辅助了用户治理，是目前比拟风行的 [1]
4.3.3 京淘我的项目单点登录设计
实现步骤:
1.当用户输出用户名和明码点击登录时,将申请发送给JT-WEB消费者服务器.
2.JT-WEB服务器将用户信息传递给JT-SSO单点登录零碎实现数据校验.
3.如果登录胜利,则动静生成密钥信息,将user数据转化为json.保留到redis中. 留神超时工夫的设定.
4.JT-SSO将登录的凭证 传给JT-WEB服务器.
5.JT-WEB服务器将用户密钥TICKET信息保留到用户的cookie中 留神超时工夫设定.
6.如果登录不胜利,则间接返回错误信息即可.
4.4 用户单点登录实现
4.4.1 页面url剖析
4.4.2 页面参数剖析
4.4.3 页面JS剖析
4.4.4 编辑UserController
`/** * 实现用户登录操作 * 1.url地址: http://www.jt.com/user/doLogin?r=0.9309436837648131 * 2.参数: {username:_username,password:_password}, * 3.返回值后果: SysResult对象 * * 4.Cookie: * 4.1 setPath("/") path示意如果须要获取cookie中的数据,则url地址所在门路设定. * url:http://www.jt.com/person/findAll * cookie.setPath("/"); 个别都是/ * cookie.setPath("/person"); * 4.2 setDomain("xxxxx") 设定cookie共享的域名地址. */ @RequestMapping("/doLogin") @ResponseBody public SysResult doLogin(User user, HttpServletResponse response){ String ticket = userService.doLogin(user); if(StringUtils.isEmpty(ticket)){ //阐明用户名或者明码谬误 return SysResult.fail(); }else{ //1.创立Cookie Cookie cookie = new Cookie("JT_TICKET",ticket); cookie.setMaxAge(7*24*60*60); //设定cookie存活有效期 cookie.setPath("/"); //设定cookie无效范畴 cookie.setDomain("jt.com"); //设定cookie共享的域名 是实现单点登录必备因素 response.addCookie(cookie); return SysResult.success(); //示意用户登录胜利!! } }` 4.4.5 编辑UserService
`/** * 1.获取用户信息校验数据库中是否有记录 * 2.有 开始执行单点登录流程 * 3.没有 间接返回null即可 * @param user * @return */ @Override public String doLogin(User user) { //username/password //1.将明文加密 String md5Pass = DigestUtils.md5DigestAsHex(user.getPassword().getBytes()); user.setPassword(md5Pass); QueryWrapper<User> queryWrapper = new QueryWrapper<>(user); //依据对象中不为null的属性当做where条件. User userDB = userMapper.selectOne(queryWrapper); if(userDB == null){ //用户名或明码谬误 return null; }else{ //用户名和明码正确 实现单点登录操作 String ticket = UUID.randomUUID().toString(); //如果将数据保留到第三方 个别须要脱敏解决 userDB.setPassword("123456你信不??"); String userJSON = ObjectMapperUtil.toJSON(userDB); jedisCluster.setex(ticket, 7*24*60*60, userJSON); return ticket; } }`