ywj1352 opened a new pull request, #5596: URL: https://github.com/apache/shenyu/pull/5596
<!-- Describe your PR here; e.g. Fixes #issueNo --> <!-- Thank you for proposing a pull request. This template will guide you through the essential steps necessary for a pull request. --> Make sure that: - [ ] You have read the [contribution guidelines](https://shenyu.apache.org/community/contributor-guide). - [ ] You submit test cases (unit or integration tests) that back your changes. - [ ] Your local test passed `./mvnw clean install -Dmaven.javadoc.skip=true`. #### Reason Originally used selector#handler to handle health checks on UpstreamCheckService. discovery module should be switched to discoveryupstream on UpstreamCheckService Up processing #### Display of the effect after integration The simulation currently has 2 upstreams <br/> <img width="1203" alt="image" src="https://github.com/user-attachments/assets/988d9b52-309e-42a1-a4fc-946165ab768e";> Forcing process killing simulates an upstream outage <br/> `kill -9 90824` UpstreamCheckService finds dropped upstreams <br/> <img width="1657" alt="image" src="https://github.com/user-attachments/assets/38139503-a8e6-4f01-b797-7110697cf0db";> Display as [status = close] in the adminservice. <br/> <img width="1145" alt="image" src="https://github.com/user-attachments/assets/0fbccf92-5003-4987-afd0-1422f04eb658";> And sync to the Gateway<br/> `2024-07-16 15:37:14 [WebSocketConnectReadThread-123] INFO org.apache.shenyu.plugin.sync.data.websocket.client.ShenyuWebsocketClient - server [ws://localhost:9095/websocket] handleResult({"groupType":"DISCOVER_UPSTREAM","eventType":"UPDATE","data":[{"selectorId":"1813106763444461568","pluginName":"divide","selectorName":"/http","upstreamDataList":[{"id":"1813114999073611777","dateCreated":"2024-07-16 15:34:36","dateUpdated":"2024-07-16 15:34:36","discoveryHandlerId":"1813106784365649920","protocol":"http://","url":"192.168.8.188:9890","status":0,"weight":50,"props":"{\"warmupTime\":\"10\"}"}]}]})` Restart the killed service again <br/> UpstreamCheckService reverts to the Upstream health check console recovery state <br/> <img width="1098" alt="image" src="https://github.com/user-attachments/assets/d9f41420-b88e-4876-b320-c4b01097ca18";> And sync to the Gateway<br/> ` 2024-07-16 15:39:02 [WebSocketConnectReadThread-123] INFO org.apache.shenyu.plugin.sync.data.websocket.client.ShenyuWebsocketClient - server [ws://localhost:9095/websocket] handleResult({"groupType":"SELECTOR","eventType":"UPDATE","data":[{"id":"1813106763444461568","pluginId":"5","pluginName":"divide","name":"/http","matchMode":0,"type":1,"sort":1,"enabled":true,"logged":true,"continued":true,"handle":"[{\"weight\":50,\"warmup\":600000,\"protocol\":\"http://\",\"upstreamHost\":\"localhost\",\"upstreamUrl\":\"192.168.8.188:9890\",\"status\":true,\"timestamp\":1721113459447},{\"weight\":50,\"warmup\":600000,\"protocol\":\"http://\",\"upstreamHost\":\"localhost\",\"upstreamUrl\":\"192.168.8.188:9879\",\"status\":true,\"timestamp\":1721115538399}]","conditionList":[{"paramType":"uri","operator":"startsWith","paramName":"/","paramValue":"/http/"}],"beforeConditionList":[],"matchRestful":false}]}) 2024-07-16 15:39:02 [WebSocketConnectReadThread-123] INFO org.apache.shenyu.plugin.base.cache.CommonPluginDataSubscriber - subscribe select data for selector: [id: 1813106763444461568, pluginName: divide, name: /http] 2024-07-16 15:39:02 [WebSocketConnectReadThread-123] INFO org.apache.shenyu.plugin.sync.data.websocket.client.ShenyuWebsocketClient - server [ws://localhost:9095/websocket] handleResult({"groupType":"DISCOVER_UPSTREAM","eventType":"UPDATE","data":[{"selectorId":"1813106763444461568","pluginName":"divide","selectorName":"/http","upstreamDataList":[{"id":"1813114999073611776","dateCreated":"2024-07-16 15:34:36","dateUpdated":"2024-07-16 15:38:58","discoveryHandlerId":"1813106784365649920","protocol":"http://","url":"192.168.8.188:9879","status":0,"weight":50,"props":"{\"warmupTime\":\"10\"}"},{"id":"1813114999073611777","dateCreated":"2024-07-16 15:34:36","dateUpdated":"2024-07-16 15:34:36","discoveryHandlerId":"1813106784365649920","protocol":"http://","url":"192.168.8.188:9890","status":0,"weight":50,"props":"{\"warmupTime\":\"10\"}"}]}]}) ` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@shenyu.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
