分布式消息系统Jafka入门指南之二

分布式消息系统Jafka入门指南之二

作者:chszs,转载需注明。博客主页:http://blog.csdn.net/chszs

三、Jafka的文件夹结构

1、安装tree命令

$ sudo yum install tree

2、查看文件夹

$ tree -L 1
.
?..?

? bin
?

..?? conf
?..?? data
?

..?? lib
?

..?? LICENSE
?..?

?

logs
?..?? VERSION


说明:
bin文件夹:命令行脚本
conf文件夹:存放配置文件
data文件夹:消息的topic数据
lib文件夹:java执行依赖库
logs文件夹:存放log4j日志输出
VERSION文件:版本号文件
LICENSE文件:许可证文件

四、环境变量及执行

最好是配置JAFKA_HOME环境变量。

在Linux系统下。run.sh脚本说明
使用方法:./run.sh [ console | start | stop | restart | condrestart | status | install | remove | dump ]
命令參数:
console:执行于当前的控制台
start:以守护进程执行在后台
stop:假设正在以守护进程或其他控制台执行,那么停止它
restart:假设正在执行。那么停止它,再重新启动它
condrestart:假设正在执行。那么重新启动它
status:查询当前状态
install:设置为server开机自启动服务
remove:移除服务
dump:假设正在执行,请求Java线程堆

在Windows系统下,执行jafka.exe命令来启动服务。
基本的命令说明
jafka -?    查看帮助
jafka -i jafka.conf    安装为Windows自启动服务
jafka -t    执行服务
jafka -p    停止服务

五、设置Maven依赖

<dependency>
  <groupId>com.sohu.jafka</groupId>
  <artifactId>jafka</artifactId>
  <version>1.2.3</version>
</dependency>

六、Jafka的依赖包
1、JSON库jackson
2、Java命令行解析库jopt simple
3、日志库log4j和slf4j
4、Kafka监控mx4j-tool
5、zookeeper的Java客户端zkclient
6、大型分布式可靠协调库zookeeper

要说明一点,在查看Jafka的源代码文件时,发现了包命名中含有sohu。预计Jafka是sohu开源的项目。

时间: 2024-10-07 10:55:58

分布式消息系统Jafka入门指南之二的相关文章

分布式消息系统Jafka入门指南

分布式消息系统Jafka入门指南 作者:chszs,转载需注明.博客主页:http://blog.csdn.net/chszs 一.JafkaMQ简介 JafkaMQ是一个分布式的发布/订阅消息系统,它是Apache Kafka的Java移植版. 2013年11月28日,JafkaMQ发布了1.2.3版. JafkaMQ的特征如下: 1)消息持久化到磁盘的算法时间复杂度为O(1),即使是TB级的消息存储,也能保证常量时间的执行性能.2)高吞吐量:即使是低配制的硬件条件,单个Broker也能支持每

分布式消息系统jafka快速起步(转)

Jafka 是一个开源的/性能良好的分布式消息系统.在上一篇文章中有所简单介绍.下面是一篇简单的入门文档.更多详细的文档参考wiki. Step 1: 下载最新的安装包 完整的安装指南在这里.最新的发行版地址在:https://github.com/adyliu/jafka/downloads $wget https://github.com/downloads/adyliu/jafka/jafka-1.0.tgz $tar xzf jafka-1.0.tgz $cd jafka-1.0 可选配

分布式消息系统的现状、挑战与未来

本文整理自冯嘉在开发者生态峰会的分享,通过此文,希望帮助大家了解: 对于分布式消息系统,传统的消息系统以及Messaging生态面临的挑战: 结合阿里巴巴自身的开源实践,提供如何应对以上挑战的参考答案: OpenMessaging生态现状和未来的发展方向. 冯嘉:Apache RocketMQ 创始人,Linux OpenMessaging 创始人,阿里巴巴 Messaging 技术负责人. 消息系统的业界挑战 第一,开源软件给传统闭源软件带来的冲击.早期的消息系统是闭源的,但随着开源生态的发展

转 猫都能学会的Unity3D Shader入门指南(二)

猫都能学会的Unity3D Shader入门指南(二) 关于本系列 这是Unity3D Shader入门指南系列的第二篇,本系列面向的对象是新接触Shader开发的Unity3D使用者,因为我本身自己也是Shader初学者,因此可能会存在错误或者疏漏,如果您在Shader开发上有所心得,很欢迎并恳请您指出文中纰漏,我会尽快改正.在之前的开篇中介绍了一些Shader的基本知识,包括ShaderLab的基本结构和语法,以及简单逐句地讲解了一个基本的shader.在具有这些基础知识后,阅读简单的sha

Asp.Net MVC4.0 官方教程 入门指南之二--添加一个控制器

Asp.Net MVC4.0 官方教程 入门指南之二--添加一个控制器 MVC概念 MVC的含义是 “模型-视图-控制器”.MVC是一个架构良好并且易于测试和易于维护的开发模式.基于MVC模式的应用程序包含: · Models: 表示该应用程序的数据并使用验证逻辑来强制实施业务规则的数据类. · Views: 应用程序动态生成 HTML所使用的模板文件. · Controllers: 处理浏览器的请求,取得数据模型,然后指定要响应浏览器请求的视图模板. 本系列教程,我们将覆盖所有这些概念,并告诉

Maven入门指南(二)

转载自并发编程网 – ifeve.com本文链接地址: Maven入门指南(二) Maven目录结构 Maven有一个标准的目录结构.如果你在项目中遵循Maven的目录结构,就无需在pom文件中指定源代码.测试代码等目录. Maven的目录结构布局,参考Maven标准目录结构介绍 以下为最重要的目录: - src - main - java - resources - webapp - test - java - resources - target src目录是源代码和测试代码的根目录.mai

[kfaka] Apache Kafka:下一代分布式消息系统

简介 Apache Kafka是分布式发布-订阅消息系统.它最初由LinkedIn公司开发,之后成为Apache项目的一部分.Kafka是一种快速.可扩展的.设计内在就是分布式的,分区的和可复制的提交日志服务. Apache Kafka与传统消息系统相比,有以下不同: 它被设计为一个分布式系统,易于向外扩展: 它同时为发布和订阅提供高吞吐量: 它支持多订阅者,当失败时能自动平衡消费者: 它将消息持久化到磁盘,因此可用于批量消费,例如ETL,以及实时应用程序. 本文我将重点介绍Apache Kaf

KAFKA分布式消息系统

KAFKA分布式消息系统 2011-08-28 18:32:46 分类: LINUX Kafka[1]是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录.浏览.点击.分享.喜欢)以及系统运行日志(CPU.内存.磁盘.网络.系统及进程状态). 当前很多的消息队列服务提供可靠交付保证,并默认是即时消费(不适合离线).高可靠交付对linkedin的日志不是必须的,故可通过降低可靠性来提高性能,同时通过构建分布式的集群,

kafka--高性能的分布式消息系统

kafka是一个分布式的,高吞吐量的.信息分片存储,消息同步复制的开源消息服务,它提供了消息系统的功能,但是采用了独特的设计. kafka最初由LinkedIn设计开发,使用Scala语言编写,用作LinkedIn网站的活动流数据和运营数据处理工具,这其中活动流数据是指页面访问量.被查看内容方面的信息以及搜索情况等内容,运营数据是指服务器的性能数据(CPU.IO使用率.请求时间.服务日志等数据). 现在kafka已被多家不同类型的公司采用,作为其内部各种数据的处理工具或消息队列服务.如今kafk