1.基本安装
分为 server + client
server的安装:
1.添加 deb http://www.rabbitmq.com/debian/ testing main 到 /etc/apt/sources.list
2.apt-get update.
3.sudo apt-get install rabbitmq-server
这个步骤会自动启动 rabbitmq-server 服务。
常用命令:
rabbitmqctl -h
rabbitmqctl status
rabbitmqctl stop
rabbitmqctl start_app
客户端安装:
maven:
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>2.8.4</version>
</dependency>
或是下载链接:
wget http://www.rabbitmq.com/releases/rabbitmq-java-client/v2.8.4/rabbitmq-java-client-bin-2.8.4.tar.gz
客户端编码---发送者:
package com.jieting.mq.rabbit.send;
import java.io.IOException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class MessageSend {
private static final String QUENE_NAME = "hello";
public static void main(String[] args) throws IOException {
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("localhost");
Connection newConnection = connectionFactory.newConnection();
Channel createChannel = newConnection.createChannel();
createChannel.queueDeclare(QUENE_NAME, true, false, false, null);
String message = "hello rabbitmq world!";
createChannel.basicPublish("", QUENE_NAME, null, message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
createChannel.close();
newConnection.close();
}
}
消费者代码:
package com.jieting.mq.rabbit.receive;
import java.io.IOException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.ShutdownSignalException;
public class MessageReceive {
private static final String QUENE_NAME = "hello";
public static void main(String[] args) throws IOException, ShutdownSignalException, ConsumerCancelledException,
InterruptedException {
ConnectionFactory connectionFactory = new ConnectionFactory();
Connection newConnection = connectionFactory.newConnection();
Channel createChannel = newConnection.createChannel();
createChannel.queueDeclare(QUENE_NAME, true, false, false, null);
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
QueueingConsumer queueingConsumer = new QueueingConsumer(createChannel);
createChannel.basicConsume(QUENE_NAME, true, queueingConsumer);
while (true) {
QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
}
}
}
以上资料都可从 一下地址找到:
http://www.rabbitmq.com/java-client.html
http://www.rabbitmq.com/getstarted.html
分享到:
相关推荐
AMQP-CPP是用于与RabbitMq消息中间件通信的c++库。它能解析从RabbitMq服务发送来的数据,也可以生成发向RabbitMq的数据包。
amqp-client-5.3.0-sources.jar ,RabbitMQ for Android SDK 源代码
标签:rabbitmq、amqp、client、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
标签:rabbitmq、amqp、client、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
标签:rabbitmq、amqp、client、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
标签:rabbitmq、amqp、client、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
jmeter amqp-client jar包 rabbitmq amqp-client-3.6.6.jar
使用JAVA进行运用了RabbitMQ的程序时所需的源码包,此包导入工程之后便可使用。
specs/amqp0-9-1.pdf来源:https://www.rabbitmq.com/resources/specs/amqp0-9-1.pdf A080219O.pdf来源:https://www.immagic.com/eLibrary/ARCHIVES/TECH/AMQP_US/A080219O.pdf amqp.pdf来源:...
AMQP-CPP-xcode-示例一个基于Copernica的AMQP-CPP库构建的RabbitMQ消息代理C11 / C ++客户端Mac Xcode示例项目。 创建的示例工作旨在展示我对C11 / C ++语言的命令,并展示了一些良好的设计实践和实时开发模式/技术...
AMQP-CPP是用于与RabbitMQ消息代理进行通信的C ++库。 该库可用于解析来自RabbitMQ服务器的传入数据,并生成可发送到RabbitMQ服务器的帧。 该库具有分层的体系结构,并且允许您(如果您愿意)完全照顾网络层。 如果...
compile 'com.rabbitmq:amqp-client:4.0.0' } 1 2 3 3.2 直接下载jar包,引用jar包 可在下载页面直接下载jar包,下载后放到LIB目录下添加引用:右键jar包->add as Library。或直接修改Gradle文件: dependencies ...
只能用于 android 7.0 以及后面的版本。别人的demo https://blog.csdn.net/lamunuosang/article/details/72287843
java整合rabbitMQ需要的jar包,需要的可以自取,分享给大家。 <groupId>com.rabbitmq</groupId> <artifactId>amqp-client <version>3.4.1 </dependency>
下载 RabbitMQ客户端插件amqp-client-3.4.4.jar,并放在Jmeter的lib/ext目录;一定要用3.X版本,否则跟源码不兼容,当然有编码能力的同学可以随意改造
go-amqp-example Golang中RabbitMQ消息的发布者和消费者示例 要求 以下说明假设您已正确安装Go (并且正确设置了 $GOPATH)并使用默认设置安装了RabbitMQ 。 获取代码 go get github....
nodemailer-amqp-example, 将Nodemailer与RabbitMQ一起使用的示例 Nodemailer示例 这是一个使用 RabbitMQ ( amqplib ) 作为队列 Nodemailer电子邮件消息的示例。 这允许你快速从应用程序推
RabbitMQ 的windows php 扩展php_amqp-1.2.0-5.3-nts-vc9-x86.dll
需要下载amqp-client-3.4.4.jar和JmeterAMQP.jar,并放在Jmeter的lib/ext目录