1.HttpClient遠程呼叫說明
1.1 需求說明:
需求:根據userId查詢用戶的資訊.
1.用戶的url地址: http://www.jt.com/findUserById/7;
2.需要在jt-web的Controller中動態的接收資料.將請求轉給sso單點登錄系統
url:http://sso.jt.com/findUserById/7
3.在jt-sso中的Controller根據userId查詢用戶資訊.
1.2 編輯jt-web Controller
/**
* 為了測驗httpClient 實作業務功能查詢用戶資訊
* url地址:http://www.jt.com/user/findUserById/7
* 引數: 7用戶ID
* 回傳值: user物件
*/
@RequestMapping("/findUserById/{userId}")
@ResponseBody
public User findUserById(@PathVariable Long userId){
return userService.findUserById(userId);
}
1.3 編輯前端 Service
@Service
public class UserServiceImpl implements UserService{
/**
* 由jt-web向jt-sso進行資料的請求.之后獲取資料.
* @param userId
* @return
*/
@Override
public User findUserById(Long userId) {
//1.定義url地址
String url = "http://sso.jt.com/user/findUserById/"+userId;
HttpClient httpClient = HttpClients.createDefault();
HttpGet httpGet = new HttpGet(url);
try {
HttpResponse httpResponse = httpClient.execute(httpGet);
if(httpResponse.getStatusLine().getStatusCode() == 200){
HttpEntity httpEntity = httpResponse.getEntity();
//json格式
String result = EntityUtils.toString(httpEntity, "UTF-8");
return ObjectMapperUtil.toObject(result, User.class);
}else{
throw new RuntimeException("請求失敗,請校驗地址資訊");
}
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}
1.4 編輯后端 Controller
/**
* 測驗httpClient呼叫方式
* url地址: http://sso.jt.com/user/findUserById/"+userId
* 回傳: user物件的JSON資料
*/
@RequestMapping("/findUserById/{userId}")
public User findUserById(@PathVariable Long userId){
return userService.findUserById(userId);
}
1.5 編輯后端 Service
@Override
public User findUserById(Long userId) {
return userMapper.selectById(userId);
}
1.6 HttpClient呼叫流程圖
2.Dubbo
2.1SOA思想
知識回顧: 面向物件的思想/ 面向介面開發 /面向切面開發 /面向服務開發
面向服務的架構（SOA）是一個組件模型，它將應用程式的不同功能單元（稱為服務）進行拆分，并通過這些服務之間定義良好的介面和協議聯系起來，介面是采用中立的方式進行定義的，它應該獨立于實作服務的硬體平臺、作業系統和編程語言，這使得構件在各種各樣的系統中的服務可以以一種統一和通用的方式進行互動，
概括:SOA思想要求按照業務將服務進行拆分,之后按照同一的中立的介面進行互動.
2.2 RPC(概念)
遠程程序呼叫:
在服務之間,由第三方完成自己的任務的程序稱之為遠程程序呼叫.
2.3 微服務呼叫原理說明
標準:
1.根據業務拆分的思想 進行了分布式的設計
2.當服務發生例外時可以自動的實作故障的遷移 無需人為的干預.
2.3.1 傳統服務呼叫方式
說明: 由于nginx做負載均衡時需要依賴組態檔.但是當服務器新增/減少時.都需要手動的修改.不能自動化的實作.所以暫時達不到微服務的標準.
2.3.2 微服務的呼叫原理介紹
步驟:
1.當服務的提供者啟動時,會將自己的服務資訊(服務名稱/IP/埠號)進行記錄
2.服務注冊中心需要記錄提供者的資訊 維護服務串列
3.當服務消費者啟動時會鏈接注冊中心.
4.從注冊中心中獲取服務串列資訊,方便下次呼叫
5.當消費者呼叫服務時,會根據負載均衡的機制挑選其中的一個服務提供者進行訪問.
6.當服務提供者宕機時,由于注冊中心有心跳檢測機制,會維護服務串列.當宕機的提供者標識為down
7.當服務串列維護之后,會全網廣播通知所有服務器的消費者更新服務串列資訊.
2.4 關于集群說明
2.4.1 為什么集群是奇數臺
原則: 搭建集群必須滿足公式 現有的節點數量 > N/2
為什么集群的最小單位是3臺:
假設: 1臺 1-1=0 > 1/2 假的
2臺 2-1=1 > 2/2 假的
3臺 3-1=2 > 3/2 真的 3臺是搭建集群的最小單位.
4臺 4-1=3 > 4/2 真的 只要大約3臺都可以搭建集群.
集群中最多允許宕機的臺數為多少???
3臺最多允許宕機幾臺? 最多宕機1臺
4臺最多允許宕機幾臺? 最多宕機1臺
從實用性的角度考慮問題 發現搭建奇數臺和偶數臺的容災能力相同.所以選用奇數臺.
2.4.2 zk集群選舉的原理
原理說明: zk集群的選舉根據最大值優先的規則,進行選舉. 如果集群一旦超過半數以上的票數同意,則當選主機,同時選舉結束.
問題: 有1,2,3,4,5,6,7節點依次啟動.
問題1: 誰當主機? 4當主機
問題2: 哪幾臺永遠不能當選主機? 1 2 3
2.5 Dubbo框架介紹
2.5.1 官網介紹
Apache Dubbo |?d?b??| 是一款高性能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向介面的遠程方法呼叫，智能容錯和負載均衡，以及服務自動注冊和發現，
2.5.2 Dubbo特性
2.5.3 Dubbo作業原理
2.6 Dubbo入門案例
2.6.1 匯入專案方式
2.6.2 匯入專案
2.6.3 定義公共的第三方介面專案
2.6.3 提供者的說明
2.6.3.1 編輯Dubbo實作類
package com.jt.dubbo.service;
import com.alibaba.dubbo.config.annotation.Service;
import com.jt.dubbo.mapper.UserMapper;
import com.jt.dubbo.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
@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.6.3.2 YML組態檔說明
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的包路徑
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.6.4 服務消費者說明
2.6.4.1 編輯Controller層
package com.jt.dubbo.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.jt.dubbo.pojo.User;
import com.jt.dubbo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
public class UserController {
利用dubbo的方式為介面創建代理物件 利用rpc呼叫
//check=false 先啟動提供者/消費者沒有關系
@Reference(check = false,timeout = 3000) //(loadbalance="leastactive")
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.6.4.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.6.4.3 消費者啟動測驗
2.6.5 關閉Dubbo面試題
問題1: 如果將其中的一個服務的提供者關閉,問 用戶訪問是否受影響?? 不受任何影響
問題2: 如果將dubbo中的注冊中心全部關閉,問用戶訪問是否受到影響??? 不受影響,因為消費者將服務串列資料保存到本地.
作業
-
熟悉Dubbo框架的呼叫原理.
-
自己新創建一個專案要求實作Dubbo的結構.并且實作user的CURD相關操作.
http://xxxxxxxxx:xxx/findUserById
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/78770.html
標籤：其他
上一篇：java注解與反射02_反射
下一篇：京東 9.17筆試題 Java