Spring Boot Admin2.1应用监控 Posted on 2018-10-26 | In springboot Spring Boot Admin 是一个管理和监控Spring Boot 应用程序的开源软件。每个应用都认为是一个客户端,通过HTTP或者使用 Eureka注册到admin server中进行展示,Spring Boot Admin UI部分使用AngularJs将数据展示在前端。 Spring ... Read more »
Netty入门(二)TCP粘包与拆包问题处理 Posted on 2018-10-12 | In Netty TCP粘包与拆包是什么?上一章的demo中客户端发送了三条数据服务端收到确是合并在一起的一条数据 这就是是TCP粘包 TCP是一个”流”协议,就像河流中的溪流一样,没有严格的分界线。当我们客户端向服务端发送数据时(比如以下发送了三条数据A,B,C),原本的想法就是三条数据单独发送,服务端接收时也是接 ... Read more »
Netty入门(一)快速入门 Posted on 2018-10-11 | In Netty Netty介绍 Netty是一个NIO client-server(客户端服务器)框架,使用Netty可以快速开发网络应用,例如服务器和客户端协议。Netty提供了一种新的方式来使开发网络应用程序,这种新的方式使得它很容易使用和有很强的扩展性。Netty的内部实现时很复杂的,但是Netty提供了简 ... Read more »
GitHub+hexo搭建个人静态博客 Posted on 2018-09-22 | In 随笔 写博客的好处是我们用博客表达自己、升华自己。 平时学习新知识总是经常性会遗忘部分内容,使用过有道云,印象笔记,公众号,缺金社区,csdn,Github,码云等等记录了零零散散一些内容。所以准备使用hexo做一个归纳 快速开始首选安装好node.js和npm 安装 Heox1$ npm insta ... Read more »
Storm系列(六)storm和kafka集成 Posted on 2018-09-21 | In storm 使用kafka-client jar进行Storm Apache Kafka集成这包括新的Apache Kafka消费者API。兼容性 Apache Kafka版本0.10起引入jar包 12345<dependency> <groupId>org.apache.storm ... Read more »
Storm系列(五)DRPC实现远程调用 Posted on 2018-09-20 | In storm Trident简介 Trident拥有一流的抽象,可以读取和写入有状态的来源。状态可以是拓扑的内部 - 例如,保存在内存中并由HDFS支持 - 或者外部存储在Memcached或Cassandra等数据库中。在任何一种情况下,Trident API都没有区别。 Trident以容错的方式管理状态, ... Read more »
Storm系列(四)并行度和流分组 Posted on 2018-09-19 | In storm 并行度(parallelism)概念 一个运行中的拓扑是由什么构成的:工作进程(worker processes),执行器(executors)和任务(tasks) 在 Worker 中运行的是拓扑的一个子集。一个 worker 进程是从属于某一个特定的拓扑的,在 worker进程中会运行一个或者多 ... Read more »
Storm系列(三)java编写第个storm程序 Posted on 2018-09-18 | In storm 本地模式在本地模式下,Storm拓扑结构运行在本地计算机的单一JVM进程上。这个模式用于开发、测试以及调试,因为这是观察所有组件如何协同工作的最简单方法。在这种模式下,我们可以调整参数,观察我们的拓扑结构如何在不同的Storm配置环境下运行。要在本地模式下运行,我们要下载Storm开发依赖,以便用来 ... Read more »
Storm系列(二)常用shell命令操作 Posted on 2018-09-17 | In storm 常用命令官方文档http://storm.apache.org/releases/1.2.2/Command-line-client.html 查看命令帮助123456789101112131415161718192021222324252627282930313233343536373839[ro ... Read more »
Storm系列(一)环境搭建安装 Posted on 2018-09-12 | In storm 什么是Apache StormApache Storm是一个分布式实时大数据处理系统。Storm设计用于在容错和水平可扩展方法中处理大量数据。它是一个流数据框架,具有最高的摄取率。虽然Storm是无状态的,它通过Apache ZooKeeper管理分布式环境和集群状态。它很简单,您可以并行地对实时数 ... Read more »