1. Dubbo

1.1 Dubbo介紹

Apache Dubbo |?d?b??| 是一款高性能、輕量級的開源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;

@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 "用戶入庫成功!!!";
	}
}

2.3.2 編輯YML組態檔

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

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負載均衡方式

@RestController
public 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: 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  #每一個服務都有自己特定的埠 不能重復.

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: .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

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

4.4.5 頁面效果展現

在這里插入圖片描述

轉載請註明出處，本文鏈接：https://www.uj5u.com/qukuanlian/184035.html

標籤：區塊鏈

上一篇：在就業創業中，您覺得最重要的是什么？

下一篇：Python 讓我再次在女同學面前長臉了！（真實案例）

2006-京淘Day18

1. 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 頁面效果展現

2.4.1 問題1:如果其中一個服務器宕機用戶訪問是否受限?