摸不到Java的顶峰,咱就转战大数据,绝不在一棵树上吊死

2023-10-15 01:59

本文主要是介绍摸不到Java的顶峰,咱就转战大数据,绝不在一棵树上吊死,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

这篇文章的目的是带那些对大数据不了解又有兴趣的人入门。如果你是老手可以忽略,或者想看看有没有不一样的东西也行。

我们学习一个新知识,第一步应该是给它个明确的定义。这样才能知道你学的是什么,哪些该学,哪些又可以先不用管。

然而,大数据虽然很火,但其实是个概念没那么清晰的东西,不同的人可能有不同的理解。

这次我们不去纠结具体的定义,也忽略那些 4 个 V、6 个 C 之类传统说教的东西,甚至不想聊架构演进以及各种调优的方法,这些东西讲了大家也不一定懂,懂了也记不住,记住了也用不起来。

我们也不去关注 AI、Machine Learning 那些炫酷的应用层面的东西,而是去看看大数据这栋房子的地基是什么模样。限于篇幅,很多技术细节点到即止,有兴趣的同学可以再按需了解,这也正是入门的含义所在。

首先第一个问题,大数据,大数据,多大叫大?或者换一个角度,什么时候需要用到大数据相关的技术?

这依然是个没有标准答案的问题,有些人可能觉得几十 G 就够大了,也有人觉得几十 T 也还好。当你不知道多大叫大,或者当你不知道该不该用大数据技术的时候,通常你就还不需要它。

而当你的数据多到单机或者几台机器存不下,即使存得下也不好管理和使用的时候;当你发现用传统的编程方式,哪怕多进程多线程协程全用上,数据处理速度依然很不理想的时候;当你碰到其他由于数据量太大导致的实际问题的时候,可能你需要考虑下是不是该尝试下大数据相关的技术。

从刚才的例子很容易能抽象出大数据的两类典型应用场景:

  • 大量数据的存储,解决装不下的问题。
  • 大量数据的计算,解决算得慢的问题。

因此,大数据的地基也就由存储和计算两部分组成。

我们在单机,或者说数据量没那么大的时候,对于存储有两种需求:

  • 文件形式的存储
  • 数据库形式的存储

文件形式的存储是最基本的需求,比如各个服务产生的日志、爬虫爬来的数据、图片音频等多媒体文件等等。对应的是最原始的数据。

数据库形式的存储则通常是处理之后可以直接供业务程序化使用的数据,比如从访问日志文件里处理得到访问者 ip、ua 等信息保存到关系数据库,这样就能直接由一个 web 程序展示在页面上。对应的是处理后方便使用的数据。

大数据也只是数据量大而已,这两种需求也一样。虽然不一定严谨,但前者我们可以叫做离线(offline)存储,后者可以叫做在线(online)存储。

离线存储这块 HDFS(Hadoop Distributed File System) 基本上是事实上的标准。从名字可以看出,这是个分布式的文件系统。实际上,「分布式」也是解决大数据问题的通用方法,只有支持无限横向扩展的分布式系统才能在理论上有解决无限增长的数据量带来的问题的可能性。当然这里的无限要打个引号。

 

这是 HDFS 的简易架构图,看起来仍然不太直观,其实要点只有几句话:

  • 文件被以 block 为单位拆分后存放在不同的服务器上,每个 block 都在不同机器上做了多份冗余。
  • 有 NameNode 和 DataNode 两种角色,前者存放元数据也就是每个 block 保存在哪里,后者负责存放实际数据。
  • 读和写数据都要先向 NameNode 拿到对应文件的元数据,然后再找对应的 DataNode 拿实际的数据。

可以看到,HDFS 通过集中记录元数据的方式实现了分布式的效果,数据量增长只需要添加一些新的 DataNode 就可以了,单机容量不再是限制。

而为了保证数据的高可用,比如某台服务器突然坏了再也起不来了,HDFS 通过冗余的方式(通常是 3 副本)来解决这个问题。这也是分布式系统里最常用的高可用方式,虽然成本可能很高。

系统级别的高可用才有意义,所以除了数据的高可用,元数据的高可用也至关重要。思路一样 -- 备份。HDFS 提供了 Secondary NameNode 来提供元数据的冗余。当然更好的方式是使用 NameNode HA 的方式,通过 active/standby 一组 NameNode 来保证不间断的元数据读写服务。

同样,扩展性刚才也只考虑到数据的横向扩展,元数据呢?当数据量大到一定程度,元数据也会非常大,类似我们在传统关系数据库里碰到的索引膨胀的问题。解决的思路是 NameNode Federation。简单讲就是把原来的一组 active/standy NameNode 拆分成多组,每组只管理一部分元数据。拆分后以类似我们在 Linux 系统里挂载(mount)硬盘的方法对外作为整体提供服务。这些 NameNode 组之间相互独立,2.x 版本的 HDFS 通过 ViewFS 这个抽象在客户端通过配置的方式实现对多组 NameNode 的透明访问,3.x 版本的 HDFS 则实现了全新的 Router Federation 来在服务端保证对多组 NameNode 的透明访问。

可以看到,元数据的横向扩展和实际数据的横向扩展思路完全一样,都是拆分然后做成分布式。

和离线存储对应的是在线存储,可以参照传统的 MySQL、Oracle 等数据库来理解。在大数据领域最常用的是 H

这篇关于摸不到Java的顶峰,咱就转战大数据,绝不在一棵树上吊死的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/214628

相关文章

Spring Security重写AuthenticationManager实现账号密码登录或者手机号码登录

《SpringSecurity重写AuthenticationManager实现账号密码登录或者手机号码登录》本文主要介绍了SpringSecurity重写AuthenticationManage... 目录一、创建自定义认证提供者CustomAuthenticationProvider二、创建认证业务Us

Java Stream流以及常用方法操作实例

《JavaStream流以及常用方法操作实例》Stream是对Java中集合的一种增强方式,使用它可以将集合的处理过程变得更加简洁、高效和易读,:本文主要介绍JavaStream流以及常用方法... 目录一、Stream流是什么?二、stream的操作2.1、stream流创建2.2、stream的使用2.

MySQL数据脱敏的实现方法

《MySQL数据脱敏的实现方法》本文主要介绍了MySQL数据脱敏的实现方法,包括字符替换、加密等方法,通过工具类和数据库服务整合,确保敏感信息在查询结果中被掩码处理,感兴趣的可以了解一下... 目录一. 数据脱敏的方法二. 字符替换脱敏1. 创建数据脱敏工具类三. 整合到数据库操作1. 创建服务类进行数据库

Java对接MQTT协议的完整实现示例代码

《Java对接MQTT协议的完整实现示例代码》MQTT是一个基于客户端-服务器的消息发布/订阅传输协议,MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛,:本文主要介绍Ja... 目录前言前置依赖1. MQTT配置类代码解析1.1 MQTT客户端工厂1.2 MQTT消息订阅适配器1.

MySQL中处理数据的并发一致性的实现示例

《MySQL中处理数据的并发一致性的实现示例》在MySQL中处理数据的并发一致性是确保多个用户或应用程序同时访问和修改数据库时,不会导致数据冲突、数据丢失或数据不一致,MySQL通过事务和锁机制来管理... 目录一、事务(Transactions)1. 事务控制语句二、锁(Locks)1. 锁类型2. 锁粒

Spring Boot项目如何使用外部application.yml配置文件启动JAR包

《SpringBoot项目如何使用外部application.yml配置文件启动JAR包》文章介绍了SpringBoot项目通过指定外部application.yml配置文件启动JAR包的方法,包括... 目录Spring Boot项目中使用外部application.yml配置文件启动JAR包一、基本原理

SpringBoot加载profile全面解析

《SpringBoot加载profile全面解析》SpringBoot的Profile机制通过多配置文件和注解实现环境隔离,支持开发、测试、生产等不同环境的灵活配置切换,无需修改代码,关键点包括配置文... 目录题目详细答案什么是 Profile配置 Profile使用application-{profil

Java中InputStream重复使用问题的几种解决方案

《Java中InputStream重复使用问题的几种解决方案》在Java开发中,InputStream是用于读取字节流的类,在许多场景下,我们可能需要重复读取InputStream中的数据,这篇文章主... 目录前言1. 使用mark()和reset()方法(适用于支持标记的流)2. 将流内容缓存到字节数组

Java慢查询排查与性能调优完整实战指南

《Java慢查询排查与性能调优完整实战指南》Java调优是一个广泛的话题,它涵盖了代码优化、内存管理、并发处理等多个方面,:本文主要介绍Java慢查询排查与性能调优的相关资料,文中通过代码介绍的非... 目录1. 事故全景:从告警到定位1.1 事故时间线1.2 关键指标异常1.3 排查工具链2. 深度剖析:

Springboot项目登录校验功能实现

《Springboot项目登录校验功能实现》本文介绍了Web登录校验的重要性,对比了Cookie、Session和JWT三种会话技术,分析其优缺点,并讲解了过滤器与拦截器的统一拦截方案,推荐使用JWT... 目录引言一、登录校验的基本概念二、HTTP协议的无状态性三、会话跟android踪技术1. Cook