技术研究之Grpc

标签: 无 分类: 未分类 创建时间:2024-11-03 06:08:30 更新时间:2025-01-17 10:39:23

1.异步java客户端

参考文章:
【1】.grpc client server Callback方式异步java实现
【2】.gRPC python 教程(四) 异步gRPC的实现 异步gRPC与之前普通方式gRPC实际过程基本一致,主要的区别如下:异步server构造器不需要线程池参数,异步协程是在同1个线程中执行;异步gRPC要求接口函数及调用都使用 async – await 来修饰;异步gRPC要求接口函数及调用都使用 async – await 来修饰
【3】.gRPC在Python的异步非阻塞实现方式 这里有一个 asyncio 和 aio 的不同的写法。

2.UNAVAILABLE: Too many pings

在执行长时间任务的时候,就会出现这个问题。

后来我发现好像是我配置的问题,这里的两个参数,后来我经过资料理解,我觉得应该是这样的 keepAliveTime:多长时间请求一次,keepAliveTimeout:每次请求后多长时间没有响应算是超时。

1
2
3
4
5
6
7
client:
grpc-ai:
address: static://localhost:40051 # gRPC服务地址
negotiation-type: plaintext
enableKeepAlive: true # 是否启用KeepAlive机制
keepAliveTime: 30s # KeepAlive时间
keepAliveTimeout: 5s # 是否在没有gRPC调用时保持KeepAlive的连接

我尝试修改了 python 服务端的配置。

1
2
3
4
5
6
7
8
9
10
11
12
server_options = [
("grpc.keepalive_time_ms", 20000),
("grpc.keepalive_timeout_ms", 10000),
("grpc.http2.min_ping_interval_without_data_ms", 5000),
("grpc.max_connection_idle_ms", 10000),
("grpc.max_connection_age_ms", 30000),
("grpc.max_connection_age_grace_ms", 5000),
("grpc.http2.max_pings_without_data", 5),
("grpc.keepalive_permit_without_calls", 1),
("grpc.http2.max_ping_strikes",0),
]
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10),options=server_options)

【解决方案】
最后在 python 服务端配置了 (“grpc.http2.max_ping_strikes”,0) 这个解决了问题。

参考文章:
【1】.配置
【2】.GRPC KeepAlive 设置参数
【3】.Grpc Error on Long Connections: Too Many Pings 这里有一个参数就是 grpc.http2.max_ping_strikes,但是我使用java不知道怎么设置。
【4】.grpc keepalive使用指南 GRPC_ARG_HTTP2_MAX_PING_STRIKES:此arg控制在发送HTTP2 GOAWAY帧并关闭传输之前,服务器允许的错误ping的最大数量。将其设置为0允许服务器接受任意数量的错误ping。(注:也就是达到这个数量的ping strike就会发送GOWAY帧–用于发起关闭连接的请求,或者警示严重错误。GOAWAY 会停止接收新流,并且关闭连接前会处理完先前建立的流)
【5】.Keepalive 这里有 python、java 等的grpc配置,我在这里找到了 grpc.http2.max_pings_without_data 配置
【6】.gRPC connection: use keepAlive or idleTimeout? keepAliveWithoutCalls is used
【7】.gRPC:too many pings 1.client和server都不开启PERMIT_KEEPALIVE_WITHOUT_CALLS。2.client的keepalive time小于10s(GRPC_ARG_KEEPALIVE_TIME_MS最小值是10s)
小额赞助
本人提供免费与付费咨询服务,感谢您的支持!赞助请发邮件通知,方便公布您的善意!
**光 3.01 元
Sun 3.00 元
bibichuan 3.00 元
微信公众号
广告位
诚心邀请广大金主爸爸洽谈合作
每日一省
isNaN 和 Number.isNaN 函数的区别?

1.函数 isNaN 接收参数后,会尝试将这个参数转换为数值,任何不能被转换为数值的的值都会返回 true,因此非数字值传入也会返回 true ,会影响 NaN 的判断。

2.函数 Number.isNaN 会首先判断传入参数是否为数字,如果是数字再继续判断是否为 NaN ,不会进行数据类型的转换,这种方法对于 NaN 的判断更为准确。

每日二省
为什么0.1+0.2 ! == 0.3,如何让其相等?

一个直接的解决方法就是设置一个误差范围,通常称为“机器精度”。对JavaScript来说,这个值通常为2-52,在ES6中,提供了Number.EPSILON属性,而它的值就是2-52,只要判断0.1+0.2-0.3是否小于Number.EPSILON,如果小于,就可以判断为0.1+0.2 ===0.3。

每日三省
== 操作符的强制类型转换规则?

1.首先会判断两者类型是否**相同,**相同的话就比较两者的大小。

2.类型不相同的话,就会进行类型转换。

3.会先判断是否在对比 null 和 undefined,是的话就会返回 true。

4.判断两者类型是否为 string 和 number,是的话就会将字符串转换为 number。

5.判断其中一方是否为 boolean,是的话就会把 boolean 转为 number 再进行判断。

6.判断其中一方是否为 object 且另一方为 string、number 或者 symbol,是的话就会把 object 转为原始类型再进行判断。

每日英语
Happiness is time precipitation, smile is the lonely sad.
幸福是年华的沉淀,微笑是寂寞的悲伤。