AliYun RocketMQ Spring Book Edition
Thanks for the help from JetBrains software
The project follows the Apache2.0 License
The license is free. You can download the code, modify it as needed, and use it in your own projects
Important: all projects published by the author on GitHub are non-profit.
Since the author registered GitHub, so far, he hasn't made a penny.
Anyone who charges for the author's project is cheating you.
If you are cheated, I hope you can get the help of a lawyer. Good luck.
IMPORTANT: The author is currently living in a miserable situation with no income and is running out of money.
The project still follows the Apache2.0 License
If the author has no money to eat, the author cannot update the project for everyone for free in a place without Internet and life.
The author is now accepting donations, thank you for your support.
The time to start accepting donations is when this text is currently updated.
Donate
IMPORTANT: This project is now out of maintenance, as the author needs to pay to maintain the commercial version while maintaining the project.
We spent money maintaining a commercial version today, but couldn't use the product.
We have decided to suspend the maintenance or update of all Ali products.
Maintainers of open source projects don't pay entrepreneurs to work for free because they disable your account.
IMPORTANT: Ali decided to sanction me, today I received a text message, he forced me to pay for maintaining Ali products.
I paid what I needed to pay yesterday, which is to maintain the Ali product, and then canceled the paid product, but I was sanctioned anyway, and now I have to pay more.
Good luck to everyone, don't be sanctioned by Ali.
Support function:
- Three modes of sending ordinary messages: synchronous, asynchronous and one-way
- Subscribe to Message Cluster, Broadcast
- Send and receive sequential messages
- Transaction messages
- Delay message
- receive and receive timing messages
Delay message and timing message: In the official case, delayed news is much the same as regular news, essentially ordinary news.
If delay message and timing message are needed, it is recommended to use timing task (timing task scheduling platform)
To achieve the purpose of delay or timing.
In the framework, the operations on transaction messages are simpler and simpler. You can complete the transaction messages by annotations only.
Whether transactional messages, distributed transactional solutions or cross-platform language solutions, the core problem of transactional solutions is to ensure that messages can be sent and consumers can consume them.
Reliability Guarantee
1.Add @TransactionMessage annotation, kernel guarantee, local transaction error, do not send message, correct execution, send message, that is, default submission.
2.Reliability assurance is adopted by default, and default submission is checked back. The reason comes from the previous factor, which guarantees that local transactions do not go wrong.
<!--Adding dependencies to pom. XML-->
<dependency>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<groupId>com.github.thierrysquirrel</groupId>
<version>2.3.1.4-RELEASE</version>
</dependency>
## application.properties
thierrysquirrel.access-key= #The Access Key you created in the AliYun Account Management Console for authentication
thierrysquirrel.secret-key= #The SecretKey you created in the AliYun Account Management Console for authentication
thierrysquirrel.name-srv-addr= #Set up TCP protocol access point and get it from console
@SpringBootApplication
@EnableRocketMQ
public class DemoApplication{
public static void main(String[] args){
SpringApplication.run(DemoApplication.class, args);
}
}
@RestController
@RocketMessage(groupID = "GID_common")
public class Common {
@GetMapping("/commonA")
@CommonMessage(topic = "commonA", tag = "commonA",messageSendType = MessageSendType.SEND)
public String sendCommonMsg() {
return "commonA";
}
@GetMapping("/commonB")
@CommonMessage(topic = "commonB", tag = "commonB",messageSendType = MessageSendType.SEND_ASYNC)
public String sendAsyncMsg() {
return "commonB";
}
@GetMapping("/commonC")
@CommonMessage(topic = "commonC", tag = "commonC",messageSendType = MessageSendType.SEND_ONE_WAY)
public String sendOneWayMessage() {
return "commonC";
}
}
@RestController
@RocketMessage(groupID = "GID_order")
public class Order {
@GetMapping("/order")
@OrderMessage(topic = "order",tag = "order")
public String order(@RequestParam @ShardingKey String shardingKey) {
return "order";
}
}
@RestController
@RocketMessage(groupID = "GID_transaction")
public class Transaction {
@GetMapping("/transaction")
@TransactionMessage(topic = "transaction",tag = "transaction")
public String transaction() {
return "transaction";
}
}
@RestController
@RocketMessage(groupID = "GID_delayed")
public class Delayed {
//startDeliverTime is the time stamp, which cannot be less than the current time
@GetMapping("/delayed")
@CommonMessage(topic = "delayed", tag = "delayed")
public String delayed(@StartDeliverTime @RequestParam("startDeliverTime") long startDeliverTime) {
return "delayed";
}
}
Monitor messages using messageModel to control cluster or broadcast consumption patterns
@RocketListener(groupID = "GID_message",messageModel = PropertyValueConst.CLUSTERING)
public class Delayed {
@MessageListener(topic = "message",tag = "message")
public void delayed(String message) {
System.out.println("message");
}
}
@RocketListener(groupID = "GID_message",messageModel = PropertyValueConst.BROADCASTING)
public class Delayed {
@MessageListener(topic = "message",tag = "message", orderConsumer = true)
public void delayed(String message) {
System.out.println("message");
}
}
@RocketListener(groupID = "GID_message",batchConsumer = true)
public class Delayed {
@MessageListener(topic = "message",tag = "message", orderConsumer = true)
public void delayed(String message) {
System.out.println("message");
}
}
@Component
public class MySendCallback implements SendCallback {
@Override
public void onSuccess(SendResult sendResult) {
System.out.println("Successful sending of message");
}
@Override
public void onException(OnExceptionContext context) {
System.out.println("Failed to send message");
}
}
@Component
public class MyTransactionExecuter implements LocalTransactionExecuter {
@Override
public TransactionStatus execute(Message msg, Object arg) {
System.out.println("Executing local affairs");
return TransactionStatus.CommitTransaction;
}
}
@Component
public class MyTransactionChecker implements LocalTransactionChecker {
@Override
public TransactionStatus check(Message msg) {
System.out.println("Review of local transactions");
return TransactionStatus.CommitTransaction;
}
}
@Component
public class JacksonSerializer implements RocketSerializer {
private static ObjectMapper objectMapper = new ObjectMapper();
@Override
public byte[] serialize(Object obj) {
//omit
}
@Override
public Object deserialize(byte[] bytes, Class<?> clazz) {
//omit
}
}
@CommonMessage callback Specify the class
@TransactionMessage checker And executer Specify the class