柚子快報激活碼778899分享：dubbo高級教程

http://yzkb.51969.com/

dubbo高級應(yīng)用

集群容錯

容錯模式

1.Failover Cluster:失敗自動切換,服務(wù)調(diào)用失敗后,會切換到集群中其他機(jī)器進(jìn)行重試, 默認(rèn)重試次數(shù)為2,retries=2,可以修改次數(shù) 重試次數(shù)增加會帶來更長的響應(yīng)延時 適用讀操作,事物型操作會帶來數(shù)據(jù)重復(fù) 2.Failfast Cluster:快速失敗,服務(wù)調(diào)用失敗,立即報錯 只發(fā)起一次調(diào)用,適用:冪等,例如新增數(shù)據(jù) 當(dāng)服務(wù)調(diào)用失敗,可能這個請求已經(jīng)在服務(wù)器端處理成功 因為網(wǎng)絡(luò)延遲導(dǎo)致響應(yīng)失敗 3.Failsafe Cluster:失敗安全,出現(xiàn)異常時,直接忽略異常 4.Failback cluster: 失敗后自動回復(fù),服務(wù)調(diào)用出現(xiàn)異常時,后臺記錄這條失敗的請求.定時重發(fā) 適用于消息通知操作,保證這個請求一定發(fā)送成功 5.Forking Cluster:并行調(diào)用集群中多個服務(wù),只要其中一個成功就返回,forks=2設(shè)置最大并行數(shù) 6.Broadcast Cluster:廣播調(diào)用所有的服務(wù)提供者,任意一個服務(wù)報錯則表示服務(wù)調(diào)用失敗 適用于,通知所有服務(wù)提供者更新緩存或本地資源信息

配置方式

@Service(retries = 3)

public class IHelloServiceImpl implements IHelloService {

@Value("${dubbo.application.name}")

private String serverName;

@Override

public String sayHello(String name) {

return "hello," + name + ", serverName:" + serverName;

}

}

實(shí)際應(yīng)用中, 查詢語句容錯建議使用默認(rèn)failover cluster 增刪改建議使用: Failfast cluster或者Failover Cluster(retries=“0”)

負(fù)載均衡

訪問量較大情況下, 通過水平擴(kuò)容的方式增加多個節(jié)點(diǎn)來平衡請求流量 軟件負(fù)載均衡目前比較主流是nginx 提供4種策略,默認(rèn)策略 random 1.Random:隨機(jī)算法,針對性能較好的服務(wù)器設(shè)置較大的權(quán)重值 權(quán)重值越大,隨機(jī)的概率也會越大 2.RoundRobin:輪詢,按照公約后的權(quán)重設(shè)置輪詢比例 3.LeastActive:最少活躍調(diào)用數(shù),處理較慢節(jié)點(diǎn)將會收到更少請求 4.ConsistentHash:一致性hash,相同參數(shù)的請求總發(fā)送到同一個服務(wù)提供者

配置方式

@Service(retries = 3,cluster = "failover",loadbalance = "roundrobin")

服務(wù)降級

服務(wù)器訪問壓力較大時,對不重要的服務(wù)進(jìn)行降級 分類： 是否可自動化分:自動降級,人工降級 功能分:讀服務(wù)降級,寫服務(wù)降級 人工降級具有前置性,在電商大促之前,關(guān)閉某些非核心服務(wù) 自動降級:系統(tǒng)出現(xiàn)某些異常時,自動觸發(fā)兜底流暢 1.故障降級:調(diào)用遠(yuǎn)程服務(wù)掛了,設(shè)置兜底數(shù)據(jù)響應(yīng)給客戶端 2.服務(wù)降級:對核心業(yè)務(wù)進(jìn)行限流 當(dāng)請求流量達(dá)到閾值時,后續(xù)請求被攔截,這些請求進(jìn)入排隊系統(tǒng) dubbo提供Mock配置實(shí)現(xiàn)服務(wù)降級 當(dāng)服務(wù)提供方出現(xiàn)網(wǎng)絡(luò)異常,無法訪問時,客戶端不拋出異常 通過降級配置返回兜底數(shù)據(jù) spring-cloud-dubbo-consumer創(chuàng)建MockHelloService類 需要實(shí)現(xiàn)自動降級接口即可

@RestController

@RequestMapping("/consumer")

public class IHelloServiceImpl {

@Reference(

mock = "com.zyl.consumer.service.MockIHelloService",

cluster = "failover"

)

private IHelloService helloService;

@GetMapping("/say")

public String say() {

return helloService.sayHello("zyl");

}

}

主機(jī)綁定規(guī)則

dubbo服務(wù)對外發(fā)布的ip地址,默認(rèn)情況下,dubbo按照以下順序查找并綁定主機(jī)ip地址 1.查找環(huán)境變量中DUBBO_IP_TO_BIND屬性配置的ip地址 2.查找dubbo.protocol.host屬性配置的ip地址,默認(rèn)是空,如果沒有配置或者ip地址不合法, 繼續(xù)向下查找 3.通過LocalHost.getHostAddress()獲取本機(jī)ip地址,如果獲取失敗,繼續(xù)向下查找 4.如果配置了注冊中心的地址,使用socket通信連接到注冊中心的地址后,使用for循環(huán)通過 socket.getLocalAddress().getHostAddress()掃描各個網(wǎng)卡獲取ip地址 注意:獲取的ip地址并不是寫入注冊中心的地址, 默認(rèn)情況下,寫入注冊中心的ip地址,優(yōu)先選擇環(huán)境變量中DUBBO_IP_TO_REGISTRY屬性配置的ip地址,在這個屬性沒有配置的情況下,才會選擇前面獲取的ip地址寫入注冊中心 建議通過dubbo.protocol.host設(shè)置主機(jī)地址 建議制定一個dubbo端口號,避免和其他dubbo服務(wù)的端口產(chǎn)生沖突

柚子快報激活碼778899分享：dubbo高級教程

http://yzkb.51969.com/

相關(guān)文章