Teknologian jakaminen

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

Ensin täytyy luoda mikropalveluarkkitehtuuri, koska yleisesti ottaen tätä käytetään mikropalveluarkkitehtuurissa (tietenkään yksittäisessä entiteetissä ei ole mitään vikaa, katso qps)

Pääprojektissa meidän on otettava käyttöön amqp-riippuvuudet

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

Valitse sitten alipalvelu, jonka tarvitsemme viestin alustuksen loppuun saattamiseksi

Ensimmäinen on viestien lähettäminen käyttämällä RabbitTemplatea viestin lähetysmallina, menetelmä 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);
    }
}

Sitten voimme luoda kuuntelijaluokan kuuntelijapaketin alle (On rekisteröitävä kevätpavuksi) valmistumisviesti @RabbitListenerin kautta

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

ok, nyt springAMQP:n alaisen rabbitmq:n viestin lähettäminen ja vastaanottaminen on valmis.