Skip to main content

RabbitMq-Web应用版

演示一个web中rabbitmq客户端的使用,更多使用方式请参考dawdler-client-plug-rabbitmq.

1. 下载并运行​

下载示例dawdler-tutorial.zip,版本为jdk1.8.

解压后,进入rabbitmq-single-web目录中.

启动rabbitmq并配置rabbitmq.properties.

运行UserWebApplication.java的main方法.

@DawdlerBootApplication
public class UserWebApplication {
	public static void main(String[] args) throws Throwable {
		DawdlerWebApplication.run(UserWebApplication.class, args);
	}
}

1.1 配置文件说明​

rabbitmq.properties rabbitmq连接配置也支持放在统一配置中心.

相关配置参考dawdler-rabbitmq-core.

1.2 通过jar包方式运行​

通过运行

 mvn clean package

获得 rabbitmq-single-web-0.0.1-jdk1.8-SNAPSHOT-all.jar

运行

java -jar rabbitmq-single-web-0.0.1-jdk1.8-SNAPSHOT-all.jar

1.3 验证​

通过postman或游览器访问 http://localhost:8085/user/sendMessage?msg=helloWorld

访问成功后, UserWebListener.java

@RabbitListener(fileName="rabbitmq", prefetchCount=1,  queueName="demo.queue", autoAck=false,concurrentConsumers = 2)
public void consume(Message message) throws Exception {
	System.out.println("receive message: " + new String(message.getBody()));
}

控制台会打印出 receive message: helloWorld