精华内容
下载资源
问答
  • rocket MQ服务器搭建

    2017-02-13 15:42:20
    可以使用rocketmq-console来监控rocketmq服务器消费情况 下面来讲解如何配置rocketmq消息队列集群部署和监控: 目前在Github上可下载最新的安装包alibaba-rocketmq-3.2.6.tar 下载地址:h...

    rocketmq单机搭建请参考:http://blog.csdn.net/loongshawn/article/details/51086876

    可以使用rocketmq-console来监控rocketmq服务器消费情况

    下面来讲解如何配置rocketmq消息队列集群部署和监控:

    目前在Github上可下载最新的安装包alibaba-rocketmq-3.2.6.tar

    下载地址:https://github.com/alibaba/RocketMQ

    一,RocketMQ简介

    ================================================

    RocketMQ是一款分布式,队列模型的消息中间件,具有以下特点:

    1.支持严格的消息顺序;

    2.支持Topic与Queue两种模式;

    3.亿级消息堆积能力;

    4.比较友好的分布式特性;

    5.同事支持Push与Pull方式消费消息

     

    ===============================================

    二,服务器分布

    ===============================================

    1.相关说明


     

    2.hosts信息添加

    #vi /etc/hosts

     

    3.系统环境

    CentOS6.8

     

    4.总体架构


     

     

    ========================================

    三,RocketMQ安装与配置

    ========================================

    1、JDK安装

    下载linux版本的jdk:http://download.oracle.com/otn-pub/java/jdk/8u121-b13/e9e7ea248e2c4826b92b3f075a80e441/jdk-8u121-linux-x64.tar.gz

    解压安装包:

    #tar -zxvf jdk-8u121-linux-x64.tar.gz

     

     

    2.RocketMQ安装

    下载:https://github.com/alibaba/RocketMQ/releases

    ①解压安装包

    #tar -zxvf alibaba-rocketmq-3.2.6.tar.gz

    ②建立软连接

    #ln -s /applicaiton/alibaba-rocketmq /opt/alibaba-rocketmq

     

    3.环境变量设置

    #vi /etc/profile


     

    #source /etc/profile  使环境变量生效

     

    4.hosts文件配置

    CentOS1,CentOS2, CentOS3配置一样,如下:


     

    5.RocketMQ配置

    ①Master1服务器

    #vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-a.properties


     

    ②Master2服务器

    #vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-b.properties


     

    ③Master3服务器

    #vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-c.properties


     

    6.启动服务器

    ①启动NameServer[Master1, Master2, Master]

    #cd /opt/alibaba-rocketmq/bin

    #nohup sh mqnamesrv &

     

    ②启动BrokerServer A[Master1]

    #cd /opt/alibaba-rocketmq/bin

    # nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties &

     

    ③启动BrokerServer B[Master2]

    #cd /opt/alibaba-rocketmq/bin

    # nohup sh mqbroker -c ../conf/2m-noslave/broker-b.properties &

     

    ④启动BrokerServer C[Master3]

    #cd /opt/alibaba-rocketmq/bin

    # nohup sh mqbroker -c ../conf/2m-noslave/broker-c.properties &

     

    #netstat -ntlp


     

    关闭nameserver broker执行的命令

    #mqshutdown namesrv

    #mqshutdown broker

     

    4.安装启动rocketmq管理控制台,可以查看rocketmq集群信息


    rocketmq主题信息


     
     

     

     

     

     

    参考:http://blog.csdn.net/lang_man_xing/article/details/47447797

     

    展开全文
  • 基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口号的问题解决基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口...

    基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通

    基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口号的问题解决

    基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口号的问题解决

    一、搭建rabbitmq

    创建docker-compose.yml

    在腾讯云中开启安全组

    二、问题描述

    三、问题排查

    1. 检查防火墙

    2. 查看端口监听

    3. 检查安全组是否真的开启

    四、问题解决

    创建docker-compose.yml

    version: '3'

    services:

    rabbitmq:

    container_name: rabbitmq

    image: rabbitmq:3.7-rc

    restart: always

    ports:

    - 5672:5672

    - 15672:15672

    volumes:

    - ./data:/var/lib/rabbitmq

    environment:

    - RABBITMQ_DEFAULT_VHOST=my_vhost

    - RABBITMQ_DEFAULT_USER=admin

    - RABBITMQ_DEFAULT_PASS=admin

    创建完毕后通过docker-compose up -d启动rabbitmq

    在腾讯云中开启安全组

    3535b717df1522933b401bde1410a4e6.png

    这时候理论上通过ip+15672就可以访问我的rabbitmq的管理页面了。但是就是访问不了,通过telnet + ip + 端口号的方式检查也是无法连接。

    1. 检查防火墙

    firewall-cmd --state

    2. 查看端口监听

    sudo netstat -tunlp | grep 15672

    [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-4pUInD9b-1600333729304)(index_files/6ee4e01f-ddff-4822-982b-8c413356dafd.png)]

    可以看到1、2都没有问题

    3. 检查安全组是否真的开启

    既然安全组开了两个端口:5672和15672,15672无法访问,那么5672呢。

    通过telnet + ip + 5672测试发现5672正常。

    将docker-compose中的端口映射互换一下,5672-》15672,15672-》5672。

    再次通过telnet + ip + 5672测试发现5672无法访问了!!!

    这说明安全组没有问题,问题肯定是出在服务上面的,那么有没有可能是rabbitmq 的控制台需要手动开启才能够访问呢?

    网上查了一下发现rabbitmq 的后缀有"-management"的镜像版本是包含网页控制台的。

    找到问题所在。。

    修改docker-compose.yml文件中rabbitmq的使用版本:

    version: '3'

    services:

    rabbitmq:

    container_name: rabbitmq

    image: rabbitmq:3.8.3-management

    restart: always

    ports:

    - 5672:5672

    - 15672:15672

    volumes:

    - ./data:/var/lib/rabbitmq

    environment:

    - RABBITMQ_DEFAULT_VHOST=my_vhost

    - RABBITMQ_DEFAULT_USER=admin

    - RABBITMQ_DEFAULT_PASS=admin

    由此可见 telnet不通的时候有可能是后台的服务根本没有启动。

    基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通相关教程

    展开全文
  • 本次搭建集群是基于阿里云ECS服务器搭建的,本质上是使用Docker完成模拟三台机器搭建集群的过程,本质上在三台机器上搭建集群的的过程和这个是相似的。由于pool,所以采用模拟的方式来搭建集群。 拉取阿里云activeMQ...

    ActiveMQ集群搭建

    本次搭建集群是基于阿里云ECS服务器搭建的,本质上是使用Docker完成模拟三台机器搭建集群的过程,本质上在三台机器上搭建集群的的过程和这个是相似的。由于pool,所以采用模拟的方式来搭建集群。

    拉取阿里云activeMQ镜像

    docker pull registry.cn-hangzhou.aliyuncs.com/daydayup/activemq
    

    可通过docker images命令查看当前镜像:
    在这里插入图片描述
    之后可以通过docker命令启动镜像,这里为了快速搭建使用的是自动分配端口的方式,所以:

    docker run -ti - d -R registry.cn-hangzhou.aliyuncs.com/daydayup/activemq
    

    可以看到已经正常启动了:
    在这里插入图片描述
    接下来基于主从(master/slave)模式构建三台机器的集群模式,所以我们需要启动三个节点,所以结构可以抽象为下面的示意图:
    在这里插入图片描述

    • 图中所表示的Node A即 cluster 节点,不进行消息的持久化,即将生产者的消息同步过来,然后发送给消费者消费。

    • 图中Node B即表示 master 节点,进行消息的生产并持久化到文件系统中,并将消息同步到 Node A(Cluster)节点。

    • 图中Node C即表示 slave 节点,属于备用节点,等待 master 释放锁,当 master 释放锁后取代Node B 称为 master节点。

    集群中的角色分配如下:
    在这里插入图片描述

    • ATTENTION :master节点跟slave节点都共用一个文件系统,并且跟cluster节点可以相互通信。

    由于采用docker来搭建activemq集群,问题是:当知道每个ActiveMQ在docker眼里就是一个运行着的容器,那么容器的文件系统跟节点访问都需要修改其配置文件,可是配置文件在容器内部,这个问题有几个解决方案:

    1. docker commit 该命令相当于在容器上追加一层(docker每个容器都是以层来区分的)
    2. dockerfile 定制镜像,就是在原有基础镜像上添加一条条指令,相当于给每一层进行配置
    3. docker cp 命令修改(覆盖)容器中的配置文件(不推荐)
    4. 启动时进行文件映射,这也是我使用的方法,比较简单,更好的方法是使用定制镜像,不过出于测试目的也可以更加了解其内容。
      这次的配置使用 docker cp 从容器内部复制配置文件到本地文件系统(官方给出的配置文件地址是在/opt/activemq/conf/activemq.xml),有兴趣的话可以试一下其他的方式。

    配置master和slave

    首先,将启动的容器中的配置文件拷贝到本地:

    1. 先进入容器找到位置,然后使用docker cp 进行拷贝:
      在这里插入图片描述

    配置文件的复制操作如下:

    #复制master
    docker cp 40b834433b0f:/opt/apache-activemq-5.13.3/conf/activemq.xml activemqConfig/activemq-master-node.xml
    #复制slave
    docker cp 40b834433b0f:/opt/apache-activemq-5.13.3/conf/activemq.xml activemqConfig/activemq-slave1-node.xml
    

    之后修改上述cluster、master和slave文件,修改后的配置在启动的时候使用,由于activeMQ支持多种协议,这里使用TCP协议进行搭建,其他的协议方式可以去掉:

    cluster节点配置

    <!-- 这里是默认的端口配置,我们都需要,只留下一个61616端口即可,由于是测试所以节点机只要端口不一致即可 -->
         <transportConnectors>
                <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
                <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
               <!-- <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> -->
            </transportConnectors>
    
          <!-- 配置网络代理,cluster 节点需要与 master 跟 slave 进行穿透 duplex参数用来消息同步,
          即 master 节点生产出消息,会变成一个 sender 把消息 cluster,同理,cluster 接收到消息也会发送给 master,称为互相穿透。-->
            <networkConnectors>
                    <networkConnector uri="static:(tcp://192.168.1.106:61617,tcp://192.168.1.106:61618)" duplex="true" />
            </networkConnectors>
    

    master 节点配置

            <transportConnectors>
                <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
               <transportConnector name="openwire" uri="tcp://0.0.0.0:61617?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600" />
               <!-- <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> -->
            </transportConnectors>
    
            <networkConnectors>
                    <networkConnector uri="static:(tcp:192.168.1.106:61616)" duplex="true" />
            </networkConnectors>
    

    slave节点配置

    		<transportConnector name="openwire" uri="tcp://0.0.0.0:61618?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <!-- <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> -->
        	</transportConnectors>
    
            <networkConnectors>
                    <networkConnector uri="static:(tcp://192.168.1.106:61616)" duplex="true" />
            </networkConnectors>
    

    可选项目

    这里我们使用的docker容器,并使用文件映射的方式来指定,所以这一步骤我们可以忽略,不过cluster中需要将这项配置进行注释,因为cluster是不作为生产者来使用的,当然如果我们生产消息时不调用该节点,这项配置也是可以省略的(理论上来说可行)。
    然后我们需要要在本地文件中创建一个目录用来进行持久化(正确的做法是使用网络文件系统,我正在学习),这一步我就省略了。接着就是启动我们的容器,slave节点是要晚于master节点的,其他两个顺序无关紧要。

    master、cluster和slave节点容器启动

    启动master

    docker run -it -d -p 61617:61616 -p 8171:8161 -v /root/activemqConfig/activemq-master-node.xml:/opt/apache-activemq-5.13.3/conf/activemq.xml -v /usr/share/activemq/kahadb:/opt/apache-activemq-5.13.3/data/kahadb registry.aliyuncs.com/daydayup/activemq
    

    启动cluster

    docker run -it -d -p 61616:61616 -p 8161:8161 -v /root/activemqConfig/activemq-cluster-node.xml:/opt/apache-activemq-5.13.3/conf/activemq.xml registry.aliyuncs.com/daydayup/activemq
    

    启动slave

    docker run -it -d -p 61618:61616 -p 8181:8161 -v /root/activemqConfig/activemq-slave-node.xml:/opt/apache-activemq-5.13.3/conf/activemq.xml -v /usr/share/activemq/kahadb:/opt/apache-activemq-5.13.3/data/kahadb registry.aliyuncs.com/daydayup/activemq
    

    可以看到启动成功了:
    在这里插入图片描述
    看下监听的端口:
    在这里插入图片描述
    如果是远程登陆的话,还需要开发端口,需要操作阿里云实例的安全组策略,暴露需要的端口,这样再去远程链接测试下,可以看到三个端口都对外开放了,我们在使用浏览器访问管理器试试效果:
    在这里插入图片描述
    可以看到可以通过远程访问我们的activeMQ了。

    参考博客:

    基于Docker搭建ActiveMQ的高可用集群

    展开全文
  • Rabbit MQ环境搭建

    2020-08-21 15:00:18
    它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。 装RabbitMQ服务器必须首先安装 Erlang 运行环境。 安装Erlang 安装Erlang 时要注意...

    RabbitMQ是一个在AMQP协议标准基础上完整的,可复用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。

    装RabbitMQ服务器必须首先安装 Erlang 运行环境。

    安装Erlang

    安装Erlang 时要注意安装的RabbityMQ 所依赖的Erlang版本,根据RabbitMQ的要求选择一个版本,这里我要安装的RabbitMQ的版本是 3.7.7 ,他依赖的Erlang版本范围是

    **19.3.6.4 到 21.0.x,**因此我选择版本是OTP 20.3. Erlang下载地址。下载Erlang安装包后直接安装就可以了。

    设置ERLANG_HOME 环境变量
    在这里插入图片描述

    我这里是默认安装所以Erlang的安装路径在:

    C:\Program Files\erl9.3\bin\erl.exe

    点击确定在系统环境变量里就增加刚刚添加的ERLANG_HOME
    在这里插入图片描述
    注意:如果之前安装了Erlang的其他版本,需要卸载后在进行重新安装和设置。

    在开始菜单查找Erlang,点击启动 打开如下界面,那么Erlang就安装成功了。接下来就安装RabbitMQ。
    在这里插入图片描述

    安装RabbitMQ

    可以在RabbitMQ的官方网站下载最新版本的RabbitMQ服务器安装程序,RabbitMQ下载地址, 这里我下载的是官方推荐的最新版本rabbitmq-server-3.7.7.exe, 然后点击默认安装。

    RabbitMQ安装好后是作为windows service 运行在后台。
    在这里插入图片描述
    设置RabbitMQ环境变量
    RabbitMQ 安装好后在开始菜单输入rabbitmq 会看到三个菜单:
    在这里插入图片描述
    这里的三个菜单是提供控制Windows service的命令,为了能够在任意Windows命令窗口上操控RabbitMQ服务需要在系统里加一个环境变量并且配置在系统的PHTH环境变量中。
    首先添加一个RABBITQM_SERVER变量:
    在这里插入图片描述
    然后在系统的path变量中配置如下:在这里插入图片描述
    这样就可以在windows administrator启动的CMD窗口操控RabbitMQ服务了。不需要每次都定位到:
    C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.7\sbin>
    安装 rabbitmq_management
    我们用命令查看一下RabbtitMQ的所有插件:
    C:\WINDOWS\system32>rabbitmq-plugins list
    看到RabbtitMQ 罗列出来了很多插件
    在这里插入图片描述
    我们用下列命令安装rabbitmq_management插件,这款插件是可以可视化的方式查看RabbitMQ 服务器实例的状态,以及操控RabbitMQ服务器。
    C:\WINDOWS\system32>rabbitmq-plugins enable rabbitmq_management
    运行完命令后,看到下图表示安装成功了。
    在这里插入图片描述
    现在我们在浏览器中输入:http://localhost:15672 可以看到一个登录界面:
    在这里插入图片描述

    这里可以使用默认账号guest/guest登录后的界面如下:
    在这里插入图片描述
    在浏览器中输入 http://localhost:15672/api/ 就可以看到 RabbitMQ Management HTTP API 文档,如下图:
    在这里插入图片描述

    这样就可以查看RabbitMQ server实例状态的相关信息了。

    管理rabbitmq_management的用户

    用命令rabbitmqctl list_users 查看一下现rabbitmq_management注册用户
    在这里插入图片描述

    发现现在只有一个用户guest,并且它的tag是administrator.
    那么在命令行下创建一个用户,创建用户的命令合是:
    rabbitmqctl add_user [username] [password]
    现在创建一个username=rabbit1 password=rabbit1的用户, 命令如下:
    rabbitmqctl add_user rabbit1 rabbit1
    创建成功了:
    在这里插入图片描述
    现在看下有多少用户,跑一下命令:
    rabbitmqctl list_users
    在这里插入图片描述
    发现用户列表里多了一个用户 rabbit1,但是tag是空的。使用命令给rabbit设置tag,设置tag的命令格式:
    rabbitmqctl set_user_tag [tag1] [tag2] …
    一次可以给一个用户设置多个tag,也可以设置一个
    在这里插入图片描述
    有5个tag可供选择,分别是:administrator ,monitoring,policymaker,management和none 有兴趣的同学可以到这里了解各个tag的含义,其实这里的tag代表的是权限,administrator是最高权限,none表示不能访问,这里administrator和none的组合,权限应该是向高看齐,忽略none,用的是administrator的权限。我们用rabbit1/rabbit1 登录rabbitmq_management。
    在这里插入图片描述
    其实有了rabbitmq_management这个可视化插件,很多事情都可以在这个插件里干,包括创建用户,创建交换机(Exchange)和创建队列(Queque)。

    关于Rabbit的在windows下的基本配置就告一段落,关于更多的更高级的配置,可以参考官网,有了rabbitmq_management 插件确实方便了不少。下面就开始创建客户端进行测试了。

    测试

    创建两个.Net Core Console 类型的应用程序,一个用于发送消息,一个用于接收消息。
    1. Send 端代码:

    using System; 
    using System.Text; 
    using RabbitMQ.Client; 
    namespace Q.Demo.Send 
    {    
        class Program    
        {        
            static void Main(string[] args)        
            {            
                var factory = new ConnectionFactory() { HostName = "localhost" };
                using (var connection = factory.CreateConnection())
                    using (var channel = connection.CreateModel())
                {                
                    channel.QueueDeclare(queue: "hello",durable: false,exclusive: false,autoDelete: false,arguments: null);
                    while (true)
                    {                    
                        var input = Console.ReadLine();
                        string message = input;
                        var body = Encoding.UTF8.GetBytes(message);
                        channel.BasicPublish(exchange: "",routingKey: "hello",basicProperties: null,body: body);
                        Console.WriteLine(" [x] Sent {0}", message);
                    }
                }
                Console.WriteLine(" Press [enter] to exit.");
                Console.ReadLine();
            }
        }
    }
    

    2.Receive端代码:

    using System;
    using System.Text;
    using RabbitMQ.Client;
    using RabbitMQ.Client.Events;
    namespace Q.Demo.Receive
    {
        class Program
        {
            static void Main(string[] args)
            {
                var factory = new ConnectionFactory() { HostName = "localhost" };
                using (var connection = factory.CreateConnection())
                    using (var channel = connection.CreateModel())
                {
                    channel.QueueDeclare(queue: "hello",
                                         durable: false,
                                         exclusive: false,
                                         autoDelete: false,
                                         arguments: null);
                    var consumer = new EventingBasicConsumer(channel);
                    consumer.Received += (model, ea) =>
                    {
                        var body = ea.Body; 
                        var message = Encoding.UTF8.GetString(body);
                        Console.WriteLine(" [x] Received {0}", message);
                    };
                    channel.BasicConsume(queue: "hello",
                                         autoAck: true,
                                         consumer: consumer);
                    Console.WriteLine(" Press [enter] to exit."); 
                    Console.ReadLine();
                } 
            } 
        } 
    }
    

    运行输入消息效果如下:
    在这里插入图片描述
    总结:

    关于RabbitMQ在windows 下的安装和基本设置步骤:

    1.安装对应版本的Erlang 并设置环境变量

    2.安装RabbitMQ

    3.设置环境变量

    4.安装插件rabbitmq_management

    5.有了插件rabbitmq_management很多事情就可以在这个可视化插件中来完成了。

    展开全文
  • mq服务,服务端建立隧道命令,并查看隧道是否通畅,查看命令。mq命令基本命令整理,运维mq服务所需要命令集合。
  • 该资源提供了新服务器搭建集群所需要的源文件及其监控消息队列创建情况的可视化控制台jar包,便于对消息队列进行管理查看
  • 赋权 通过端口15672登录进后台之后,选择“admin”菜单,然后选择创建的“admin”用户,进去单击“Set permission”即可 五、如果同一台服务器上存在了activemq,需要改端口 1.在rabbitmq的etc下创建文件 vim ...
  • mq性能 内容精选换一换Kafka采用拉取(Pull)方式消费消息,吞吐量相对更高,适用于海量数据收集与传递场景,例如日志采集和集中分析。RabbitMQ在吞吐量方面略有逊色,但支持更多的消息队列功能。以下从性能、数据可靠...
  • 浅谈MQ集群搭建关系

    2019-06-27 15:56:18
    设备:22.188.xxx.60/61 MQ结构:一台网关队列管理器(GW),两台目标队列管理器(完全存储仓库-GW1/GW2) ...4.定义接受通道TO_GW(用作当其他MQ服务器像其发送数据时,使用的发送通道应当与该...
  • MQ 服务器错误代码2035

    2019-09-25 21:42:43
    搭建一个MQ7.1服务器,用了一个小的demo测试程序,结果报错, 测试代码: import com.ibm.mq.MQC; import com.ibm.mq.MQEnvironment; import com.ibm.mq.MQException; import com.ibm.mq.MQQueueMana...
  • 场景:项目开发中使用的mq中间件一直不太熟悉,遇到问题就需要问人,公司的同事也不怎么爱搭理,弄的好受伤!不熟悉的时候只是感觉好难,逼的没办法,好好研究下,发现里面的过程也没想象中的难, 经过一番研究,...
  • Linux 服务器环境搭建及配置

    万次阅读 2019-12-12 16:24:27
    环境搭建(源码) 1、配置 JDK 1.8 运行环境 (1)、新建文件夹。 mkdir /opt/java (2)、进入安装 jdk 的位置。 cd /opt/java/ (3)、利用 WinSCP 工具,将下载的压缩包上传到目录下。 (4)、然后进行解压命令,...
  • websphere和db2和IBM MQ搭建过程

    千次阅读 2013-12-25 14:11:10
    最近几天去银行做了一个POC,他们用的是websphere,db2和IBM MQ的。安装过程如下: websphere: 1、gzip -d was.cd.6100.trail.base.linux.ia32.tar.gz 2、tar -xvf was.cd.6100.trail.base.linux.ia32.tar ...
  • RabbitMQ消息队列+spring监听mq服务器多个ip,接收消费mq消息(三) https://blog.csdn.net/zhanglf02/article/details/77584012 背景:上个月写过一个客户端监听mq。用的是配置方式,这个配置用了...
  • SVN服务器搭建

    2018-08-02 10:59:47
    1、下载SVN安装包 服务端:http://subversion.apache.org/packages.html#windows     客户端:...3、SVN服务器搭建 3.1 打开VisualSVN Server Manager 3.2 创建自定义仓库 ...
  • mqtt的服务器搭建

    2020-10-02 20:54:06
    windows服务器搭建步骤 (1)下载服务器(windows采用的是apollo) 百度许多资源已经找不到了,以前都是去阿帕奇官网activemq下找,如今找不到了 我这里搞到了一个旧版的1.7.1的可以使用。 (2) 新建一个目录用于放...
  • 局域网GIt服务器搭建

    千次阅读 2019-02-28 15:43:03
    局域网Git服务器搭建 环境 服务器 Ubnutu16.4 + git (version 2.7.4) 客户端 windows10 + git 安装Git 服务器端 #安装git #sudo apt-install git-core #查看git版本 #git --version 客户端 下载GIt...
  • RabbitMq系列(一):服务器搭建 目录 前言 构建服务器 添加用户 前言 这里开始RabbitMq系列,整个系列会从官网提供的例子一步步深入......RabbitMq服务器搭建可以采用安装包搭建、docker镜像和Kubernetes等等...
  • ACS服务器搭建步骤

    2017-08-23 11:53:00
    ACS 服务器搭建方法 简介 由于将要用到的openacs和jboss都是用java语言所编写,所以配置前我们需要一些必须的环境配置 安装环境 linux系统,(version:centos6.8) jdk(version:1.8) jboss(version:-4.2.0.GA) ...
  • 常见MQTT服务器搭建

    千次阅读 2020-05-07 12:00:33
    简介 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,它比较适合于在低...本文就社区上常见的开源MQTT服务器在常见操作系统上的搭建做详细介绍。目前一些开源MQTT服...
  • MQ整理—安装搭建

    2017-08-24 18:44:00
    上篇对mq进行了简单的了解,本篇则了解一下mq搭建过程.集群搭建类型分为好多种,多master模式;多master多slave模式。本篇我们则针对多master模式进行搭建: 一、操作etc\hosts(hosts添加信息) 我搭建mq是...
  • MQTT服务器搭建 windows

    2021-06-26 07:49:26
    MQ 遥测传输 (MQTT) 是轻量级基于代理的发布/订阅的消息传输协议,设计思想是开放、简单、轻量、易于实现。这些特点使它适用于受限环境。例如,但不仅限于此: 网络代价昂贵,带宽低、不可靠。 在嵌入设备中运行,...
  • MQTT服务器搭建--Mosquitto 1.Mosquitto简介 MQTT(MQ Telemetry Transport),消息队列遥测传输协议,轻量级的发布/订阅协议,适用于一些条件比较苛刻的环境,进行低带宽、不可靠或间歇性的通信。目前已经是...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 11,876
精华内容 4,750
关键字:

mq服务器搭建