@GrpcClient and @GrpcClientBean doesn't work without GrpcService

[stillya]

I have two microservices with common-lib and lib for proto-definition and my grpc client located at common-lib, but it only works with first microservice, where I have GrpcService, in second I haven't grpc client, no such bean definition.

I tried @GrpcClient, @GrpcClientBean and it doesn't work. I checked dependency graph, both have grpc-client dep, both have the same version of spring. It so strange, I added breakpoint on GrpcClientBeanPostProcessor and in second microservice I don't go there, but post processor in classpath. Have any ideas about it?

Both microservices and lib written on Kotlin.

[ST-DDT]

Does injecting any other bean work?

[stillya]

Does injecting any other bean work?

Yes, everything else works fine.

[ST-DDT]

Then please create a @GrpcClientBean on a @Configuration class and inject the required stub or channel.

That way you you have the bean in your context and since injection works, it should work there as well.

If that does not work, there must be something else going on. Is your bean a special bean like a spring infrastructure bean?
Could you provide an example project that we can use to reproduce the error?

[stillya]

Then please create a @GrpcClientBean on a @configuration class and inject the required stub or channel.
I do exactly this thing.

I created repository which pretty close to my project, where this problem reproducing.

This is common spring project with common-proto(lib where placed some common proto definitions), lib-commons(common lib for all microservices) and two microservices, in auth-service everything is working fine, but ms-config-constructor(it has own api-lib) fail with error on required bean not found.

@GrpcClientBean placed in lib-commons dataflow.commons.configuration.CommonConfiguration and inejcts in dataflow.commons.security.AuthorizationGrpcClient. By the way, this client injects in controllers in AuthService and ConfigConstructor just for testing purposes.

[ST-DDT]

I try to look into this this weekend.

[ST-DDT]

Sorry, I didn't have time this weekend. I will try to look into it soon.

[stillya]

It's ok. By the way, thank you for spending your time on this.

[stillya]

Hello, haven't had time to look on this bug(or not) yet?

[a-simeshin]

Hello, haven't had time to look on this bug(or not) yet?

Hey! I tried to investigate the problem.

We have:

1. Configuration in the module lib-commons with @GrpcClientBean

@GrpcClientBean(
    beanName = "authStub",
    clazz = AuthorizationServiceGrpc.AuthorizationServiceBlockingStub::class,
    client = GrpcClient("AuthClient")
)
@Configuration
class CommonConfiguration {
}

2. Component in the module lib-commons

@Component
class AuthorizationGrpcClient(private val authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub) {
}

3. @RestController in another module ms-config-constructor with dependency lib-commons and access to gRPC bean client with getting from the spring context

@RestController
@RequestMapping(path = ["/configs"])
class ConfigRestController(val auth: AuthorizationGrpcClient) {

    @Autowired
    private lateinit var authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub

    @PostConstruct
    fun beanPresentLogNotification() {
        println("gRPC bean client successfully autowired to another module [$authStub]")
        println("Bean wrapper with gRPC bean client successfully autowired to another module [$auth]")
    }
}

4. Logs

Parameter 0 of constructor in dataflow.commons.security.AuthorizationGrpcClient required a bean of type 'com.dataflow.commons.AuthorizationServiceGrpc$AuthorizationServiceBlockingStub' that could not be found.

I suppose something strange happen with @Component constructor and even @Autowired injection in the SAME module, but if you'll try to manually create AuthorizationGrpcClient bean like

@GrpcClientBean(
    beanName = "authStub",
    clazz = AuthorizationServiceGrpc.AuthorizationServiceBlockingStub::class,
    client = GrpcClient("AuthClient")
)
@Configuration
class CommonConfiguration {

    @Bean
    fun decoder(): Base64.Decoder = Base64.getDecoder()

    @Bean
    fun authorizationGrpcClient(authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub): AuthorizationGrpcClient {
        return AuthorizationGrpcClient(authStub);
    }
}

you will get in logs

gRPC bean client successfully autowired to another module [com.dataflow.commons.AuthorizationServiceGrpc$AuthorizationServiceBlockingStub@214fba74]
Bean wrapper with gRPC bean client successfully autowired to another module [dataflow.commons.security.AuthorizationGrpcClient@252c6cdb]

@stillya hope manually bean construction for kt classes would be helpful, at least it works. Another possible workaround is to develop java classes that requires @Grpclient bean instead of kt classes. Both options definitely not great at all :(

@ST-DDT sadly GrpcClientBeanPostProcessor have 0 reaction for both method and field injections in kt class. Should we use something like runtimeOnly 'org.jetbrains.kotlin:kotlin-reflect:1.2.41' to have proper access?

1. Breakpoint somewhere in processFields and 0 reaction for

@Component
class AuthorizationGrpcClient {

    //bean not found
    @Autowired
    lateinit var authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub
}

2. Breakpoint somewhere in processMethods and 0 reaction for

@Component
class AuthorizationGrpcClient(private val authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub) {
     //bean not found
...
}

UPD
This is kt too, but here field injection works properly because @GrpcBean authStub and AuthorizationGrpcClient already exists in the spring context

@RestController
@RequestMapping(path = ["/configs"])
class ConfigRestController(val auth: AuthorizationGrpcClient) {

    @Autowired
    private lateinit var authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub

    @PostConstruct
    fun beanPresentLogNotification() {
        println("gRPC bean client successfully autowired to another module [$authStub]")
        println("Bean wrapper with gRPC bean client successfully autowired to another module [$auth]")
    }
}

[stillya]

@a-simeshin your workaround isn't working if I wanna more than one grpcClientBean to create another bean, i.e.

@Configuration
@GrpcClientBeans(
    value = [
        GrpcClientBean(
            beanName = "authStub",
            clazz = AuthorizationServiceGrpc.AuthorizationServiceBlockingStub::class,
            client = GrpcClient("AuthorizationService")
        ),
        GrpcClientBean(
            beanName = "permissionStub",
            clazz = PermissionServiceGrpc.PermissionServiceBlockingStub::class,
            client = GrpcClient("PermissionService")
        )
    ]
)
class TestConfiguration {

    @Bean
    fun authorizationGrpcClient(
        authStub: AuthorizationServiceGrpc.AuthorizationServiceBlockingStub,
        permissionStub: PermissionServiceGrpc.PermissionServiceBlockingStub
    ): AuthorizationGrpcClient {
        return AuthorizationGrpcClient(authStub, permissionStub)
    }
}

We'll haven't even first stub-bean, which previously work. I don't know how to work around this.

[Sun-Phil-Kwon-Miro]

hi team any update on this?