一.metaq单机部署
1.安装jdk1.7
2.解压zookeeper到/usr/tools目录
3.将zookeeper-3.4.3/conf目录下的zoo_sample.cfg文件拷贝一份,命名为为“zoo.cfg”
4.修改zoo.cfg,将dataDir配置改为/usr/tools/zookeeper-3.4.3/data,将dataLogDir配置改为/usr/tools/zookeeper-3.4.3/dataLog,将server.1配置改为本机ip加默认端口号
5.创建/usr/tools/zookeeper-3.4.3/data目录,创建myid文件,编辑文件内容为1
6.启动zookeeper
7.进入bin目录,查看zookeeper.out日志是否有异常
9.解压metaq到/usr/tools目录
10.将metaq/conf目录下的sample.server.ini文件拷贝一份,命名为为“server.ini”
11.修改server.ini,修改dataPath为/usr/tools/metaq/data,并根据实际应用配置端口号等其他基本配置,配置zookeeper为当前机器ip
12.添加以下topic配置[topic=order-event]
13.启动metaq
14.启动成功后,通过浏览器访问dashboard,查看是否启动成功(注意防火墙设置)
15.添加开机启动项:在/etc/rc.d/rc.local下添加如下代码
bash /usr/zookeeper-3.4.5/bin/zkServer.sh start
bash /usr/metamorphosis-server-wrapper/bin/metaServer.sh start
16.部署完成
二.集群部署
4.初步打算将zookeeper部署在三台服务器A,B,C,metaq部署在四台服务器,2主2备
三.注意事项
1.注意集群中的防火墙设置,确认不同端口是否可以相互通信
2.需要为每台机器开放一个端口作为192.168.99网段访问metaq的dashboard使用
3.遇到kill不掉的进程,可以使用kill -9 pid命令。可以杀掉绝大部分进程,但是进入内核态运行的进程会屏蔽所有信号,包括SIGKIL,所以杀不掉。
分享到:
相关推荐
3. 分布式:MetaQ采用分布式集群部署,可以动态扩展节点以应对不断增长的业务量,具备良好的水平扩展能力。 4. 消息持久化:支持消息持久化到磁盘,即使服务器重启,也不会丢失未消费的消息,确保数据安全。 5. ...
- **解决方案:** 利用多线程技术、异步处理机制以及分布式部署方案,提升系统的并发处理能力。 **3. 顺序消息处理** - **解决方案:** 采用特定的消息发送策略和消息队列管理方式,保证消息的顺序性。 **4. ...
- **部署**:Metaq环境通常预装在日常环境中,若需自建,可参考服务器部署指南。 - **角色**:消息中间件的角色分为消息生产者和消息消费者。生产者创建并发送消息至Metaq服务器,服务器负责消息的持久化,消费者...
- 高可用与负载均衡:通过多台机器部署 Broker 和 Controller 实现高可用,消息可以在集群中自动进行负载均衡。 6. **监控与维护**: - 日志分析:监控日志可以帮助排查问题,优化系统性能。 - 性能调优:根据...
RocketMQ是一个由阿里巴巴开源的消息中间件,脱胎自阿里巴巴的MetaQ,在设计上借鉴了Kafka。下面将详细介绍Window搭建部署RocketMQ的步骤。 一、安装RocketMQ 首先需要下载RocketMQ的发行版本,解压缩后得到bin、...
RocketMQ 的前世今生是 Metaq,Metaq 在阿里巴巴集团内部、蚂蚁金服、菜鸟等各业务中被广泛使用,接入了上万个应用系统中。 RocketMQ 的使用场景包括应用解耦、流量削峰等。应用解耦系统的耦合性越高,容错性就越低...
- 缓存模块:包含Metaq和Kafka,用于临时存储和快速传递数据。 - 实时计算模块:支持Spark和Storm两种实时计算框架,以适应不同业务需求。 - Store层:将处理后的数据存储到HIVE、Hbase等系统中,供后续分析使用。 -...
7. **MetaQ与RocketMQ关系**:MetaQ 在 3.0 版本之后更名为 RocketMQ。 8. **JMS支持**:RocketMQ 支持 JMS 客户端 API,用户可以通过官方提供的 rocketmq-jmsclient 进行开发。 9. **启动异常**:如果启动 Broker...
物理部署中可能包括消息服务器(Broker)、NameServer、生产者和消费者等。 3. RocketMQ逻辑部署结构 逻辑部署结构是指消息系统的软件架构和组件间的交互。包括生产者、消费者、Broker服务器、NameServer和消息...
JStorm的架构设计包括TLog、Kepler、NUT、ARM、RDS等模块,以及通过Portal(Koala)实现的SQL引擎和插件系统,支持Kafka、Metaq、TT、Mysql、HDFS、Hbase等多种数据源。其核心组件包括本地集群、独立模式、YARN和...
MQ在专有云部署方面也表现出灵活性,提供技术方案设计、现场支持与培训,支持独立部署和混合云架构。运维管控工具如MaAdmin命令集和Open API便于集成和统一运维。 MQ的优势体现在: 1. **专业性**:作为业界专业...
- **2012年**:为了适应更加复杂的业务场景,阿里巴巴发布了AliwareMQ v1.0,支持公有云、金融云、私有云等多种部署方式,并提供了更强的数据安全性保障。 - **2015年**:RocketMQ正式开源,标志着阿里巴巴在消息...
Zookeeper已成为Hadoop生态系统中的基础组件,适用于HDFS、YARN、Storm、HBase、Flume、Dubbo(阿里巴巴)、metaq(阿里巴巴)等系统。 Zookeeper的特点包括: 1. 最终一致性:Zookeeper为客户端展示同一视图,确保...
阿里巴巴作为拥有庞大微服务架构的企业,其电商业务涉及众多子品牌如天猫、淘宝等,依赖Dubbo RPC进行服务间的通信,MetaQ则用于异步解耦。然而,这种架构存在服务可见性无隔离、接口级服务发现等问题,以及Java技术...
6. **Plugin**:支持多种插件,如Kafka、Metaq、TT、Mysql等,扩展了JStorm的功能。 7. **CEP Plugin**:复杂事件处理插件,用于处理和识别特定的事件模式。 8. **Trident**:提供精确一次的消息处理语义。 9. **...
6. **MetaQ**:阿里巴巴开源的一款消息中间件,支持大规模的集群部署和消息分发。 7. **RabbitMQ**:一个健壮、易用的开源消息代理和队列服务器,支持多种消息协议。 #### 五、MQ选型考虑因素 选择合适的消息...
例如,MTEE服务用于决策服务,PMML用于模型计算,Tair和Hbase处理在线和离线指标,ODPS用于模型训练,Drools执行规则计算,Quartz进行监控预警,日志系统如MetaQ+Galaxy记录操作。 二、场景应用举例 1. 解决小微...
- **RocketMQ**的前身是MetaQ,最初可以看作是LinkedIn的Kafka(Scala版)的一个Java版本,并在此基础上增加了事务支持。 - **RocketMQ**相对于原生Kafka的特点在于除了基本的日志收集功能外,还支持高可用(HA)、...
2. **Broker**:消息的实际存储单元,可以组成Broker Group来支持集群部署。 3. **Producer**:消息生产者,负责向Broker发送消息。 4. **Consumer**:消息消费者,负责从Broker拉取消息或接收消息推送。 RocketMQ...
1. **RocketMQ简介**:RocketMQ是由阿里巴巴开源的一款高可用、高性能的消息中间件,它最初是基于Metaq发展而来,经过不断的优化和迭代,现已成为Apache顶级项目。RocketMQ的设计目标是提供低延迟、高吞吐量以及强大...