Κοινή χρήση τεχνολογίας

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Πρώτα πρέπει να δημιουργήσουμε μια αρχιτεκτονική microservice, γιατί γενικά αυτό χρησιμοποιείται σε μια αρχιτεκτονική microservice (φυσικά δεν υπάρχει τίποτα κακό με μια μεμονωμένη οντότητα, βλέπε qps)

Στο μητρικό έργο πρέπει να εισαγάγουμε τις εξαρτήσεις amqp

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

Στη συνέχεια, επιλέξτε την υπο-υπηρεσία που χρειαζόμαστε για να ολοκληρώσουμε την πρώτη εκκίνηση του μηνύματος

Το πρώτο είναι η αποστολή μηνυμάτων, χρησιμοποιώντας το RabbitTemplate ως πρότυπο αποστολής μηνυμάτων, η μέθοδος convertAndSend

@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    void testMsgCaiyiTestQueue(){
        String msg = "this is message from caiyi";
        rabbitTemplate.convertAndSend("cybg_study_queue",msg);
    }
}

Στη συνέχεια, μπορούμε να δημιουργήσουμε την κλάση ακροατή κάτω από το πακέτο ακροατών (Πρέπει να καταχωρηθεί ως ανοιξιάτικο φασόλι) μήνυμα ολοκλήρωσης, μέσω @RabbitListener

@RabbitListener(queues = "cybg_study_queue")
public void listenQueueMsg(String msg){
    System.out.println("接收到的msg："+msg);
}

εντάξει, τώρα ολοκληρώθηκε η αποστολή και λήψη μηνύματος για το rabbitmq στο springAMQP.