后端RPC框架【免费下载链接】finagleA fault tolerant, protocol-agnostic RPC system项目地址https://gitcode.com/gh_mirrors/fi/finagle点击查看免费下载导读finagle-grpc-context是 Finagle 仓库中的一个轻量级 Java 集成模块它通过覆盖 gRPC Java 的Context.Storage默认实现使 gRPC Context 能够像 Twitter Util 的Local一样跨com.twitter.util.Future边界自动传播。读完本文你将掌握 gRPC Context 在异步 RPC 环境下的传播原理、io.grpc.override包名约定的由来、ContextStorageOverride三个核心方法的实现细节以及如何通过测试与构建配置在 Finagle 生态中落地使用这一能力。该模块当前状态为Experimental实验性。一、背景与动机为什么 gRPC Context 需要覆盖 Storage1.1 gRPC Context 与线程本地存储gRPC Java 通过io.grpc.Context承载一次 RPC 调用生命周期内的作用域数据如认证凭据、超时、分布式追踪信息。默认情况下Context依赖ThreadLocal存储这意味着它的生命周期与当前执行线程强绑定。然而 Finagle 的核心编程模型是异步回调式的Future的map、flatMap、transform等组合操作可以在任意线程上执行回调经常被调度到不同的线程池。一旦执行流跨越线程边界基于ThreadLocal的 gRPC Context 就会丢失——这正是该集成要解决的核心问题。1.2 Twitter Util 的 Local异步环境下的线程本地Twitter Util 提供了com.twitter.util.Local作为ThreadLocal的异步替代当你在Local的作用域内创建Future时该Local的值会随Future的执行链传播即使回调被调度到其他线程依然能读到原始作用域里写入的值。这也是 Finagle 自身上下文机制如 LocalContext、Contexts的底层基础。本模块的思路非常直接把 gRPC Context 的存储后端从ThreadLocal换成com.twitter.util.Local让 gRPC Context 获得与Local完全一致的跨 Future 传播能力。正如模块 README 所述This integration allows gRPCs Contexts to propagate across Twitter Future boundaries in the same way that Utils Locals do.二、核心机制覆盖io.grpc.Context.Storage2.1 gRPC Java 的存储覆盖约定gRPC Java 的Context并不硬编码存储实现而是通过io.grpc.Context.Storage抽象类提供可插拔的存储后端。为了让自定义实现生效gRPC 约定使用者在 classpath 中提供一个位于io.grpc.override包下、名为ContextStorageOverride的类。正是这个包名约定解释了本项目源码目录为何命名为io/grpc/override。在 ContextStorageOverride.java 的类注释中作者明确写道A default implementation of grpc-contexts Storage that is compatible with TwitterFutures. Seeio.grpc.Context.Storagejavadoc for the reason why this class must exist atio.grpc.override.ContextStorageOverride.2.2 类结构一览public final class ContextStorageOverride extends Storage { private static final Logger LOGGER Logger.getLogger(io.grpc.override.ContextStorageOverride); private final LocalContext storage; public ContextStorageOverride() { this.storage new Local(); } ... }关键点继承io.grpc.Context.Storage实现 gRPC 要求的三个核心抽象方法内部持有一个com.twitter.util.LocalContext作为真正的存储容器类被声明为final构造函数为无参公开构造便于 gRPC 通过反射/服务发现方式实例化。2.3 三个核心方法的实现剖析Storage抽象类要求实现的三个方法分别是current()、detach(...)与doAttach(...)实现文件位于 ContextStorageOverride.javacurrent()读取当前 ContextOverride public Context current() { OptionContext ctx storage.apply(); if (ctx.isEmpty()) { return null; } else { return ctx.get(); } }storage.apply()返回scala.OptionContext。若当前Local中没有任何值则返回nullgRPC 约定用null表示当前无 Context否则返回实际 Context。这里借助scala.Some/scala.Option与 Util 的Local直接交互。doAttach(...)挂载新 ContextOverride public Context doAttach(Context toAttach) { Context current current(); storage.set(Some.apply(toAttach)); return current; }将新 Context 写入Local并返回挂载前的旧 Context。gRPC 框架会保存这个返回值用于后续恢复——这与Local.let的保存旧值、设置新值、执行后恢复语义一致。detach(...)卸载并恢复Override public void detach(Context toDetach, Context toRestore) { if (current() ! toDetach) { LOGGER.log( Level.SEVERE, Context was not attached when detaching, new Throwable().fillInStackTrace() ); } doAttach(toRestore); }卸载时先校验当前 Context 是否确实是要卸载的那个若不一致则记录SEVERE级别日志并附上完整堆栈new Throwable().fillInStackTrace()用于暴露并发/作用域错乱问题。随后通过doAttach(toRestore)恢复为调用方期望的 Context。2.4 为什么能跨 Future 传播由于存储介质是com.twitter.util.Local而非ThreadLocal当请求处理链上创建的任何Future回调需要读取Context.current()时Util 的Local传播机制会把挂载时写入的值带到回调执行现场。这就实现了同Local一般的传播方式。三、测试验证传播行为有据可依模块自带的 JUnit 测试 ContextStorageOverrideTest.java 完整覆盖了存储后端的四个关键行为测试方法验证点testCurrent初始状态下current()返回nulltestDoAttachdoAttach(Context.ROOT)返回旧值此处为null随后current()等于Context.ROOTtestDetach卸载null恢复ROOT、卸载ROOT恢复null两种路径均正确testWithFutures核心场景挂载带键值key - 1的 Context 后在Future.Done().map(...)回调中读取key.get(storage.current())断言仍能取到 1其中testWithFutures直接验证了本模块的立身之本——在 Future 回调里依然能读取挂载时写入的 gRPC Context 值。测试通过Await.result(f)等待 Future 完成后断言回调结果证明传播链路完整可用Context.KeyInteger key Context.key(intKey); storage.doAttach(Context.ROOT.withValue(key, 1)); FutureInteger f Future.Done().map(func(i - { int current key.get(storage.current()); Assert.assertEquals(1, current); return current 1; })); int result Await.result(f); Assert.assertEquals(2, result);提示doAttach的返回值在传播场景中被有意忽略因此测试方法上带有SuppressWarnings(CheckReturnValue)注解。四、构建与依赖如何在项目中引入4.1 sbt 模块定义在仓库根目录的 build.sbt 中finagle-grpc-context被定义为独立项目仅依赖两个库lazy val finagleGrpcContext Project( id finagle-grpc-context, base file(finagle-grpc-context) ).settings( sharedSettings ).settings( name : finagle-grpc-context, libraryDependencies Seq( util(core), io.grpc % grpc-context % 1.13.2 ) )util(core)提供com.twitter.util.Local、Future等核心异步原语io.grpc:grpc-context:1.13.2gRPC Java 的 Context API 与Storage抽象。4.2 Bazel/Pants 构建BUILD 文件将该模块发布为com.twitter:finagle-grpc-context同样声明依赖3rdparty/jvm/io/grpc:grpc-context与util/util-core测试目标 BUILD.bazel 额外引入 JUnit 与 Scalatest 的 JUnit 桥接。4.3 引入方式将模块源码加入 classpath 后gRPC 会依据包名约定自动发现io.grpc.override.ContextStorageOverride无需任何显式注册代码。也就是说只要这个类在运行时的 classpath 上所有使用Context.current()/Context.attach()的 gRPC 代码就会自动改用基于Local的存储。五、真实使用场景OpenCensus 追踪模块finagle-grpc-context在仓库内被finagle-opencensus-tracing模块实际消费。其 BUILD 中的依赖声明为finagle/finagle-grpc-context/src/main/java/io/grpc/override,结合 ClientTraceContextFilter.scala 可以看到典型用法过滤器通过Tracing.getTracer.getCurrentSpan读取 OpenCensus 的当前 Span并将其封装进 Finagle 的广播上下文Contexts.broadcast.let随 RPC 传递。在这种OpenCensus Span 上下文与Finagle 异步执行链混合的场景中gRPC Context 能否随Future传播直接决定了回调里能否读到正确的当前 Span——这正是本模块存在的价值。从依赖关系可以推断finagle-grpc-context目前被定位为 OpenCensus 追踪栈的底层支撑件其他需要gRPC Context 与 Finagle 异步模型共存的模块同样可以复用它。六、版本与状态说明模块状态Experimental实验性README 中明确标注依赖的 gRPC Context API 版本为 1.13.2见 build.sbt根据 CHANGELOG.rst该模块已启用 Scala 2.13.0 的跨版本构建finagle-grpc-context: Enables cross-build for 2.13.0。作为实验性模块建议在引入生产环境前充分评估其与目标 gRPC 版本Storage接口的兼容性并通过类似 ContextStorageOverrideTest.java 的用例验证传播行为。小结finagle-grpc-context用一个不到 60 行的 Java 类优雅地解决了gRPC Context 与 Twitter Future 异步模型之间的存储冲突通过 gRPC 官方的io.grpc.override.ContextStorageOverride覆盖约定将存储后端从ThreadLocal替换为com.twitter.util.Local从而让 gRPC Context 与 UtilLocal一样随Future执行链传播。其核心要点可归纳为机制覆盖Context.Storage的current/doAttach/detach三个方法底层使用LocalContext接入依赖util-core与grpc-context 1.13.2classpath 上存在该类即可全局生效无需显式注册验证JUnit 测试覆盖了挂载、卸载、恢复及跨Future回调读取的完整链路用途为 OpenCensus 追踪等需要 gRPC Context 与 Finagle 异步执行链共存的场景提供底层支撑状态Experimental注意版本兼容性评估。赞分享后端RPC框架【免费下载链接】finagleA fault tolerant, protocol-agnostic RPC system项目地址https://gitcode.com/gh_mirrors/fi/finagle点击查看免费下载相关推荐gRPC-Go 取消传播实战基于 Context 取消在途 RPC 的完整指南gRPC Go 取消传播实战基于 Context 取消在途 RPC 的完整指南 导读 gRPC 客户端在发起 RPC 时传入的 context.Context后端RPC框架Ornith-1.0-9B-GGUF自我改进训练框架深度解析如何通过RL优化代码生成质量Ornith 1.0 9B GGUF自我改进训练框架深度解析如何通过RL优化代码生成质量 Ornith 1.0 9B GGUF是一款革命性的自我改进训练框架gRPC-Go 如何通过取消 context 取消进行中的 RPCgRPC Go 如何通过取消 context 取消进行中的 RPC 在 grpc gogRPC 的 Go 语言实现中客户端把 context 传给 RP开发工具IDE代码编辑器上一篇ZLUDA跨硬件 CUDA 兼容层的技术突破与实践指南下一篇AugLy组合操作符终极指南Compose与OneOf的完整使用教程创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 Finagle gRPC Context 集成指南：让 gRPC Context 跨 Twitter Future 边界传播
后端RPC框架【免费下载链接】finagleA fault tolerant, protocol-agnostic RPC system项目地址https://gitcode.com/gh_mirrors/fi/finagle点击查看免费下载导读finagle-grpc-context是 Finagle 仓库中的一个轻量级 Java 集成模块它通过覆盖 gRPC Java 的Context.Storage默认实现使 gRPC Context 能够像 Twitter Util 的Local一样跨com.twitter.util.Future边界自动传播。读完本文你将掌握 gRPC Context 在异步 RPC 环境下的传播原理、io.grpc.override包名约定的由来、ContextStorageOverride三个核心方法的实现细节以及如何通过测试与构建配置在 Finagle 生态中落地使用这一能力。该模块当前状态为Experimental实验性。一、背景与动机为什么 gRPC Context 需要覆盖 Storage1.1 gRPC Context 与线程本地存储gRPC Java 通过io.grpc.Context承载一次 RPC 调用生命周期内的作用域数据如认证凭据、超时、分布式追踪信息。默认情况下Context依赖ThreadLocal存储这意味着它的生命周期与当前执行线程强绑定。然而 Finagle 的核心编程模型是异步回调式的Future的map、flatMap、transform等组合操作可以在任意线程上执行回调经常被调度到不同的线程池。一旦执行流跨越线程边界基于ThreadLocal的 gRPC Context 就会丢失——这正是该集成要解决的核心问题。1.2 Twitter Util 的 Local异步环境下的线程本地Twitter Util 提供了com.twitter.util.Local作为ThreadLocal的异步替代当你在Local的作用域内创建Future时该Local的值会随Future的执行链传播即使回调被调度到其他线程依然能读到原始作用域里写入的值。这也是 Finagle 自身上下文机制如 LocalContext、Contexts的底层基础。本模块的思路非常直接把 gRPC Context 的存储后端从ThreadLocal换成com.twitter.util.Local让 gRPC Context 获得与Local完全一致的跨 Future 传播能力。正如模块 README 所述This integration allows gRPCs Contexts to propagate across Twitter Future boundaries in the same way that Utils Locals do.二、核心机制覆盖io.grpc.Context.Storage2.1 gRPC Java 的存储覆盖约定gRPC Java 的Context并不硬编码存储实现而是通过io.grpc.Context.Storage抽象类提供可插拔的存储后端。为了让自定义实现生效gRPC 约定使用者在 classpath 中提供一个位于io.grpc.override包下、名为ContextStorageOverride的类。正是这个包名约定解释了本项目源码目录为何命名为io/grpc/override。在 ContextStorageOverride.java 的类注释中作者明确写道A default implementation of grpc-contexts Storage that is compatible with TwitterFutures. Seeio.grpc.Context.Storagejavadoc for the reason why this class must exist atio.grpc.override.ContextStorageOverride.2.2 类结构一览public final class ContextStorageOverride extends Storage { private static final Logger LOGGER Logger.getLogger(io.grpc.override.ContextStorageOverride); private final LocalContext storage; public ContextStorageOverride() { this.storage new Local(); } ... }关键点继承io.grpc.Context.Storage实现 gRPC 要求的三个核心抽象方法内部持有一个com.twitter.util.LocalContext作为真正的存储容器类被声明为final构造函数为无参公开构造便于 gRPC 通过反射/服务发现方式实例化。2.3 三个核心方法的实现剖析Storage抽象类要求实现的三个方法分别是current()、detach(...)与doAttach(...)实现文件位于 ContextStorageOverride.javacurrent()读取当前 ContextOverride public Context current() { OptionContext ctx storage.apply(); if (ctx.isEmpty()) { return null; } else { return ctx.get(); } }storage.apply()返回scala.OptionContext。若当前Local中没有任何值则返回nullgRPC 约定用null表示当前无 Context否则返回实际 Context。这里借助scala.Some/scala.Option与 Util 的Local直接交互。doAttach(...)挂载新 ContextOverride public Context doAttach(Context toAttach) { Context current current(); storage.set(Some.apply(toAttach)); return current; }将新 Context 写入Local并返回挂载前的旧 Context。gRPC 框架会保存这个返回值用于后续恢复——这与Local.let的保存旧值、设置新值、执行后恢复语义一致。detach(...)卸载并恢复Override public void detach(Context toDetach, Context toRestore) { if (current() ! toDetach) { LOGGER.log( Level.SEVERE, Context was not attached when detaching, new Throwable().fillInStackTrace() ); } doAttach(toRestore); }卸载时先校验当前 Context 是否确实是要卸载的那个若不一致则记录SEVERE级别日志并附上完整堆栈new Throwable().fillInStackTrace()用于暴露并发/作用域错乱问题。随后通过doAttach(toRestore)恢复为调用方期望的 Context。2.4 为什么能跨 Future 传播由于存储介质是com.twitter.util.Local而非ThreadLocal当请求处理链上创建的任何Future回调需要读取Context.current()时Util 的Local传播机制会把挂载时写入的值带到回调执行现场。这就实现了同Local一般的传播方式。三、测试验证传播行为有据可依模块自带的 JUnit 测试 ContextStorageOverrideTest.java 完整覆盖了存储后端的四个关键行为测试方法验证点testCurrent初始状态下current()返回nulltestDoAttachdoAttach(Context.ROOT)返回旧值此处为null随后current()等于Context.ROOTtestDetach卸载null恢复ROOT、卸载ROOT恢复null两种路径均正确testWithFutures核心场景挂载带键值key - 1的 Context 后在Future.Done().map(...)回调中读取key.get(storage.current())断言仍能取到 1其中testWithFutures直接验证了本模块的立身之本——在 Future 回调里依然能读取挂载时写入的 gRPC Context 值。测试通过Await.result(f)等待 Future 完成后断言回调结果证明传播链路完整可用Context.KeyInteger key Context.key(intKey); storage.doAttach(Context.ROOT.withValue(key, 1)); FutureInteger f Future.Done().map(func(i - { int current key.get(storage.current()); Assert.assertEquals(1, current); return current 1; })); int result Await.result(f); Assert.assertEquals(2, result);提示doAttach的返回值在传播场景中被有意忽略因此测试方法上带有SuppressWarnings(CheckReturnValue)注解。四、构建与依赖如何在项目中引入4.1 sbt 模块定义在仓库根目录的 build.sbt 中finagle-grpc-context被定义为独立项目仅依赖两个库lazy val finagleGrpcContext Project( id finagle-grpc-context, base file(finagle-grpc-context) ).settings( sharedSettings ).settings( name : finagle-grpc-context, libraryDependencies Seq( util(core), io.grpc % grpc-context % 1.13.2 ) )util(core)提供com.twitter.util.Local、Future等核心异步原语io.grpc:grpc-context:1.13.2gRPC Java 的 Context API 与Storage抽象。4.2 Bazel/Pants 构建BUILD 文件将该模块发布为com.twitter:finagle-grpc-context同样声明依赖3rdparty/jvm/io/grpc:grpc-context与util/util-core测试目标 BUILD.bazel 额外引入 JUnit 与 Scalatest 的 JUnit 桥接。4.3 引入方式将模块源码加入 classpath 后gRPC 会依据包名约定自动发现io.grpc.override.ContextStorageOverride无需任何显式注册代码。也就是说只要这个类在运行时的 classpath 上所有使用Context.current()/Context.attach()的 gRPC 代码就会自动改用基于Local的存储。五、真实使用场景OpenCensus 追踪模块finagle-grpc-context在仓库内被finagle-opencensus-tracing模块实际消费。其 BUILD 中的依赖声明为finagle/finagle-grpc-context/src/main/java/io/grpc/override,结合 ClientTraceContextFilter.scala 可以看到典型用法过滤器通过Tracing.getTracer.getCurrentSpan读取 OpenCensus 的当前 Span并将其封装进 Finagle 的广播上下文Contexts.broadcast.let随 RPC 传递。在这种OpenCensus Span 上下文与Finagle 异步执行链混合的场景中gRPC Context 能否随Future传播直接决定了回调里能否读到正确的当前 Span——这正是本模块存在的价值。从依赖关系可以推断finagle-grpc-context目前被定位为 OpenCensus 追踪栈的底层支撑件其他需要gRPC Context 与 Finagle 异步模型共存的模块同样可以复用它。六、版本与状态说明模块状态Experimental实验性README 中明确标注依赖的 gRPC Context API 版本为 1.13.2见 build.sbt根据 CHANGELOG.rst该模块已启用 Scala 2.13.0 的跨版本构建finagle-grpc-context: Enables cross-build for 2.13.0。作为实验性模块建议在引入生产环境前充分评估其与目标 gRPC 版本Storage接口的兼容性并通过类似 ContextStorageOverrideTest.java 的用例验证传播行为。小结finagle-grpc-context用一个不到 60 行的 Java 类优雅地解决了gRPC Context 与 Twitter Future 异步模型之间的存储冲突通过 gRPC 官方的io.grpc.override.ContextStorageOverride覆盖约定将存储后端从ThreadLocal替换为com.twitter.util.Local从而让 gRPC Context 与 UtilLocal一样随Future执行链传播。其核心要点可归纳为机制覆盖Context.Storage的current/doAttach/detach三个方法底层使用LocalContext接入依赖util-core与grpc-context 1.13.2classpath 上存在该类即可全局生效无需显式注册验证JUnit 测试覆盖了挂载、卸载、恢复及跨Future回调读取的完整链路用途为 OpenCensus 追踪等需要 gRPC Context 与 Finagle 异步执行链共存的场景提供底层支撑状态Experimental注意版本兼容性评估。赞分享后端RPC框架【免费下载链接】finagleA fault tolerant, protocol-agnostic RPC system项目地址https://gitcode.com/gh_mirrors/fi/finagle点击查看免费下载相关推荐gRPC-Go 取消传播实战基于 Context 取消在途 RPC 的完整指南gRPC Go 取消传播实战基于 Context 取消在途 RPC 的完整指南 导读 gRPC 客户端在发起 RPC 时传入的 context.Context后端RPC框架Ornith-1.0-9B-GGUF自我改进训练框架深度解析如何通过RL优化代码生成质量Ornith 1.0 9B GGUF自我改进训练框架深度解析如何通过RL优化代码生成质量 Ornith 1.0 9B GGUF是一款革命性的自我改进训练框架gRPC-Go 如何通过取消 context 取消进行中的 RPCgRPC Go 如何通过取消 context 取消进行中的 RPC 在 grpc gogRPC 的 Go 语言实现中客户端把 context 传给 RP开发工具IDE代码编辑器上一篇ZLUDA跨硬件 CUDA 兼容层的技术突破与实践指南下一篇AugLy组合操作符终极指南Compose与OneOf的完整使用教程创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考