文章目录前言1.安装erlang 语言2.安装rabbitMQ3. 内网穿透3.1 安装cpolar内网穿透(支持一键自动安装脚本)3.2 创建HTTP隧道4. 公网远程连接5.固定公网TCP地址5.1 保留一个固定的公网TCP端口地址5.2 配置固定公网TCP端口地址前言RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的可复用的企业消息系统是当前最主流的消息中间件之一。由erlang开发的AMQPAdvanced Message Queue 高级消息队列协议 的开源实现由于erlang 语言的高并发特性性能较好本质是个队列FIFO 先入先出里面存放的内容是message,下面介绍通过在ubuntucpolarrabbitMQ环境下实现mq服务端远程访问。1.安装erlang 语言由于rabbitMQ是erlang语言实现的,所以我们需要安装erlangsudoapt-getinstallerlang-nox2.安装rabbitMQ安装最新版rabbitMQsudoapt-getinstallrabbitmq-server查看rabbitMQ状态,active(running)表示在线sudosystemctl status rabbitmq-server设置访问MQ用户名账号和密码admin表示账号可自定义123456表示密码可自定义sudorabbitmqctl add_user admin123456设置上面admin用户的角色,administrator表示是最高管理员sudorabbitmqctl set_user_tags admin administrator设置admin角色权限sudorabbitmqctl set_permissions-p/admin.*.*.*以上信息设置好后我们往下走。3. 内网穿透接着我们使用cpolar穿透本地MQ服务,使得远程可以进行访问连接cpolar支持http/https/tcp协议不限制流量操作简单无需公网IP也无需路由器。cpolar官网https://www.cpolar.com/3.1 安装cpolar内网穿透(支持一键自动安装脚本)cpolar 安装国内使用curl-Lhttps://www.cpolar.com/static/downloads/install-release-cpolar.sh|sudobash或 cpolar短链接安装方式(国外使用curl-sLhttps://git.io/cpolar|sudobash查看版本号cpolar versiontoken认证登录cpolar官网后台点击左侧的验证查看自己的认证token之后将token贴在命令行里cpolar authtoken xxxxxxx向系统添加服务sudosystemctlenablecpolar启动cpolar服务sudosystemctl start cpolar正常显示为active则表示服务为正常在线启动状态3.2 创建HTTP隧道在ubuntu系统本地安装cpolar内网穿透之后在ubuntu浏览器上访问本地9200端口打开cpolar web ui界面:http://127.0.0.1:9200。点击左侧仪表盘的隧道管理——创建隧道,由于rabbitMQ中默认的是5672端口因此我们要来创建一条http隧道指向5672端口隧道名称可自定义注意不要重复协议tcp本地地址5672域名类型选择随机域名地区选择China VIP点击创建打开在线隧道列表,查看随机公网tcp地址,使用下面随机的tcp公网地址,即可远程连接MQ4. 公网远程连接maven坐标dependencygroupIdcom.rabbitmq/groupIdartifactIdamqp-client/artifactIdversion5.10.0/version/dependency这里使用java 测试使用上面公网地址进行连接,编写发布者ConnectionFactoryfactorynewConnectionFactory();//cpolar公网地址factory.setHost(1.tcp.cpolar.cn);//公网地址对于的端口号factory.setPort(24889);//用户名和密码factory.setUsername(admin);factory.setPassword(123456);Connectionconnectionnull;Channelchannelnull;try{// 1.创建连接和通道connectionfactory.newConnection();channelconnection.createChannel();// 2.为通道声明exchange和exchange的类型channel.exchangeDeclare(EXCHANGE_NAME,BuiltinExchangeType.FANOUT);Stringmsg hello world;// 3.发送消息到指定的exchange,队列指定为空,由exchange根据情况判断需要发送到哪些队列channel.basicPublish(EXCHANGE_NAME,,null,msg.getBytes());System.out.println(product send a msg: msg);}catch(IOExceptione){e.printStackTrace();}catch(TimeoutExceptione){e.printStackTrace();}finally{// 4.关闭连接if(channel!null){try{channel.close();}catch(IOExceptione){e.printStackTrace();}catch(TimeoutExceptione){e.printStackTrace();}}if(connection!null){try{connection.close();}catch(IOExceptione){e.printStackTrace();}}}编写消费者ConnectionFactoryfactorynewConnectionFactory();//cpolar公网地址factory.setHost(1.tcp.cpolar.cn);//公网地址对于的端口号factory.setPort(24889);//用户名和密码factory.setUsername(admin);factory.setPassword(123456);Connectionconnectionnull;Channelchannelnull;try{// 1.创建连接和通道connectionfactory.newConnection();channelconnection.createChannel();// 2.为通道声明exchange以及exchange类型channel.exchangeDeclare(exchange,BuiltinExchangeType.FANOUT);// 3.创建随机名字的队列StringqueueNamechannel.queueDeclare().getQueue();// 4.建立exchange和队列的绑定关系channel.queueBind(queueName,exchange,);System.out.println( **** Consumer1 keep alive ,waiting for messages, and then deal them);// 5.通过回调生成消费者并进行监听ConsumerconsumernewDefaultConsumer(channel){OverridepublicvoidhandleDelivery(StringconsumerTag,Envelopeenvelope,com.rabbitmq.client.AMQP.BasicPropertiesproperties,byte[]body)throwsIOException{// 获取消息内容然后处理StringmsgnewString(body,UTF-8);System.out.println(*********** Consumer1 get message :[msg]);}};// 6.消费消息channel.basicConsume(queueName,true,consumer);}catch(IOExceptione){e.printStackTrace();}catch(TimeoutExceptione){e.printStackTrace();}先启动消费者,然后启动发布者,然后消费者控制台输出消费者发送的消息表示成功.我们实现了远程访问MQ。5.固定公网TCP地址由于以上创建的隧道使用的是随机地址隧道,地址会在24小时内变化,为了使连接更加稳定,我们还需要固定tcp地址。5.1 保留一个固定的公网TCP端口地址登录cpolar官网后台点击左侧的预留选择保留的TCP地址。地区选择China VIP描述即备注可自定义填写点击保留地址保留成功后系统会生成相应的固定公网地址将其复制下来5.2 配置固定公网TCP端口地址在浏览器上访问9200端口登录cpolar web ui管理界面点击左侧仪表盘的隧道管理——隧道列表找到上面创建的隧道点击右侧的编辑修改隧道信息将保留成功的固定tcp地址配置到隧道中端口类型修改为固定tcp端口预留的tcp地址填写保留成功的地址点击更新隧道更新成功后点击左侧仪表盘的状态在线隧道列表找到需要编辑的隧道可以看到公网地址已经更新成为了固定TCP地址。更新好后,我们修改代码中的两个参数//cpolar公网地址,改为我们固定的地址factory.setHost(5.tcp.vip.cpolar.cn);//固定地址对应的端口号factory.setPort(13630);然后我们重新启动消费者,再启动生产者,正常发布和消费消息表示成功