RabbitMQ安裝和測試小記

ShangShujie 2010-07-25

展開全文

RabbitMQ安裝和測試小記收藏

操作系統(tǒng)CentOS x86_64 5.4

安裝Erlang

可以到www.erlang.org去下載最新的源碼，編譯安裝。

不過RabbitMQ的官方文檔建議使用yum安裝。

EPEL是啥？

參見http:///wiki/EPEL/FAQ#howtouse

安裝步驟：

wget http://download.fedora./pub/epel/5/x86_64/epel-release-5-3.noarch.rpm

rpm -Uvh epel-release-5-3.noarch.rpm

yum install erlang

安裝RabbitMQ

到 http://www./server.html 下載

rabbitmq-server-1.7.2-1.x86_64.rpm

然后

rpm -ivh rabbitmq-server-1.7.2-1.x86_64.rpm

運(yùn)行RabbitMQ

/etc/init.d/rabbitmq-server start

注意

RabbitMQ使用了5672端口，修改iptables把5672端口打開。

測試

在官網(wǎng)下載java的客戶端rabbitmq-java-client-bin-1.7.2.tar.gz

消息發(fā)布

view plain copy to clipboard print ?

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConnectionParameters;
import com.rabbitmq.client.MessageProperties;
public class PublishTest {
public static void main(String[] args) {
try {
ConnectionParameters params = new ConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory = new ConnectionFactory(params);
Connection conn = factory.newConnection("192.168.56.110", 5672);
Channel channel = conn.createChannel();
channel.exchangeDeclare("exchange1", "direct", true);
channel.queueDeclare("queue1", true);
channel.queueBind("queue1", "exchange1", "key1");
byte[] messageBodyBytes = "Hello, world!".getBytes();
channel.basicPublish("exchange1", "key1", MessageProperties.PERSISTENT_TEXT_PLAIN, messageBodyBytes);
channel.close();
conn.close();
System.out.println("Over.");
} catch (Exception e) {
e.printStackTrace();
}
}
}

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConnectionParameters;
import com.rabbitmq.client.MessageProperties;
public class PublishTest {
public static void main(String[] args) {
try {
ConnectionParameters params = new ConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory = new ConnectionFactory(params);
Connection conn = factory.newConnection("192.168.56.110", 5672);
Channel channel = conn.createChannel();
channel.exchangeDeclare("exchange1", "direct", true);
channel.queueDeclare("queue1", true);
channel.queueBind("queue1", "exchange1", "key1");
byte[] messageBodyBytes = "Hello, world!".getBytes();
channel.basicPublish("exchange1", "key1", MessageProperties.PERSISTENT_TEXT_PLAIN, messageBodyBytes);
channel.close();
conn.close();
System.out.println("Over.");
} catch (Exception e) {
e.printStackTrace();
}
}
}

消息接收

view plain copy to clipboard print ?

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConnectionParameters;
import com.rabbitmq.client.GetResponse;
public class ConsumerTest {
public static void main(String[] args) {
try {
ConnectionParameters params = new ConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory = new ConnectionFactory(params);
Connection conn = factory.newConnection("192.168.56.110", 5672);
Channel channel = conn.createChannel();
boolean noAck = false;
GetResponse response = channel.basicGet("queue1", noAck);
if (response == null) {
System.out.println("No message!");
} else {
byte[] body = response.getBody();
long deliveryTag = response.getEnvelope().getDeliveryTag();
String str = new String(body);
System.out.println(str);
channel.basicAck(deliveryTag, false); // acknowledge receipt of the message
}
channel.close();
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConnectionParameters;
import com.rabbitmq.client.GetResponse;
public class ConsumerTest {
public static void main(String[] args) {
try {
ConnectionParameters params = new ConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory = new ConnectionFactory(params);
Connection conn = factory.newConnection("192.168.56.110", 5672);
Channel channel = conn.createChannel();
boolean noAck = false;
GetResponse response = channel.basicGet("queue1", noAck);
if (response == null) {
System.out.println("No message!");
} else {
byte[] body = response.getBody();
long deliveryTag = response.getEnvelope().getDeliveryTag();
String str = new String(body);
System.out.println(str);
channel.basicAck(deliveryTag, false); // acknowledge receipt of the message
}
channel.close();
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}

本站是提供個(gè)人知識管理的網(wǎng)絡(luò)存儲空間，所有內(nèi)容均由用戶發(fā)布，不代表本站觀點(diǎn)。請注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息，謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點(diǎn)擊一鍵舉報(bào)。

轉(zhuǎn)藏 分享

QQ空間 QQ好友新浪微博微信

獻(xiàn)花（0） +1

來自： ShangShujie > 《資料》

舉報(bào)/認(rèn)領(lǐng)