rabbitmq实例_rabbitmq创建队列

$ tar -zxvf otp_src_18.3.tar.gz 

$ cd otp_src_18.3

$ ./configure --prefix=/usr/local/erlang --with-ssl -enable-threads -enable-smmp-support -enable-kernel-poll --enable-hipe --without-javac

$ make

$ sudo make install

ERLANG_HOME=/usr/local/erlang
PATH=$ERLANG_HOME/bin:$PATH
export ERLANG_HOME
export PATH

source /etc/profile

$ sudo yum install xmlto

$ xz -d rabbitmq-server-generic-unix-3.6.1.tar.xz

$ tar -xvf rabbitmq-server-generic-unix-3.6.1.tar 

# 移动目录
$ sudo cp -rf ./rabbitmq_server-3.6.1/ /usr/local/

$ cd /usr/local

#改名字
$  mv rabbitmq_server-3.6.1 rabbitmq-3.6.1

# 安装web管理插件
$ cd sbin/

$ ./rabbitmq-plugins enable rabbitmq_management

$ ./rabbitmq-server

# 后台启动
$ ./rabbitmq-server -detached

# 关闭
$ ./rabbitmqctl stop

$ ./rabbitmqctl add_user pony 123456
Creating user "pony" ...

$ ./rabbitmqctl set_user_tags pony administrator       
Setting tags for user "pony" to [administrator] ...

-A INPUT -p tcp -m state --state NEW -m tcp --dport 15672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 25672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 5672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 4369 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 5671 -j ACCEPT

ERLANG_HOME C:\Program Files\erl7.3

%ERLANG_HOME%\bin;

RABBITMQ_SERVER C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9

%RABBITMQ_SERVER%\sbin;

C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9\sbin>rabbitmq-plugins.bat enable rabbitmq_management

C:\WINDOWS\system32>net stop RabbitMQ && net start RabbitMQ
RabbitMQ 服务正在停止.
RabbitMQ 服务已成功停止。

RabbitMQ 服务正在启动 .
RabbitMQ 服务已经启动成功。


C:\WINDOWS\system32>

C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9\sbin>rabbitmqctl.bat add_user pony 123456
Creating user "pony" ...

C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9\sbin>rabbitmqctl.bat set_user_tags pony administrator
Setting tags for user "pony" to [administrator] ...

private final static String QUEUE_NAME = "hello";
public static void main(String[] args) throws Exception{ 

// TODO Auto-generated method stub
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");//因为两个进程在同一个机器上
Connection connection = null;
Channel channel = null;
connection = factory.newConnection();
channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Hello World!";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
System.out.println(" [Producer] Sent '" + message + "'");
channel.close();
connection.close();
}

private final static String QUEUE_NAME = "hello";
public static void main(String[] args) throws Exception{ 

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
Consumer consumer = new DefaultConsumer(channel) { 

@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
throws IOException { 

String message = new String(body, "UTF-8");
System.out.println(" [Consumer] Received '" + message + "'");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
}

String basicConsume(String queue, boolean autoAck, Consumer callback) throws IOException 

 [*] Waiting for messages. To exit press CTRL+C

 [Producer] Sent 'Hello World!'

 [*] Waiting for messages. To exit press CTRL+C
[Consumer] Received 'Hello World!'