rabbitmq是實現了高階訊息佇列協議（amqp）的開源訊息代理軟體，也成為面向訊息的中介軟體。RabbitMQ伺服器是用高效能，可伸縮而聞名的Erlang語言編寫而成的，其叢集和故障轉移是構建在開放電信平臺框架上的。

RabbitMQ的安裝這裡不重複說明，可以參考centos7自學之7-rabbitmq的安裝與配置,這裡介紹spring cloud使用RabbitMQ。

建立工程（springcloud-server-bus-rabbitmq）

新增依賴

<parent>
    <groupId>org.springframework.boot</groupId
 
>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
    <relativePath />
</parent>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId
 
>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Edgware.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
 

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

建立入口類

@SpringBootApplication
public class SpringCloudServerBusRabbitmq {
    public static void main(String[] args) {
        new SpringApplicationBuilder(SpringCloudServerBusRabbitmq.class)
                .web(true)
                .run(args)
                ;
    }
}

建立配置檔案

spring:
  rabbitmq:
    host: 192.168.175.128
    port: 5672
    username: admin
    password: admin
  application:
    name: springcloud-server-bus-rabbitmq

建立配置類

@Configuration
public class RabbitMqConfig {

    public static final String queueName = "springcloud-server-bus-rabbitmq" ;
    public Queue rabbitMqQueue(){
        return new Queue(queueName);
    }
}

建立生產者

@Component
public class Prodecer {

    private final Logger _logger = LoggerFactory.getLogger(this.getClass()) ;
    @Autowired
    private AmqpTemplate rabbitMqTemplate ;

    public void send(){
        String context = "hello" + new Date() ;
        _logger.info("正在向佇列傳送訊息：{}",context);
        this.rabbitMqTemplate.convertAndSend(RabbitMqConfig.queueName,context);
    }
}

建立消費者

@Component
@RabbitListener(queues = RabbitMqConfig.queueName)
public class Consumer {
    private final Logger _logger = LoggerFactory.getLogger(this.getClass()) ;

    @RabbitHandler
    public void consumer(String message){
        _logger.info("從佇列獲取到的訊息:{}",message);
    }
}

建立web介面

@Controller
@RequestMapping("/api/rest")
public class RestfulController {

    @Autowired
    Prodecer prodecer ;
    @GetMapping("/message")
    public void message(){
        prodecer.send();
    }
}

建立結構圖如下

執行專案

啟動springcloud-server-bus-rabbitmq。

原始碼

歷史文章