首页 > 编程知识 正文

怎么看rabbitmq的安装位置,rabbitmq使用教程

时间:2023-05-06 01:56:46 阅读:146643 作者:1017

调查1MQ是否存在

dockersearchrabbitmq :管理

2下载镜像

dockerpullrabbitmq 3360管理

发布docker镜像

docker run-d-- namerabbit-erabbit MQ _ default _ user=admin-erabbit MQ _ default _ pass=admin-p 15672336015672 133

说明

命令中的【rabbit MQ _ default _ user=admin-erabbit MQ _ default _ pass=admin】是web管理平台的用户名和密码

【-p 15672:15672】控制平台docker映射到系统的对应端口

【-p 5672:5672】APP应用程序的访问端口

请单击此处查看端口说明

4 web端管理界面:

http://106.12.214.8:15672

系统将提示您输入用户名和密码

现在设置的是admin,没有设置密码,所以系统默认设置guest

5写测试范例:

importorg.JUnit.Jupiter.API.test; import com.rabbit MQ.client.channel; import com.rabbit MQ.client.connection; import com.rabbit MQ.client.connection factory; import java.io.IOException; import Java.util.concurrent.time out exception; publicclasstestmq { @ testpublicvoidtestsendmess (} { string queue name=' test _ q '; try { connectionfactoryfactory=newconnectionfactory (); factory.setusername('guest ); factory.setpassword('guest123 ); factory.sethost(106.12.214.8 ); factory.setport(5672; factory.setvirtualhost('/'; 连接连接=factory.new连接(; channel channel=connection.create channel (; channel.queuedeclare(queuename,false,false,null ); String message='Hello World!' ; channel.basicPublish (',queueName,null,message.getBytes ); system.out.println ([ x ] sent ' ' message ' ' ); channel.close (; connection.close (; }catch(exceptione ) }}这个例子参考了网站

引用包的pom.xml文件包括:

从属关系

groupid org.spring framework.boot/groupid

artifactidspring-boot-starter-amqp/artifact id

版本1.5.2 .版本/版本

/从属

springboot示例验证此地址

上面的测试用例在运行时出错:

17:54336040.740 [ amqpconnection 106.12.214.833605672 ] error com.rabbit MQ.client.impl.forgivingexceptionhananananation

ava.net.socket exception : socket closed

at Java.net.socket inputstream.socketread0(本机方法) )。

at Java.net.socket inputstream.read (socket inputstream.Java :150 )。

at Java.net.socket inputstream.read (socket inputstream.Java :121 )。

at Java.io.buffered inputstream.fill (buffered inputstream.Java :246 ) ) )。

at Java.io.buffered inputstream.read (buffered inputstream.Java :265 ) ) )。

at Java.io.data inputstream.readunsignedbyte (data inputstream.Java :288 )。

atcom.rabbit MQ.client.impl.frame.readfrom (frame.Java :91 )。

atcom.rabbit MQ.client.impl.socketframehandler.read frame (socketframehandler.Java :184 )。

atcom.rabbit MQ.client.impl.amqconnection $ main loop.run (amqconnection.Java :598 ) ) )。

at Java.lang.thread.run (thread.Java :744 )。

这是因为我创建的guest没有授予权限。 改成刚才的管理员就可以了。 管理员是管理员权限。 更改gust的权限就可以了。 访问成功!

显示管理界面:

此测试消息已经发送到mq。

版权声明:该文观点仅代表作者本人。处理文章:请发送邮件至 三1五14八八95#扣扣.com 举报,一经查实,本站将立刻删除。