关于dubbo:第三阶段-Day18-Dubbo-完成用户注册单点登录

115次阅读

共计 7620 个字符，预计需要花费 20 分钟才能阅读完成。

Dubbo

=========

Apache Dubbo |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 框架，它提供了三大外围能力：面向接口的近程办法调用，智能容错和负载平衡，以及服务主动注册和发现。

阐明: 接口我的项目个别定义公共的局部, 并且被第三方依赖.

`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);
    }
}`

`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                #开启驼峰映射规定 `

`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;

@RestController
public 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 "用户入库胜利!!!";
    }
}`

`server:
  port: 9001
dubbo:
  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`

答: 因为 zk 的帮忙, 使得程序永远能够拜访正确的服务器. 并且当服务重启时,duboo 有服务的主动发现性能, 消费者不须要重启即能够拜访新的服务.

答: 用户的拜访不受影响, 因为消费者在本地存储服务列表信息, 当拜访故障机时, 主动的将标识信息改为 down 属性.

1. 客户端负载平衡
Dubbo/SpringCloud 等微服务框架

2. 服务端负载平衡
阐明: 客户端发动申请之后, 必须由对立的服务器进行负载平衡, 所有的压力都在服务器中.
NGINX

`@RestController
public class UserController {
    
    // 利用 dubbo 的形式为接口创立代理对象 利用 rpc 调用
    //@Reference(loadbalance = "random")            // 默认策略  负载平衡随机策略
    //@Reference(loadbalance = "roundrobin")        // 轮询形式
    //@Reference(loadbalance = "consistenthash")    // 一致性 hash  消费者绑定服务器提供者
    @Reference(loadbalance = "leastactive")            // 筛选以后负载小的服务器进行拜访
    private UserService userService; 

}`

 `<!-- 引入 dubbo 配置 -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>`

`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: true

logging:
  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  #每一个服务都有本人特定的端口 不能反复.`

测试 Dubbo 服务器启动是否失常.

`server:
  port: 8092    
spring:     #定义 springmvc 视图解析器
  mvc:
    view:
      prefix: /WEB-INF/views/
      suffix: .jsp

dubbo:
  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`

依据 url 地址阐明申请为同域申请.

参数信息:

阐明: 依据剖析获取返回值数据信息应该为 SysResult 对象

 `/**
     * 需要: 实现用户信息注册
     * 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();}`

`/**
     * 注意事项:
     *  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);
    }`

阐明: 在 zk 中数据的存储采纳 树形构造 的形式保留
命令: [root@localhost bin]# sh zkCli.sh
查问命令: ls /…

阐明: 如果采纳 SESSION 的形式实现用户的登录操作, 因为 nginx 负载平衡的策略, 用户能够拜访不同的服务器. 然而 Session 不能共享, 所以导致用户频繁的登录. 用户的体验不好.

单点登录 (SingleSignOn，SSO)，就是通过用户的一次性甄别登录。当用户在身份认证服务器上登录一次当前，即可取得拜访单点登录零碎中其余关联系统和应用软件的权限，同时这种实现是不须要管理员对用户的登录状态或其余信息进行批改的，这意味着在多个利用零碎中， 用户只需一次登录就能够拜访所有相互信任的利用零碎。这种形式缩小了由登录产生的工夫耗费，辅助了用户治理，是目前比拟风行的 [1]

实现步骤:
1. 当用户输出用户名和明码点击登录时, 将申请发送给 JT-WEB 消费者服务器.
2.JT-WEB 服务器将用户信息传递给 JT-SSO 单点登录零碎实现数据校验.
3. 如果登录胜利, 则动静生成密钥信息, 将 user 数据转化为 json. 保留到 redis 中. 留神超时工夫的设定.
4.JT-SSO 将登录的凭证传给 JT-WEB 服务器.
5.JT-WEB 服务器将用户密钥 TICKET 信息保留到用户的 cookie 中留神超时工夫设定.
6. 如果登录不胜利, 则间接返回错误信息即可.

 `/**
     * 实现用户登录操作
     * 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();     // 示意用户登录胜利!!}
    }`

`/**
     * 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;
        }
    }`

正文完

dubbo

发表至： dubbo

2020-11-09

0

关于dubbo:Whats-new-in-dubbogo-v156

关于dubbo:聊聊dubbogo的DubboPackage

关于dubbo:Dubbo负载均衡策略之一致性哈希-京东云技术团队

关于dubbo:Dubbo-3-深度剖析-透过源码认识你

关于html5:iOS下带小数点的数字键盘

关于dubbo:第三阶段-Day18-Dubbo-完成用户注册单点登录

1.1 Dubbo 介绍

1.2 Dubbo 特点

2 Dubbo 入门案例

2.1 定义公共接口我的项目

2.2 服务提供者介绍

2.2.1 提供者代码构造

2.2.2 编辑实现类

2.2.3 编辑提供者配置文件

2.3 服务消费者介绍

2.3.1 编辑 Controller

2.3.2 编辑 YML 配置文件

2.3.3 Dubbo 入门案例测试

2.4 对于 Dubbo 框架知识点

2.4.1 问题 1: 如果其中一个服务器宕机 用户拜访是否受限?

2.4.2 问题 2: 如果 ZK 集群短时间宕机, 用户拜访是否受限?

2.5 Dubbo 负载平衡策略

2.5.1 负载平衡品种

2.5.2 Dubbo 负载平衡形式

3 京淘我的项目 Dubbo 革新

3.1 革新 JT-SSO

3.1.1 增加 jar 包文件

3.1.2 创立 DubboUserService 接口

3.1.3 创立提供者实现类

3.1.3 编辑提供者 YML 配置文件

3.1.4 启动服务提供者

3.2 革新服务消费者 JT-WEB

3.2.1 注入 Service 接口

3.2.2 编辑消费者配置文件

3.2.3 启动成果测试

4. 用户模块实现

4.1 用戶注册

4.1.1 URL 剖析

4.1.2 页面 JS 剖析

4.1.3 编辑 UserController

4.1.4 编辑 UserService

4.1.5 页面成果展示

4.2 对于 ZK 数据存储构造

4.3 用户单点登录原理介绍

4.3.1 传统形式登录存在的问题

4.3.2 SSO

4.3.3 京淘我的项目单点登录设计

4.4 用户单点登录实现

4.4.1 页面 url 剖析

4.4.2 页面参数剖析

4.4.3 页面 JS 剖析

4.4.4 编辑 UserController

4.4.5 编辑 UserService

4.4.5 页面成果展示

Just My Socks（注册教程 内含优惠码）

2.4.1 问题 1: 如果其中一个服务器宕机用户拜访是否受限?

Just My Socks（注册教程内含优惠码）