最近在开发中遇到一个Protostuff序列化问题，在这记录一下问题的根源；分析一下Protostuff序列化和反序列化原理；以及怎么样避免改bug。
我们有个方法 通过 attrKey 查询 List ,同时方法中有缓存，会优先查询缓存，没有读库，然后 写缓存 返回。
flink-release-1.7.2/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobService.java
package com.fh.util; import java.io.BufferedInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.RandomAccessFile; import j
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/DBServerState.java
主要说下reactor模式：简单来说reactor模式用于同时处理一个或多个传递给服务端的请求的事件的处理模式。 然后，服务端处理程序解析输入别的请求，并将它们同步分派给与之关联的请求异步处理程序。不恰当可类比web页面事件，当点击某个按钮时，浏览器收到这个信号（监听），分派给相关的js处理程序处理（handler）。
1. 为什么是Reactor模式 2. Reactor模式简介 3. 多线程IO的致命缺陷 4. 单线程Reactor模型 4.1. 什么是单线程Reactor呢？ 4.2. 单线程Reactor的参考代码 4.3. 单线程模式的缺点: 5. 多线程的Reactor 5.1. 基于线程池的改进 5.2. 改进后的完整示意图 5.3. 多线程Reactor的参考代码 6. Reactor持续改进 7. Reactor编程的优点和缺点 7.1. 优点 7.2. 缺点
Service层代码中FileService.java展示 import com.demo.fileTree.configuration.GlobalConfig; import com.demo.fileTree.model.FileHandleResponse; import com.demo.fileTree.model.JstreeNode; import com.demo.fileTree.utils.ZipUtils; import org.springframework.beans.facto
flink-release-1.7.2/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobWriter.java
上面的聊天案例无论是服务端还是客户端，都是单线程的，所有的链接及读写都是在一个main方法所在的主线程内运行。
TextInputFormat是Hadoop默认的数据输入格式,但是它只能一行一行的读记录，如果要读取多行怎么办？ 很简单 自己写一个输入格式，然后写一个对应的Recordreader就可以了，但是要实现确不是这么简单的 首先看看TextInputFormat是怎么实现一行一行读取的 大家看一看源码 public class TextInputFormat extends FileInputFormat<LongWritable, Text> { @Override public Record
Spring cloud zuul里面有一些核心过滤器，以前文章大致介绍了下各个过滤器的作用，武林外传—武三通的zuul之惑。这次重点讲解下FormBodyWrapperFilter，先贴出完整源码：
在夜晚，仰望星空的时候，你只能看到星星和月亮。在Stream的世界里，你只能看到无数的0和1组成的二进制数据（byte）。我们在网络中传输的数据，其实都是以一组有序的byte的形式传输的。
java中的IO流可以分为两种：字符流和字节流 字符流，顾名思义，就是对字符进行操作，只能操作文本文件 字节流，就是对字节进行操作，然而所有文件都是由字节组成的，可以字节流可以操作一切文件 字符流中的两个大类：Reader和Writer 详情可见 https://cloud.tencent.com/developer/article/1036410 简单的Writer和Reader 字节流中也同样有两个大类：InputStream和OutputStream 又“读进来，写出去”，所以
在netty数据传输过程中可以有很多选择，比如；字符串、json、xml、java对象，但为了保证传输的数据具备；良好的通用性、方便的操作性和传输的高性能，我们可以选择protobuf作为我们的数据传输格式。
代码已托管到 https://github.com/yangshangwei/commonUtils
本文主要是重新梳理了Java的IO模型，基于之前NIO的文章进行补充，为学习Netty做准备。
org/apache/tomcat/util/net/AbstractEndpoint.java
编写简单的 I / O操作很简单，仅仅涉及到很少的类和方法。 但是编写高效，便携式I / O非常困难，特别是如果我们必须处理不同的字符集。 这就解释了为什么有这么多的I / O包（在JDK 1.7中有9个）！
1、例子1 package soapDemo; import java.io.ByteArrayOutputStream; import java.io.InputStream; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; /** * 翻译TranslatorWebService * https://www.cnblogs.com/garfieldcgf/p/5966317.ht
canal-1.1.4/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/DirectLogFetcher.java
JSON (JavaScript Object Notation) 是一种轻量级的数据交换格式，它可以用来存储和传输结构化的数据。在 Java 中，有多种方法可以将 JSON 文件读取为字符串，本文将介绍其中的几种。
Strings C-style strings have a special feature:The last character of every string is the null character .Consider the following two declarations: char dog[8] = {'b','e','a','u','x',' ','I','I'};// not a string char cat[8] = {'f','a','t','e','s','s','a','\0
此类提供API以从持久性保存/加载/修改网络配置商店。 使用密钥库进行证书/密钥管理操作。 注意：此类只能在WifiConfigManager中使用，并且不是线程安全的！ 一般WifiConfigManager中才会调用WifiConfigStore的方法，比如要加载已保存过的网络时，要迁移保存过的网络数据时，都会调用WifiConfigStore的方法。 WifiConfigManager代码路径： /frameworks/opt/net/wifi/service/java/com/android/server/wifi/WifiConfigManager.java
Jafka Acceptor接受client而建立后的连接请求，Acceptor会将Socket连接交给Processor进行处理。Processor通过下面的处理步骤进行client请求的处理：
jackson-core是三大核心模块之一，并且它是核心中的核心，它提供了对JSON数据的完整支持。 此模块提供了最具底层的Streaming JSON解析器/生成器，这组流式API属于Low-Level API，具有非常显著的特点：
java序列化方案：首先把对象信息写到ObjectOutputStream 中，然后再写到ByteArrayOutputStream 中，最后写到字节数组中；
一.前言 本文是对大数据文本文件读取（按行读取）的优化，目前常规的方案（限于JDK）有三种，第一种LineNumberReader，第二种RandomAccessFile，第三种是内存映射文件（详见http://sgq0085.iteye.com/blog/1318622）在RandomAccessFile基础上调用getChannel().map(...)。 1.LineNumberReader 按行读取，只能从第一行向后遍历，到需要读取的行时开始读入，直到完成；在我的测试用例中，读取1000W行
为什么不直接试用int,string而要采用IntWritable和Text呢？这就涉及到了序列化。 序列化
flink-runtime_2.11-1.7.0-sources.jar!/org/apache/flink/runtime/state/CheckpointStreamFactory.java
在Spring Boot应用程序中，如果您尝试将应用程序打包成一个 JAR 并运行，那么您不能使用File或FileInputStream来直接读取 JAR 内部的文件，因为这些文件不是以传统文件系统的形式存在的。相反，它们被嵌入到了 JAR 文件中，必须通过类加载器来访问。那么您应该始终使用类路径访问方式（ClassLoader.getResourceAsStream或Spring的ResourceLoader），而不是尝试直接访问文件系统路径。
射频识别技术RFID（Radio Frequency Identification），又称为电子标签、无线射频识别，是一种非接触式的自动识别技术，通过无线电讯号识别特定目标并读写相关数据而无需识别系统与特定目标之间建立机械或光学接触。可用于识别高速运动物体并可同时识别多个标签，过程中无需人工干预，操作快捷方便。可工作于各种环境，实现对各类物体或设备（人员、物品）在不同状态（移动、静止或恶劣环境）下的自动识别和管理。
1、字节位移 要穷尽所有的类型进行位移。 package com.guanjian.serialize; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.util.Arrays; /** * Created by Administrator on 2018-05-20. */ public class Test1 {
注意点：1）Thrift客户端和服务端使用的I/O模型必须一致，上例中都是使用阻塞式同步I/O模型。
对于视频/音频软件，音乐软件，视频软件，都有缓存这个功能，那如何实现边下边播功能：
data source. 提供原始数据的原始媒介。常见的：数据库、文件、其他程序、内存、网络连接、IO设备。
1 package DEMO ; 2 3 import java.io.File; 4 import java.io.FileInputStream; 5 import java.io.IOException; 6 import java.io.InputStream; 7 8 9 /* 文件字节输入流 10 * 1.设定输入流的源 11 * 2.创建指定源的输入流 12 * 3.让输入流读取源中的数据 13 * 4.关闭输入流 14 * */
同步客户端比较简单，以RPC-Thrift（一）中的的例子为基础进行研究源码，先看一下类图。
背景： 1,golang自带的json解析库encoding/json提供了json字符串到json对象的相互转换，在json字符串比较简单的情况下还是挺好用的，但是当json字符串比较复杂或者嵌套比较多的时候，就显得力不从心了，不可能用encoding/json那种为每个嵌套字段定义一个struct类型的方式，这时候使用simplejson库能够很方便的解析。
在学习NIO时，ByteBuffer、Channel、Selector三个组件是必须了解的。前面我们说到ByteBuffer是作为缓冲区进行数据的存放或者获取。通常我们需要进行flip翻转操作，但是这个在Netty中，有一个更为强大的类可以替代ByteBuf,其不需要进行翻转，也可以进行读写的双向操作。要将数据打包到缓冲区中，通常需要使用通道，而通道作为传输数据的载体，也即它可以使数据从一端到另一端，因此就必须进行了解。
最近几次测试 APP 时，遇到过几次非 http/https 通信的情况，burp、fiddler 等 http 代理工具都无法正常抓到包，经过分析发现 app 是通过 socket 通信的，所以写出来记录下。
我们知道netty中数据传输的核心是ByteBuf,ByteBuf提供了多种数据读写的方法，包括基本类型和byte数组的读写方法。如果要在netty中传输这些数据，那么需要构建ByteBuf，然后调用ByteBuf中对应的方法写入对应的数据，接着套用netty中标准的模板即可使用。
ZipUtil import java.io.*; import java.net.URLEncoder; import javax.servlet.http.HttpServletResponse; import org.apache.tools.zip.ZipEntry; import org.apache.tools.zip.ZipOutputStream; import org.slf4j.Logger; import org.slf4j.LoggerFactory; //import java
需求 编写一个NIO群聊系统,实现服务器端和客户端之间的数据简单通讯,非阻塞 实现多人群聊 服务器端: 可以监测用户上线, 离线, 并实现消息转发功能 客户端: 通过Channel可以无阻塞发送消息给其他用户,同时可以接受其他用户发送的消息(由服务器转发得到) 目的: 进一步了解NIO非阻塞网络编程机制 示意图分析和代码 示意图 编码 Server package com.dance.netty.nio.demo.groupchat; import java.io.IOException; impor
Buffer 是一个特定原始类型的容器。Buffer 是一个原始类型的线性的、有限序列，除了 Buffer 存储的内容外，关键属性还包括：capacity, limit 和 position。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
