springboot使用RabbitMQ教程
docker安裝,拉取鏡像
docker pull rabbitmq:management
創建容器並啟動
docker run -d --name rabbitmq --publish 5671:5671 --publish 5672:5672 --publish 4369:4369 --publish 25672:25672 --publish 15671:15671 --publish 15672:15672 rabbitmq:management
管理地址:
http://localhost:15672/ 用戶名:guest 密碼:guest
2、配置springboot
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
(2)添加rabbit配置文件,配置server信息
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
- @Author 馮戰魁
- @Date 2018/1/12 下午2:50*/
@Configuration
br/>*/
@Configuration
br/>@Bean
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
connectionFactory.setVirtualHost("/");
connectionFactory.setPublisherConfirms(true); //必須要設置
return connectionFactory;}
@Bean
br/>}
@Bean
return new Queue("hello");
}
}
(3)創建生產者,循環下發四個任務,用sleep模擬任務處理時間,一個.代碼任務處理1s的時長,分別有四個不同時長的任務下發
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
- @Author 馮戰魁
- @Date 2018/1/12 上午11:21*/
@RestController
br/>*/
@RestController
br/>@Autowired
br/>@RequestMapping("/sender")
String[] tasks = {"1.","2..","3...","4...."};
for (int i=0;i<tasks.length;i++){
String content = tasks[i];
System.out.println("Sender : " + content);
this.rabbitTemplate.convertAndSend("hello",content);
}
}
}
(4)創建兩個消費者Receiver1,Receiver2處理隊列的任務
Receiver1:
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
/**
- @Author 馮戰魁
- @Date 2018/1/12 下午3:06*/
@Component
br/>*/
@Component
public class RabbitReceiver1 {@RabbitHandler
br/>@RabbitHandler
System.out.println("Receiver1 : " + content);
try {
dowork(content);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void dowork(String content) throws InterruptedException{
for (char ch: content.toCharArray()) {
if (ch == ‘.‘){
Thread.sleep(1000);
}
}
}
}
Receiver2:
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
/**
- @Author 馮戰魁
- @Date 2018/1/12 下午3:06*/
@Component
br/>*/
@Component
public class RabbitReceiver2 {@RabbitHandler
br/>@RabbitHandler
System.out.println("Receiver2 : " + content);
try {
dowork(content);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void dowork(String content) throws InterruptedException{
for (char ch: content.toCharArray()) {
if (ch == ‘.‘){
Thread.sleep(1000);
}
}
}
}
(5)驗證代碼
啟動springboot,執行生產者的接口
http://localhost:8080/sender
然後查看終端輸出的信息,如圖所示
可以看到最先完成的消費者去執行下一個任務,是按任務時長執行,並不是按任務個數平分,防止消費者無意義的等待,提高效率。
查看rabbit的管理端http://localhost:15672/
可以看到已經生成隊列
至此整個任務完成!
springboot使用RabbitMQ教程