English | 中文
Stream asynchronous message high-performance processing framework, similar to go chan, multi-threaded asynchronous processing of messages, supports batch processing of messages.
- Asynchronous multithreading (fixed thread), support for specifying the number of threads
- Support Kafka, MQTT, RabbitMQ message source and support expansion
- Message processing supports training and random processing
- Message processing support interceptor
- Support Spring Boot
Compilation requires JDK 8 and above, Maven 3.2.5 and above.
If you use Maven, you just need to add the following dependency in pom.xml:
<dependency>
<groupId>io.github.wendy512</groupId>
<artifactId>stream-core</artifactId>
<version>1.0.1</version>
</dependency>
Stream is based on the Apache License 2.0 agreement, and Stream relies on some third-party components whose open source agreement is also Apache License 2.0.
- Email:wendy512@yeah.net