StreamBridge is a singleton, and its send() method has performance issues.

[imgoby]

Describe the issue

During high concurrency, StreamBridge's send() calls are frequent, and the internal synchronization of send() prevents applications from fully utilizing the multi-core capabilities of the CPU.

To Reproduce Steps to reproduce the behavior:

1. Run a application built Spring Cloud Stream and RocketMQ,Spring Cloud Stream Version:

   <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-stream</artifactId>
      <version>4.0.0</version>
    </dependency>

3. Message concurrency is 10000 messages per second
4. We can see : thread wait (blocked) in the StreamBridge's send() method

Additional context I tried to increase the number of instances of StreamBridge through certain methods, and CPU usage began to rise. Concurrent performance improves.

So,I know :Default situation,StreamBridge is a singleton, and its send() method has performance issues.

Does spring cloud stream team know this issue? Can it be optimized?

[sobychacko]

@imgoby Thanks for the report. We will triage the issue and get back to you.

[olegz]

You can set it to async. StreamBridge.setAsync() and then your sends will be asynchronous

[olegz]

I am closing it as an answered question. If you still believe there is an issue please describe and more details and we'll reopen

[imgoby]

there is not setAsync() method in spring cloud 2022.

[olegz]

Please upgrade ;)

[imgoby]

OK,Thank you