亚洲免费在线视频-亚洲啊v-久久免费精品视频-国产精品va-看片地址-成人在线视频网

您的位置:首頁技術(shù)文章
文章詳情頁

Python grpc超時(shí)機(jī)制代碼示例

瀏覽:7日期:2022-07-11 11:34:45

工作中遇到一個(gè)問題,上游服務(wù)通過grpc調(diào)用下游服務(wù),但是由于下游服務(wù)負(fù)載太高導(dǎo)致上游服務(wù)的調(diào)用會(huì)隨機(jī)出現(xiàn)超時(shí)的情況,但是有一點(diǎn)不太明確:超時(shí)之后,下游服務(wù)還會(huì)繼續(xù)進(jìn)行計(jì)算么?

于是自己寫了一個(gè)damon試了一下:

client:

# Copyright 2015 gRPC authors.## Licensed under the Apache License, Version 2.0 (the 'License');# you may not use this file except in compliance with the License.# You may obtain a copy of the License at## http://www.apache.org/licenses/LICENSE-2.0## Unless required by applicable law or agreed to in writing, software# distributed under the License is distributed on an 'AS IS' BASIS,# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.# See the License for the specific language governing permissions and# limitations under the License.'''The Python implementation of the GRPC helloworld.Greeter client.'''from __future__ import print_functionimport loggingimport grpcimport helloworld_pb2import helloworld_pb2_grpcdef run(): # NOTE(gRPC Python Team): .close() is possible on a channel and should be # used in circumstances in which the with statement does not fit the needs # of the code. with grpc.insecure_channel(’localhost:50051’) as channel: stub = helloworld_pb2_grpc.GreeterStub(channel) response = stub.SayHello(helloworld_pb2.HelloRequest(name=’you’), timeout=30) print('Greeter client received: ' + response.message)if __name__ == ’__main__’: logging.basicConfig() run()

server:

# Copyright 2015 gRPC authors.## Licensed under the Apache License, Version 2.0 (the 'License');# you may not use this file except in compliance with the License.# You may obtain a copy of the License at## http://www.apache.org/licenses/LICENSE-2.0## Unless required by applicable law or agreed to in writing, software# distributed under the License is distributed on an 'AS IS' BASIS,# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.# See the License for the specific language governing permissions and# limitations under the License.'''The Python implementation of the GRPC helloworld.Greeter server.'''from concurrent import futuresimport timeimport loggingimport grpcimport helloworld_pb2import helloworld_pb2_grpc_ONE_DAY_IN_SECONDS = 60 * 60 * 24class Greeter(helloworld_pb2_grpc.GreeterServicer): def SayHello(self, request, context): count = 0 while count < 10: print(’time:%s’ % (time.time())) time.sleep(5) return helloworld_pb2.HelloReply(message=’Hello, %s!’ % request.name)def serve(): server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) helloworld_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server) server.add_insecure_port(’[::]:50051’) server.start() try: while True: time.sleep(_ONE_DAY_IN_SECONDS) except KeyboardInterrupt: server.stop(0)if __name__ == ’__main__’: logging.basicConfig() serve()

這兩個(gè)例子就是在grpc官方提供的python例子上做了一下小的改動(dòng),得到的結(jié)果是:當(dāng)client超時(shí)報(bào)錯(cuò)退出之后,server還是會(huì)繼續(xù)進(jìn)行計(jì)算,直到結(jié)束,那如果是這樣的話,超時(shí)的機(jī)制對(duì)于server來說是沒有作用的,即使client已經(jīng)不再等待這個(gè)結(jié)果了,但是server還是會(huì)繼續(xù)計(jì)算,浪費(fèi)server的資源。

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 亚洲一区视频在线播放 | 亚洲逼 | 亚洲www色| 国产永久在线视频 | 精品一区二区三区的国产在线观看 | 欧美一级看片 | 亚洲第一大网站 | 国产成人福利免费观看 | 久久在线观看免费视频 | 精品视频99 | a级毛片免费完整视频 | 国产精品资源 | 美国一级片免费看 | 欧美日韩精品一区二区三区高清视频 | 亚州综合网 | 亚洲福利视频精选在线视频 | 久久久久久免费观看 | 在线免费黄色网址 | 久久亚洲不卡一区二区 | 黄色美女网站免费看 | 怡红院亚洲怡红院首页 | 在线成人97观看 | 国产a国产 | 亚洲免费视频网站 | 色网址在线 | 午夜精| 国产日韩久久久精品影院首页 | 91九色首页| 久久综合狠狠综合久久综合88 | 久草福利资源 | 成人欧美在线视频 | 模特视频一二三区 | 亚洲精品中文字幕一区 | 日韩欧美理论片 | 日韩视频在线观看一区二区 | 久久久夜间小视频 | 三级黄网 | 高清三级毛片 | 国产无套视频在线观看香蕉 | 免费高清一级欧美片在线观看 | 日本丶国产丶欧美色综合 |