??? ?? ??? ??, ?? ? ??? ?? ??? ???? ? ???? ??? ???? ?? ???????. ?? ???? ??? ?????. 1. ???? ??? ??; 2. ??? ?? ?? ??? ?????. 3. ?? ?? ??? ??????. Java? ?? ??? ????? RabbitMQ (?? ??? ?? ??? ?? ????), Kafka (?? ??? ????? ??), ActiveMQ (?? ?????? ?? ??? ??) ? RocketMQ (??? ?? ???? ??)? ?????. ?? ??? ?? ?? ??, ?? ??, ?? ?? ? ?? ? ?? ?? ?????? ???????.

??? ??? ?? ?? ????? ???? Java ??? ??? ??? ???? ? ??? ?????. ??? ???? ???? ?? ?? ???? ??? ?? ???? ??? ?? ??? ?? ??? ?? ??? ???? ? ????. Java?? ??? ?? ??? ???? ??? ?? ?? ??? ??? ??? ?? ????? ???????.

??? ????? ?????? ? ??????

??? ???, ??? ???? ???? ?? ???? ?? ???????. ???? ??? ???? ????. ???? ????? ??? ?????. ? ???? ??? ??? ????.

• ? ?? ? : ???? ???? ??? ??? ?? ? ??? ????.
• ?? ?? ? ?? ?? : ?? ?? ??? ?? ? ? ??? ??? ? ? ????.
• ??? ?? : ?? ???? ?? ?? ??

?? ??, ???? ??? ? ??? ??? ??? ? ?? ??? ?? ??? ?? ???? ?? ?? ??? ??? ???? ??? ??????? ??? ?????.

???? ????? ???? ?? ??? ?? ??

?? Java ????? ??? ?? ?? ??? ???? ????.

• RabbitMQ : ?? ??? ????, ??? ??? ?? ????? ???? ???? ?? ????? ?????.
• Kafka : ? ??? ?? ??, ??? ??? ?? ?? ?? ????? ??? ????? ?????.
• ActiveMQ : ???? ??? Apache? ?? ????? ??? Kafka ? Rabbitmq?? ?? ????.
• Rocketmq : ??? ???? ??? ? ??? ? ?? ??? ???? Alibaba? ?? ?? ??.

??? ??? ?? ?? ???? ??? ?? ????. ?? ??:

• ??? ???? ??? ???? ??? ?? ?? ? ?? ??? ?? ???? ? ?? RabbitMQ? ?? ?????.
• ?? ??, ??? ???? ?? ?? ???? ??? ???? ? ?? Kafka? ? ?????.
• ?? Alibaba Cloud Ecosystem? ???? ?? RocketMQ? ????? ? ?? ? ????.

???? ??? ???? ???? ??? ??????

RabbitMQ? ?? ??, ?? ????? ??? ????.

1. ????? ??? ?? (Maven) :

    <???>
       <groupid> com.rabbitmq </groupid>
       <artifactid> amqp-client </artifactid>
       <??> 5.21.0 </??>
   </???>

2. ?? ? ?? ?? :

    ConnectionFactory Factory = New ConnectionFactory ();
   Factory.Sethost ( "LocalHost");
   ?? ?? = factory.newConnection ();
   ?? ?? = Connection.CreateChannel ();

3. ???? ???? ???? ?????.

    channel.queuedeClare ( "task_queue", false, false, false, null);
   ??? ??? = "Hello World!";
   channel.basicpublish ( "", "task_queue", null, message.getBytes ());

4. ??? ?? ??? ??? :

    DeliveryCallback DeliverCallback = (???, ??) -> {
       ??? msg = new String (Delivery.getBody (), "UTF-8");
       System.out.println ( "??? ?? :"msg);
   };
   channel.basicConsume ( "task_queue", true, delivercallback, consumertag-> {});

??? ??? ??????. ?? ????? ? ??, ?? ?? ? ? ?? ????? ?? ??? ???????.

??? ???? ??? ? ??? ? ??

• ??? ?? ?? : ???? ???? ?? ???? ???? ??? ??? ? ?? ?? ??? ???????.
• ???? ?? ?? : ??? ??? ?? ? ? ?? ID? ?? ?? ??? ?? Idempotence? ???????.
• Performance Bottleneck : ?? ????? ??? ??? ?? ??? ?, ?? ?? ?? ?? ?? ??? ????? ?????.
• ?? ? ?? ?? ?? : ????? ??? ???? ??, ???? ? ???? ???? ?????.

?? ?? ???? ???? (AWS SQS, Alibaba Cloud RocketMQ ?)? ???? MQ ???? ?? ???? ?? ?? ? ?? ?? ??? ?? ? ? ????.

????? ?? ??. ??? ???? ?? ? ?? ????? ????? ??? ? ?? ??? ?? ????? ?? ? ? ???? ??? ? ? ????.

? ??? ??? ????? Java ??? ???? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!