- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个简单的 gRPC 客户端,由 Gradle 使用 shadowJar 打包在一个 jar 中。当我运行 main()
使用 IntelliJ,RPC 发送成功。当我用 java -jar
运行它时,我得到一个异常(exception):
更新:我想我已经确定 IntelliJ 和 ./gradlew shadowJar 都提供了同一组类,但顺序不同。我怀疑这会导致不同的行为,但我真的不明白为什么,或者在这两种情况下如何控制类路径的顺序。如果我能弄清楚哪些类在这里真正相关,那将是一个很大的帮助。完整扩展包括 19k 类文件。
Exception in thread "main" io.grpc.StatusException: UNKNOWN
at io.grpc.Status.asException(Status.java:550)
at io.grpc.kotlin.ClientCalls$rpcImpl$1$1$1.onClose(ClientCalls.kt:296)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:562)
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:743)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:722)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.nio.channels.UnsupportedAddressTypeException
at java.base/sun.nio.ch.Net.checkAddress(Net.java:146)
at java.base/sun.nio.ch.Net.checkAddress(Net.java:157)
at java.base/sun.nio.ch.SocketChannelImpl.checkRemote(SocketChannelImpl.java:816)
at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:839)
at io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:91)
at io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:88)
at java.base/java.security.AccessController.doPrivileged(AccessController.java:569)
at io.netty.util.internal.SocketUtils.connect(SocketUtils.java:88)
at io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:322)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:248)
at io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1342)
at io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
at io.netty.channel.AbstractChannelHandlerContext.connect(AbstractChannelHandlerContext.java:533)
at io.netty.channel.ChannelDuplexHandler.connect(ChannelDuplexHandler.java:54)
at io.grpc.netty.WriteBufferingAndExceptionHandler.connect(WriteBufferingAndExceptionHandler.java:157)
at io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:548)
at io.netty.channel.AbstractChannelHandlerContext.access$1000(AbstractChannelHandlerContext.java:61)
at io.netty.channel.AbstractChannelHandlerContext$9.run(AbstractChannelHandlerContext.java:538)
at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
... 1 more
我的客户(这似乎不是问题所在):
fun main() {
runBlocking {
SampleClient().hello("hello")
}
}
class SampleClient() : Closeable {
private val channel = ManagedChannelBuilder.forAddress("localhost", StationController.PORT).usePlaintext().build()
private val stub = StationServiceGrpcKt.StationServiceCoroutineStub(channel)
suspend fun hello(msg: String) {
val request = helloRequest { message = msg }
stub.hello(request)
}
override fun close() {
channel.shutdown().awaitTermination(5, TimeUnit.SECONDS)
}
}
运行java -jar build/libs/test-0.1-all.jar
因上述异常而失败。使用 java -classpath <very long classpath> com.test.MainKt
运行成功。
我试图最小化仍然显示此行为的 gradle.build.kts:
import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
import com.google.protobuf.gradle.*
plugins {
kotlin("jvm") version "1.7.10"
id("com.github.johnrengelman.shadow") version "6.0.0"
id("com.google.protobuf") version "0.8.19"
}
// These address this error:
// 'compileJava' task (current target is 17) and 'compileKotlin' task (current target is 1.8) jvm target compatibility
// should be set to the same Java version.
java { sourceCompatibility = JavaVersion.VERSION_17; targetCompatibility = JavaVersion.VERSION_17 }
tasks.withType<KotlinCompile> { kotlinOptions { jvmTarget = "17" } }
group = "com.test"
version = "0.1"
repositories { mavenCentral() }
dependencies {
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.3")
implementation("io.grpc:grpc-protobuf:1.48.1")
implementation("io.grpc:grpc-kotlin-stub:1.3.0")
// The rpc fails only when I run it from the fat jar. running from intellij works. the stacktrace is all in netty,
// but when I compile without netty there is no netty in the jar, making me think there is no transitive dependency
// on netty. it fails with both netty and netty-shaded, but with different stack traces.
// with netty-shaded, it says Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: connect(..) failed: Address family not supported by protocol: /localhost:8980
// with netty, it just says Caused by: java.nio.channels.UnsupportedAddressTypeException
implementation("io.grpc:grpc-netty:1.48.1")
implementation("com.google.protobuf:protobuf-kotlin:3.21.4")
}
// for gRPC
protobuf {
protoc { artifact = "com.google.protobuf:protoc:3.21.4" }
plugins {
// We only need this for Kotlin, but it doesn't fully link without the java sources.
id("grpc") { artifact = "io.grpc:protoc-gen-grpc-java:1.48.1" }
id("grpckt") { artifact = "io.grpc:protoc-gen-grpc-kotlin:1.3.0:jdk8@jar" }
}
generateProtoTasks {
all().forEach {
it.plugins { id("grpc"); id("grpckt") }
// The plugins above (I think) generate the Java proto code, but not the extra Kotlin stuff like DSLs.
// Including this adds a /kotlin folder to the generated code which contains all the extra stuff.
it.builtins { id("kotlin") }
}
}
}
sourceSets {
main {
java {
// These are the default generated source dirs, but they have to be added manually currently:
// https://github.com/google/protobuf-gradle-plugin/issues/109
// The plugin generates both a grpc dir with Java files, and grpckt with Kotlin files. I believe the grpckt
// contents includes all the functionality of the grpc (java) contents, but I'm not positive. The kotlin
// files might just be stubs for the java version? so maybe this compiles but doesn't run?
srcDirs("build/generated/source/proto/main/grpc")
srcDirs("build/generated/source/proto/main/grpckt")
// This contains the Java classes like the request and response messages.
srcDirs("build/generated/source/proto/main/java")
// This contains the Kotlin extensions to those java classes, like DSLs.
srcDirs("build/generated/source/proto/main/kotlin")
}
}
}
tasks.jar { manifest.attributes["Main-Class"] = "com.test.MainKt" }
我不知道如何继续调试它。
最佳答案
一位 friend 找到了答案。这个对 build.gradle.kts 的添加最终成为让它工作的全部:
tasks.named("shadowJar", ShadowJar::class) {
mergeServiceFiles()
}
参见 shadowJar 的 documentation关于这里发生的事情。摘要:“Java 库通常在 JAR 的 META-INF/services 目录中包含服务描述 rune 件。服务描述符通常包含以行分隔的特定服务支持的类列表。在运行时,读取并使用此文件配置库或应用程序行为。
多个依赖项可以使用相同的服务描述 rune 件名。在这种情况下,通常希望将文件的每个实例的内容合并到一个输出文件中。” mergeServiceFiles()
就是这样做的。
关于intellij-idea - gRPC UnsupportedAddressTypeException,但仅当与 shadowJar 打包时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/73286776/
关于 gRPC Health Checking ,如果 gRPC 服务托管在与其他也需要健康检查的 HTTP 服务相同的端口上,则对 grpc.health.v1.Health.Check 的响应应该
我的项目是读取服务器中的图像,进行一些处理,然后将整个图像传递给客户端。客户端占用图像并进行更多处理,并将一些输出值返回给服务器。服务器和客户端之间使用的图像大小为 [640x480x3]。 以下是我
gRPC 基于 HTTP/2,它(假设)被浏览器广泛支持。因此,我觉得从浏览器使用 gRPC 应该没有问题。 但是,很明显存在问题。协议(protocol),grpc web , 是不同的,因为“由于
关于服务器端代码的幂等性的问题,或者说它的必要性。对于一般的 gRPC,或者专门针对 java 实现。 当我们从客户端发送消息一次时,是否有可能由我们的服务实现处理两次?也许这与服务似乎不可用时的重试
假设我想使用 Grpc Server 流式传输或双向流式传输。 考虑到它在底层使用 http/2,流可以持续多长时间是否有任何限制? 如果是的话,它可以用来代替消息总线,这样流就可以打开并存活多久?
使用 gRPC 向客户端发送有关错误的更多详细信息的模式是什么? 例如,假设我有一个用于注册用户的表单,用于发送消息 message RegisterUser { string email = 1
我是 GRPC 的新手。我想知道当 GRPC 客户端启动一个请求时,服务器是否启动一个新线程来处理。 最佳答案 最多可能有一个 Runnable加入 Server's executor用于申请处理。每
我想传输一个 int64 数组。 我查了一下如何使用它。在我的原型(prototype)文件中,我需要一个流: service myService { rpc GetValues(myRequ
通常,客户端可以通过以下方式取消 gRPC 调用: (requestObserver as ClientCallStreamObserver) .cancel("Cancelled", nul
在 100Gb 网络上,我创建了一个服务器来监听 4 个端口,grpc 客户端可以达到 3GB+/s 的吞吐量。然而,当服务器监听一个端口时,grpc 客户端达到了 1GB/s 的吞吐量,即使我设置了
我想验证调用并可能在服务器拦截器中回答错误。有没有办法做到这一点?如果是,我该如何实现? 最佳答案 简单地从拦截器响应 RPC,可能通过调用 close() ,不要调用next .您仍然需要返回一个监
我有一个 GRPC API,经过重构,一些包被重命名。这包括我们定义 API 的原型(prototype)文件之一中的 package 声明。像这样的: package foo; service Ba
我想在 Ubuntu 上使用源代码中的所有子模块编译 grpc,并将其安装到/usr/local 以外的指定位置 为提供的 Makefile 指定此位置的方法是什么(类似于配置脚本的 --prefix
我不断在控制台中收到此警告: DeprecationWarning: grpc.load: Use the @grpc/proto-loader module with grpc.loadPackag
上下文 我正在尝试使用 Google 的 Cloud Natural Language API。我有我的服务帐户 key JSON 文件,并且正在尝试编写一个简单的 .NET Core 应用程序(更具
用户在测试中遇到了此崩溃。我的第一个猜测是这与内存有关,但除此之外我没有什么可做的。更深入地研究代码,我认为这可能是主线程问题,但看起来监听器在后台线程上被删除,所以我怀疑这就是原因。 我认为在应用程
我正在编写一个 grpc 服务并在 Kubernetes (https://github.com/grpc-ecosystem/grpc-health-probe) 上使用 gRPC 健康检查。在我的
如何使用 gRPC-java 实现检测网络错误并尝试从中恢复的策略?我知道 UNAVAILABLE 状态可能意味着网络错误,但这并没有告诉我它是哪种网络错误 - 并且 UNAVAILABLE 也可以从
假设我们有一个 Search-Service service Search { rpc Search (SearchRequest) returns (SearchReply) {} } mess
如果浏览器支持http/2,为什么 grpc-web 需要 envoy 代理? 不支持 http/2 的旧浏览器是否只需要它? 最佳答案 回答于 https://github.com/grpc/grp
我是一名优秀的程序员,十分优秀!