rabbitmq实例_rabbitmq创建队列

rabbitmq实例_rabbitmq创建队列RabbitMQ简介RabbitMQ是一个受欢迎的消息代理,通常用于应用程序之间或者程序的不同组件之间通过消息来进行集成。具有高可用高并发的优点,适合集群服务器。采用Erlang实现,对主要的编程语言都有客户端支持。RabbitMQ环境配置linux下环境配置我用的是centos6.5版本。先从这个地址下载安装包下载地址$tar-zxvfotp_…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

RabbitMQ简介

RabbitMQ是一个受欢迎的消息代理,通常用于应用程序之间或者程序的不同组件之间通过消息来进行集成。具有高可用高并发的优点,适合集群服务器。采用 Erlang实现, 对主要的编程语言都有客户端支持。

RabbitMQ环境配置

linux下环境配置

我用的是centos 6.5版本。

先从这个地址下载安装包

下载地址

$ 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

配置环境变量

vim /etc/profile

在文件末尾添加下面文字:

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

使环境变量生效

source /etc/profile

然后下载RabbitMQ,下载地址

先安装依赖

$ 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

登录web管理端

启动rabbitmq,然后浏览器输入
http://10.0.0.221:15672/

这个ip地址是你实际安装的主机的ip,请根据实际情况修改。

这里写图片描述

下面配置登录账号

$ ./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

windows下环境配置

erlang下载地址

rabbitmq下载地址

可以根据需要下载自己所需要的版本,我这里下载的分别是:

otp_win64_18.3.exe和rabbitmq-server-3.6.9.exe

默认方式安装otp_win64_18.3.exe,完成后,配置环境变量

ERLANG_HOME C:\Program Files\erl7.3

添加到PATH

%ERLANG_HOME%\bin;

默认方式安装rabbitmq-server-3.6.9.exe,完成后,配置环境变量

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

添加到PATH

%RABBITMQ_SERVER%\sbin;

进入sbin目录打开一个控制台,安装web管理插件

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

然后重启下服务使上面的配置生效(注意这里要使用管理员打开cmd命令行,路径无影响),

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

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


C:\WINDOWS\system32>

打开浏览器,输入http://localhost:15672/,可以正常访问。由于我是在本机安装,所以这里是localhost。

接下来配置一个账号并赋予管理员权限(当然要确保是启动状态),

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] ...

在web端用这个账号登录,可以成功!

java调用示例

我的开发环境是myeclipse+win10,windows环境下已经按照前面章节配置好了rabbitmq服务。**然后保持启动状态。**java要使用rabbitmq需要依赖一个客户端。下载地址

如果用maven的话就不用下载,配置文件加上依赖描述即可。

我这里新建两个工程,分别为RabbitMQDemo-P(表示生产者)和RabbitMQDemo-C(表示消费者),两个工程运行起来后就代表两个独立的进程通过消息队列通信。生产者不断的往消息队列发送消息,而消费者不断的从队列取消息。工程中导入前面下载的客户端依赖包。

源码来自:rabbitmq-tutorials

eclipse工程源码下载地址

这里写图片描述

先生产者的代码:


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();
	}

比较简单,涉及到的API具体说明可以自行搜索学习。运行一次就往名为hello的队列上发布一条消息:“Hello World”,然后进程结束。

消费者稍微复杂一点,

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);
		
	}

Channel.basicConsume方法将Consumer与消息队列绑定,它的定义如下:

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

第一个参数是Consumer绑定的队列名,第二个参数是自动确认标志,如果为true,表示Consumer接受到消息后,会自动发确认消息(Ack消息)给消息队列,消息队列会将这条消息从消息队列里删除,第三个参数就是Consumer对象,用于处理接收到的消息。

第三个参数其实是个回调,当消费者收到消息时,会调用Consumer对象的handleDelivery方法。我们这里重写了这个方法,收到消息之后打印出来。

先运行消费者,如下:

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

开始等待消息。

再运行生产者,如下:

 [Producer] Sent 'Hello World!'

再次看下消费者的控制台信息,接收到消息:

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

在这里插入图片描述
欢迎大家关注我的公众号

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/189011.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • volatile为什么不能保证原子性

    volatile为什么不能保证原子性首先要了解的是,volatile可以保证可见性和顺序性,这些都很好理解,那么它为什么不能保证原子性呢?可见性可见性与Java的内存模型有关,模型采用缓存与主存的方式对变量进行操作,也就是说,每个线程都有自己的缓存空间,对变量的操作都是在缓存中进行的,之后再将修改后的值返回到主存中,这就带来了问题,有可能一个线程在将共享变量修改后,还没有来的及将缓存中的变量返回给主存中,另外一个线程就对…

  • web应用开发常见问题解决总结

    web应用开发常见问题解决总结

  • java类加载器是什么_类加载器有几种

    java类加载器是什么_类加载器有几种类加载器是有了解吗?解析:底层原理的考察,其中涉及到类加载器的概念,功能以及一些底层的实现。答:顾名思义,类加载器(classloader)用来加载Java类到Java虚拟机中。一般来说,Java虚拟机使用Java类的方式如下:Java源程序(.java文件)在经过Java编译器编译之后就被转换成Java字节代码(.class文件)。类加载器负责读取Java…

  • java线程池面试题有哪些?java线程池常见面试题「建议收藏」

    java线程池面试题有哪些?java线程池常见面试题「建议收藏」进行java面试的过程中,java线程池是必问的面试题目,因为这是java的重点知识,也是在java工作中经常会遇到的,那java线程池面试题有哪些?下面来我们就来给大家讲解一下java线程池常见面试题。1.了解过线程池的工作原理吗?当线程池中有任务需要执行时,线程池会判断如果线程数量没有超过核心数量就会新建线程池进行任务执行,如果线程池中的线程数量已经超过核心线程数,这时候任务就会被放入任务队列中排队等待执行;如果任务队列超过最大队列数,并且线程池没有达到最大线程数,就会新建线程来执行任务;如果超过了

  • psd效果预览转成网站首页(html+css)

    psd效果预览转成网站首页(html+css)1.先确定结构按结构划分区块,从整体到部分2.切图:ctrl+缩览图可以载入选区(1)logo类:包括一些小图标+文字+数字(透明背景)首先选择这些图片的图层(shift选择多个),转成智能对象,双击图标进入,存储为web格式(png-24,颜色不需要太丰富,24即可)注意,这些logo一般放在<a>链接中,href="#"链接到首页(本页)(2)海报、设计图…

  • windows退出vim

    windows退出vim在普通模式下,用ZZ来保存并退出,用ZQ不保存退出。在插入模式下,先按来回到普通模式,再按ZZ或者ZQ。(注意:ZZ或者ZQ直接按,要大写。)

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号