Java把不同类型的输入、输出抽象为流stream,分为输入流和输出流,用统一的接口来表示
Java开发环境中提供了包javaio,其中包括一系列的类来实现输入/输出处理
InputStream是所有字节输入流的祖先,而OutputStream是所有字节输出流的祖先
public abstract class InputStream implements Closeable
public abstract class OutputStream implements Closeable, Flushable
具体子类: ByteArrayInputStream, FileInputStream, FilterInputStream, ObjectInputStream,
PipedInputStream, SequenceInputStream, StringBufferInputStream
InputStream
InputStream类是一个抽象类,方法包括:
int read()
int read(byte[])
int read(byte[],int,int)
void close()关闭流
int available()报告流中直接可读的字节数
skip(long)跳过流中指定的字节
OutputStream
OutputStream也是一个抽象类。它的主要方法包括:
void write(int)
void write(byte[])
void write(byte[],int,int)
其中第一个方法的int型的参数对应要写入的字节,后两个方法的参数与InputStream类似。
void close() 关闭输出流
void flush() 强行将写入缓冲区中剩余的数据写入
File file = new File("d:\\FileTestjava");
if (fileexists()) {
try (InputStream is = new FileInputStream(file);) {
byte[] buffer = new byte[8192];
int len = isread(buffer);
while (len > 0) {
Systemoutwrite(buffer, 0, len);
len = isread(buffer);
}
} catch (Exception e) {
eprintStackTrace();
}
}
InputSream 和 OutputStream 中定义了 read() 和 write() 方法,它们被派生流类重载。字节流是字节序
列,它与外部设备中的字节存在着一一对应的关系,不存在字符的转换,被读写字节的个数与外部设备中的字节个数是相同的
基本输入输出方法
System类是Java语言中一个功能强大、非常有用的类,它提供了标准输入/输出及运行时的系统信息
System类不能创建对象,也就是说,System类的所有属性和方法都是静态的,引用时要以System 作为前缀
Systemin与Systemout是System类的两个静态属性,分别对应了系统的标准输入/输出流 System类管理标准输入输出流和错误流
Systemout:把输出送到缺省的显示(通常是显示器),是PrintStream的对象
Systemin:从标准输入获取输入(通常是键盘),是InputStream的对象
Systemerr:把错误信息送到缺省的显示,是PrintStream的对象
同时使用Systemout和Systemerr输出信息不能保证显示顺序就是执行顺序,为了避免这种情况在测试代码执行中经常使用Systemerr输出
FileInputStream、FileOutputStream 顺序读取文件
PipedInputStream、PipedOutputStream 管道
ByteArrayInputStream、ByteArrayOutputStream 内存读写
FilterInputStream、FilterOutputStream 过滤流(有多线程同步)
DataInputStream、DataOutputStream 对数据类型读写,有多线程同步
BufferedInputStream、BufferedOutputStream 缓冲类型读写
1 、使用字节流进行文件的单字节复制
FileInputStream是InputStream的子类,FileInputStream属于节点流,用于按字节读取文件内容
FileOutputStream是OutputStream的子类,FileOutputStream属于节点流,用于按字节输出数据到文件中
//FileInputStream中read方法的定义
/
从指定的输入流中按字节读取数据,如果读到流的末尾则返回-1,否则返回读取到的数据。如果文件不存
在则异常FileNotFoundExceptionIOException的子类
/
public int read() throws IOException {
return read0();
}
//FileOutputStream中write方法的定义
//属性,用于表示是否进行文件的追加 *** 作而不是覆盖 *** 作
private final boolean append;
//构造器方法的定义,其中name是文件名称,默认采用覆盖 *** 作
public FileOutputStream(String name) throws FileNotFoundException {
this(name != null new File(name) : null, false);
}
//按照字节执行写出int数据,自动会去除多余的字节。如果文件不存在则自动创建新文件,如果
文件已经存在则按照append的值决定采用的是追加 *** 作还是覆盖 *** 作
public void write(int b) throws IOException {
write(b, append);
}
private native void write(int b, boolean append) throws IOException; //
由VM采用对等类的方式提供实现
public class Test1 {
public static void main(String[] args) throws IOException {
try (InputStream is = new FileInputStream("c:/面向对象文档txt");
OutputStream os = new FileOutputStream("testtxt");) {
int kk;
while ((kk = isread()) != -1) {
oswrite(kk);
}
}
}
}
2 、读取 Ajava 文件并在控制台上显示
如何使用控制台输出 : Systemout 字节流
分析:使用字节流从 Ajava 中一个字节一个字节的读取内容,然后再使用 Systemoutprint 方法输出即可
注意:读取 *** 作返回的 int 的取值范围为 0-255 ,则表示这里不会有符号位,所以 isread()==-1 不是只适合于文本文件
File ff = new File("T1java");
if (ffexists()) {// 如果文件存在则进行拷贝 *** 作,否则提示文件不存在
InputStream is = new FileInputStream(ff);
OutputStream os = new FileOutputStream("t1bak");
while (true) {
int kk = isread();// 返回值应该是0-255,如果返回-1表示流已经结束
if (kk < 0)break;
oswrite(kk);
}
isclose();
osclose();
} else
Systemoutprintln("T1java文件不存在");
InputStream基本输入类
InputStream类是基本的输入类。它定义了所有输入流所需的方法。
public abstract int read() throws IOException读取一个字节并以整数的形式返回,0-255。如果 返回-1已到输入流的末尾。
public int read(byte b[]) throws IOException读取一系列字节并存储到一个数组,返回实际读取的 字节数。如果已经读到输入流的末尾则返回-1
public void close() throws IOException 关闭输入流并释放资源
public int read(byte b[],int offset,int length) throws IOException功能为从输入流中读数据。这一 方法有几种重载形式,可以读一个字节或一组字节。当遇到文件尾时,返回-1。最后一种形式中的 offset是指把结果放在b[]中从第offset个字节开始的空间,length为长度
public long skip (long n) throws IOEnception 从输入流跳过几个字节。返回值为实际跳过的字节数
OutputStream基本输出类
三个重载形式都是用来向输出流写数据的
public abstract void write(int b)向输入流写入一个字节数据,该字节为参数的低8位。
public void write(byte b[],int offset,int length)将一个字节类型的数组中的从指定位置offset开始 的length个字节写入到输出流
public void close( ) 关闭输出流,释放资源
public void write(byte b[])将一个字节类型的数组中的数据写入到输出流
public void flush() 清除缓冲区,将缓冲区内尚未写出的数据全部输出
字符流
在顶层有 Reader 和 Writer 两个抽象类。 Reader 和 Writer 中定义了 read() 和 write() 方法,它们被派生流类重载
Reader 抽象类的定义
public abstract class Reader implements Readable, Closeable {
//BIO,读取一个有效的字符,返回值为0到65535的整数,如果到达流的末尾则返回-1
public int read() throws IOException
//BIO,读取字符存储到char数组中,返回读取的字符个数,流结束则返回-1
public int read(char cbuf[]) throws IOException
//关闭流,同时释放资源
abstract public void close() throws IOException;
Writer 抽象类的定义
public abstract class Writer implements Appendable, Closeable, Flushable {
//写出一个字符到字符流,要写的字符包含在给定整数值的16个低位;16个高位被忽略。
public void write(int c) throws IOException
//将字符数组中的指定部分内容压入到字符流,从off开始共len个字符
abstract public void write(char cbuf[], int off, int len) throws
IOException;
/关闭流,同时释放资源
abstract public void close() throws IOException;
相关的子类
InputStreamReader、OutputStreamWriter桥接流,用于自动实现字节流和字符流的转换
FileReader、FileWriter文件流,用于实现针对文本文件的读写 *** 作
CharArrayReader、CharArrayWriter内存流,用于实现针对char数组的读写 *** 作
PipedReader、PipedWriter管道流,用于线程之间的通讯
FilterReader、FilterWriter过滤流的父类
BufferedReader、BufferedWriter缓存流,用于在流中添加缓冲区
StringReader、StringWriter内存流,用于实现针对字符串的读写 *** 作
使用字符流实现 txt 文件的读取显示其中包含中文
编写一个程序,读取文件 testtxt 的内容并在控制台输出。如果源文件不存在,则显示相应的错误信息。
字符流 Reader
int read()读取一个字符并以整数的形式返回0-65535,如果返回-1则已到输入流末尾
int read(char[] cbuf)读取一系列字符并存储到一个数组中,返回实际读取的字符数,如果读到输入流末尾则返回-1
void close()关闭输入流并释放内存资源
int read(char[] cbuf, int off, int len) 读取len个字符并存储到一个数组中,从off位置开始,返回实
际读取的字符数,如果读取到输入流末尾则返回-1
long skip(long n)跳过n个字符不读,返回实际跳过的字节数
字符流 Writer
void write(int c) 将字符(int数组的低8位)压入到字符流中
void write(char[] cbuf, int off, int len)将字符数组中的指定部分内容压入到字符流中,从off开始共len个字符
void write(String str) 将字符串中的内容压入到字符流中
void close() 关闭流并释放所占用的资源
void write(String str, int off, int len) 将字符串中的指定部分内容压入到字符流中,从下标off开始共len个字符
void flush()刷新缓冲区,将缓冲区中的数据全部送出到目标地,然后清空缓冲区
void write(char[] cbuf) 将字符数组中的所有数据压入到字符流中
一般来说:一次读写一个字符效率太低,可以引入 char[] 数组提高执行效率
小结
在学些BIO时记忆父类的方法,区分子类的实现不同
InputStream中的方法 read(byte[]):int; Reader中方法read(char[]):int 如果到达流末尾 则-1
OutputStream中的方法 write(byte[],0,len):void;Writer中的方法 write(char[],0,len)/write(String)
一般在使用中,如果读取数据使用字节流,则写出数据采用的也是字节流;不建议混用,除非引入 桥接流
文件流
FileInputStream("file-name") FileInputStream(File) FileNotFoundException
FileReader("file-name") FileReader(File) FileNotFoundException
FileOutputStream("file-name") FileOutputStream("file-name",true) 默认文件覆盖,如果 参数true表示追加
FileWriter("file-name") FileWriter("file-name",true)
一般不使用单字节或者单字符的 *** 作方法,使用数组
注意:try(){}是推荐写法,否则应该使用try{}finally{}结构保证流的关闭
针对二进制文件不建议使用字符流,建议使用字节流进行 *** 作,否则有可能拷贝文件出现问题:
如果针对文本文件则建议使用字符流,因为编码使用比较方便
文章知识点与官方知识档案匹配
Java技能树类和接口类和面向对象
89124 人正在系统学习中
点击阅读全文
打开CSDN,阅读体验更佳
java用于输入输出流的类_java输入输出流_lsgn的博客
java输入输出流 java IO综述 在整个Javaio包中最重要的就是5个类和一个接口。5个类指的是File、OutputStream、InputStream、Writer、Reader;一个接口指的是Serializable。 Java I/O主要包括如下几个层次,包含三个部分:
java常见输入输出类型_3分钟秒懂大数据的博客
输入:每行输入一个数,连续输入n行,遇到0结束输入,然后输出结果。 importjavautilArrayList; importjavautilScanner; publicclassTest4{ publicstaticvoidmain(String[] args){ Scannersc=newScanner(Systemin);
25、JAVA进阶——输入输出流
一、认识Java的流 二、使用字节流读写文本文件 1、使用字节流类FileInputStream读文本文件 2、使用字节流类FileOutputStream写文本文件 三、使用字符流读写文本文件 1、使用字符流类BufferedReader和FileReader读文本文件 2、使用字符流类BufferedWrite和FileWrite写文本文件 四、读写二进制文件 1、 使用字节流读二进制文件 2、 使用字节流写二进制文件 五、序列化和反序列化 1、认识序列化 2、序列化保存对
继续访问
java 输入类_java 输入输出类
java中输入输出类如果理不清思路的话就会很混乱!一File类提供与 *** 作系统无关的文件 *** 作!可以查看api文档了解它的方法二输出 *** 作:1把信息输出到屏幕上最简单的 *** 作就是使用标准输出:Systemoutprintln();下面讨论一下流方式的输出,与之相关的类如下OutputStreamWriter:它提供字符流到字节流的转换,换句话说它写入字符数据然后按照指定字符集转换为字节数据Buf
继续访问
JAVA的输入输出_努力的地球人的博客_java输出
Java的输入 Scanner类 为了使用scanner类,我们首先需要导入javautilScanner包 import javautilScanner; 1 创建scanner对象,从用户获取输入 //创建scanner对象 Scanner str=new Scanner(Systemin); //接受用户输入 int w=strnextIn
java输入输出_java中输入输出总结_weixin_39609407的博客
标准输入studin,对象是键盘。 标准输出stdout,对象是屏幕。 标准错误输出stderr,对象也是屏幕。 二、javaio包中的数据流和文件类 字节流:从InputStream和OutputStream派生出来的一系列类。这类流以字节(byte)为基本处理单位。
Java——不同数据类型的输入输出方式与转化方式
java 中不同数据类型的 输入方法 输出格式 与 转化方式
继续访问
Java文本输出常用类
package comssextract; import javaio; import orgapachelog4jLogger; / 结果输出类 @author Shu / public class ResultOutput { private
继续访问
1Java基础入门 -(2)输入输出类_菜鸟的小虫子的博客
一 Java Scanner 类 javautilScanner是 Java5 的新特征,我们可以通过 Scanner 类来获取用户的输入。 Scanner 对象的基本语法: Scanner in= new Scanner(Systemin); 示例1: 输入结果:
java的输入输出流类型_理解JAVA输入输出流_天接云涛的博客
1、字节流抽象类 InputStream输入流 OutputStream输出流 2、字符流抽象类 Reader 输入字符流 Writer 输出字符流 四、JAVA中流体系架构 有一些对流进行 *** 作的基本的方法,我们以文件输入输出流进行说明:
java的输出类
Systemout这个类是PrintStream类,定义如下 public class PrintStream extends FilterOutputStream PrintStream都是用print的相关函数输出到控制台上。print的实现都是用write(String s)实现。 而,PrintWriter这个输出类,也同样实现输出:PrintWriter extends
继续访问
Java中的各种输出形式
一、Java中的各种输出形式: package cnjllwj; public class Demo00 { public static void main(String[] args) { //标识符定义 区分大小写 int a = 5; int A = 6; //区分大小写 int Class = 6; int age = 5; //定义常量 final int AGE_MAX = 30;
继续访问
java中的BIO基础-3
java中的io基础
继续访问
Java学习-IO流进阶
缓冲流也称为高效流、或者高级流。之前学习的字节流可以称为原始流。
继续访问
IO进阶之高级IO
高级IO
继续访问
Java中的IO进阶 *** 作
Java中的IO进阶 *** 作 一、序列化和反序列化 常用于多台服务器之间进行java对象的数据传递。 1概念 序列化 是指程序中准备好的Java对象,永久的保存在磁盘中,这个过程其实是一个out的动作。 ObjectOutputStream:通过在流中使用文件可以实现对象的持久存储。 创建对象:ObjectOutputStream(OutputStream out) 常用方法: void writeObject(Object obj):将指定的对象写入ObjectOutputStream 反序列化 是指把
继续访问
Java IO最详解,欢迎提出意见
Java IO 详解 初学java,一直搞不懂java里面的io关系,在网上找了很多大多都是给个结构图草草描述也看的不是很懂。而且没有结合到java7 的最新技术,所以自己来整理一下,有错的话请指正,也希望大家提出宝贵意见。 首先看个图:(如果你也是初学者,我相信你看了真个人都不好了,想想java设计者真是煞费苦心啊!) 这是java io 比较基本的一些处理流,除此之外我们还会
继续访问
java输出类型_java中各种类型的输入输出
import javalangException;import javalangString;import javautilScanner;public class test {public static void main(String[] args) {Scanner s = new Scanner(Systemin);char ch;Systemoutprint("Char
继续访问
java中输入流的类_Java中的输入/输出流类
Java中包含的输入/输出流类 1javaio包中的接口 (1)处理字节流的有DataInput接口和DataOutput接口,RandomAccessFile同时实现了这两个接口; (2)处理对象流的有ObjectInput接口和ObjectOutput接口,ObjectInputStream类实现了ObjectInput接口,ObjectOutputStream类实现了ObjectOutp
继续访问
使用java的输入/输出类
1. 什么是IO? I:input 输入 通常做读取 *** 作(将不同数据源的数据读入到内存中,也叫读取流) O:output 输出通常做写入 *** 作(将内存中的数据写入到不同的数据源,也叫写入流) 2. 理解流的概念。 想像一下自来水公司要把水输到用户家里,应该先把自来水公司到用户家里的连接水管建好,再将水输出去。管道里输送的是水,但IO里输送的是字节。 u流是
继续访问
Java中的输入/输出流类
Java中包含的输入/输出流类 1javaio包中的接口 (1)处理字节流的有DataInput接口和DataOutput接口,RandomAccessFile同时实现了这两个接口; (2)处理对象流的有ObjectInput接口和ObjectOutput接口,ObjectInputStream类实现了ObjectInput接口,ObjectOutputStream类实现了ObjectOutp
继续访问
最新发布 Java基础自定义一个格式输出类
在项目实际开发中,后端接口都按照一定的格式输出给前端调用,在返回中包括状态码和接口的主要作用等注释,再包含实际的data。
继续访问
IO流(进阶提高)
本篇文章继上一篇IO流(小试牛刀)继续更新JavaIO流的知识。 常见IO流的结构图解: 回顾一下IO的基本接口知识: ————————————————————我是不起眼的分割线———————————————————————— IO的序列化与反序列化 Java序列化是指把Java对象转换为字节序列的过程;Java反序列化是指把字节序列恢复为Java对象的过
继续访问
java进阶8——IO流
File类 File概述 File文件和目录路径名的抽象表示形式。即,Java中把文件或者目录(文件夹)都封装成File对象。也就是说如果我们要去 *** 作硬盘上的文件,或者文件夹只要找到File这个类即可。 File类的构造函数 File(String pathname); // 将一个字符串路径封装成File对象 File(String parent,String child);
继续访问
Java IO流进阶之常用流(一)
请多参考JDK文档:>
Netty事件分为入站事件与出站事件,可以通过ChannelPipline或者ChannelHandlerContext进行事件传播。通过ChannelPipline传播入站事件,它将被从ChannelPipeline的头部开始一直被传播到ChannelPipeline的尾端,出站事件则从尾端开始传递到头部。通过ChannelHandlerContext传播入站事件,它将被从下一个ChannelHandler开始直至传递到尾端,出站事件则从下一个ChannelHandler直至传递到头部。
Netty为了提高传输数据的效率,在写出数据时,会先将数据(ByteBuf)缓存到ChannelOutboundBuffer中,等到调用flush方法时才会将ChannelOutboundBuffer中的数据写入到socket缓冲区。
ChannelOutboundBuffer中有三个重要属性:
从其属性可以看出,ChannelOutboundBuffer内部是一个链表结构,里面有三个指针:
ChannelOutboundBuffer中有两个比较重要的方法,addMessage:将数据以链表形式缓存下来,addFlush:移动链表指针,将缓存的数据标记为已刷新,注意此时并没有将数据写入到socket缓冲区。接下来我们看下两个方法的实现:
我们进入其addMessage方法分析下它是怎么缓存数据的:
当第一次添加数据数,会将数据封装为Entry,此时tailEntry、unflushedEntry指针指向这个Entry,flushedEntry指针此时为null。每次添加数据都会生成新的Entry,并将tailEntry指针指向该Entry,而unflushedEntry指针则一直指向最初添加的Entry,我们通过画图展示下:
第一次添加:
第N次添加:
为了防止缓存数据过大,Netty对缓存数据的大小做了限制:
addMessage方法最后会调用incrementPendingOutboundBytes方法记录已缓存的数据大小(totalPendingSize),如果该大小超过了写缓冲区高水位阈值(默认64K),则更新不可写标志(unwritable),并传播Channel可写状态发生变化事件:fireChannelWritabilityChanged:
移动链表指针,将缓存的数据标记为已刷新,并设置每个数据节点状态为不可取消:
执行完addFlush方法后,链表图示如下:
通过ChannelHandlerContext#writeAndFlush方法来分析下Netty是如何将数据通过网络进行传输的:
ChannelHandlerContext#writeAndFlush方法最终会调用其子类AbstractChannelHandlerContext的writeAndFlush方法:
主要逻辑在write方法中:
write方法主要做了两件事,一是:找到下一个ChannelHandlerContext。二是:调用下一个ChannelHandlerContext的w riteAndFlush方法传播事件。writeAndFlush方法是一个出站事件,前面我们也讲过对于出站事件,通过ChannelHandlerContext进行事件传播,事件是从pipline链中找到当前ChannelHandlerContext的下一个ChannelHandlerContext进行传播直至头部(HeadContext),在这期间我们需要自定义编码器对传输的Java对象进行编码,转换为ByteBuf对象,最终事件会传递到HeadContext进行处理。
invokeWriteAndFlush方法主要做了两件事,一是:调用invokeWrite0方法将数据放入Netty缓冲区中(ChannelOutboundBuffer),二是:调用invokeFlush0方法将缓冲区数据通过NioSocketChannel写入到socket缓冲区。
invokeWrite0方法内部会调用ChannelOutboundHandler#write方法:
前面说过,出站事件最终会传播到HeadContext,在传播到HeadContext之前我们需要自定义编码器对Java对象进行编码,将Java对象编码为ByteBuf,关于编码器本章节暂不进行解析。我们进入HeadContext的write方法:
HeadContext#write方法中会调用AbstractChannelUnsafe#write方法:
该方法主要做了三件事情,一:对数据进行过滤转换,二:估测数据大小,三:缓存数据。我们先看下filterOutboundMessage方法:
一、对数据进行过滤转换:
filterOutboundMessage方法首先会对数据进行过滤,如果数据不是ByteBuf或者FileRegion类型,则直接抛出异常。如果数据是ByteBuf类型,则判断数据是否为直接直接内存,如果不是则转换为直接内存以提升性能。
二、估测数据大小:
三、缓存数据:
最后会调用ChannelOutboundBuffer#addMessage方法将数据缓存到链表中,关于addMessage方法可以回顾下文章中的Netty缓冲区部分。
回到AbstractChannelHandlerContext#invokeWriteAndFlush方法,方法内部在调用完invokeWrite0方法将数据放入到缓存后,会调用invokeFlush0方法,将缓存中的数据写入到socket缓冲区。invokeFlush0方法内部会调用ChannelOutboundHandler#flush方法:
flush方法最终会将事件传播到HeadContext的flush方法:
HeadContext#flush方法中会调用AbstractChannelUnsafe#flush方法:
方法主要做了两件事,一:调用ChannelOutboundBuffer#addFlush方法,移动链表指针,将缓存的数据标记为已刷新。二:调用flush0方法将缓存中数据写入到socket缓冲区。关于addFlush方法可以看文中Netty缓冲区部分,我们直接进入flush0方法:
flush0方法主要做了两件事,一:判断是否有挂起的刷新。二:调用父类flush0方法。
一、判断是否有挂起的刷新
文中提到写入数据时,当socket缓冲区没有可用空间时会设置不可写状态,并注册OP_WRITE事件,等待socket缓冲区有空闲空间时会触发forceFlush,我们进入到isFlushPending方法看下方法是如何判断的:
二、调用父类flush0方法
写入socket缓冲区的具体逻辑在AbstractNioChannel#AbstractNioUnsafe父类AbstractChannel#AbstractUnsafe中:
核心逻辑在doWrite方法中,我们进入到AbstractChannel子类NioSocketChannel的doWrite方法看下具体实现:
NioSocketChannel#doWrite方法根据nioBufferCnt大小执行不同的写逻辑,如果为0则调用AbstractNioByteChannel#doWrite方法。如果nioBufferCnt为1或者大于1,则调用NioSocketChannel不同的重载方法进行处理。注意,写数据时自旋次数默认为16,也就是说如果执行16次write后仍有数据未写完,则调用incompleteWrite方法将flush *** 作封装为一个任务,放入到队列中,目的是不阻塞其他任务。另外,如果调用NioSocketChannel#write方法后,返回的localWrittenBytes为0,则表示socket缓冲区空间不足,则注册OP_WRITE事件,等待有可用空间时会触发该事件,然后调用forceFlush方法继续写入数据。
在Androidpn的底层主要采用的两大框架mina和openfire两大框架,其中mina主要为底层数据传输的Socket框架。下面简单的介绍一下Socket框架
Apache Mina Server 是一个网络通信应用框架,也就是说,它主要是对基于TCP/IP、UDP/IP协议栈的通信框架(也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等),Mina 同时提供了网络通信的Server 端、Client 端的封装,无论是哪端,Mina 在整个网通通信结构中都处于如下的位置:
可见Mina 的API 将真正的网络通信与我们的应用程序隔离开来 ,你只需要关心你要发送、接收的数据以及你的业务逻辑即可。同样的,无论是哪端,Mina 的执行流程如下所示:
(1) IoService:这个接口在一个线程上负责套接字的建立,拥有自己的Selector,监听是否有连接被建立。
(2) IoProcessor:这个接口在另一个线程上负责检查是否有数据在通道上读写,也就是说它也拥有自己的Selector,这是与我们使用JAVA NIO 编码时的一个不同之处,通常在JAVA NIO 编码中,我们都是使用一个Selector,也就是不区分IoService与IoProcessor 两个功能接口。另外,IoProcessor 负责调用注册在IoService 上的过滤器,并在过滤器链之后调用IoHandler。
(3) IoFilter:这个接口定义一组拦截器,这些拦截器可以包括日志输出、黑名单过滤、数据的编码(write 方向)与解码(read 方向)等功能,其中数据的encode 与decode是最为重要的、也是你在使用Mina 时最主要关注的地方。
(4) IoHandler:这个接口负责编写业务逻辑,也就是接收、发送数据的地方。
通过Mina的原理我们研究androidpn的运行流程不能看出,如下:
1spring初始化并启动过程,调用NioSocketAcceptor。
2NioSocketAcceptor开始执行调用IoProcessor
3IoProcessor开始调用FilterChain。FilterChain调用相关的IoFilter的。其中ProtocolCodecFilter的过滤器调用了organdroidpnserverxmppcodecXmppCodecFactory进行编码。
4XmppIoHandler实现自IoHanlder并调用通过openfire 的XMLLightweightParser解析相关的业务逻辑。
5根据解析的信息调用xmpp并处理相关信息。
AndroidPN(Android Push Notification) 是一个基于 XMPP 协议的 Java 开源推送通知实现,它包含了完整的客户端和服务端。
AndroidPN基于 Openfire 下的一些开源项目构建。
AndroidPN服务器包含两个部分,
一个是侦听在5222端口上的XMPP服务,负责与客户端的XMPPConnection类进行通信,作用是用户注册和身份认证,并发送推送通知消息。
另外一部分是Web服务器,采用一个轻量级的>
最上层包含四个组成部分,分别是SessionManager,Auth Manager,PresenceManager以及Notification Manager。
SessionManager负责管理客户端与服务器之间的会话。
Auth Manager负责客户端用户认证管理。
Presence Manager负责管理客户端用户的登录状态。
NotificationManager负责实现服务器向客户端推送消息功能。
IQHandler消息处理器的类:
IQHandler:消息处理器抽象类。
IQAuthHandler:权限协议的消息处理类,消息的类型为:jabber:iq:auth
IQRegisterHandler:用户注册的消息处理类,消息类型为: jabber:iq:register
IQRosterHandler:用户消息交互类,消息类型为:jabber:iq:roster
PresenceUpdateHandler:用户状态展现变化处理类。内部调用,不具有类型。
将Java代码中的ANSI X34-1968编码改为UTF编码,可以按照以下步骤进行:
1备份代码:在进行任何修改之前,务必备份代码,以免修改过程中出现错误导致代码丢失。
2打开代码文件:使用文本编辑器打开Java代码文件,找到文件编码方式。
3转换编码方式:将文件编码方式从ANSI X34-1968改为UTF-8或其他UTF编码方式,具体步骤如下:
a在文本编辑器中找到“另存为”选项;
b在d出的对话框中选择编码方式为UTF-8或其他UTF编码方式;
c保存文件并关闭文本编辑器。
4检查代码:重新打开Java代码文件,检查代码是否能够正常编译和运行,以确保代码在编码转换过程中没有出现问题。
需要注意的是,如果Java代码中存在中文或其他非ASCII字符,转换编码方式可能会导致这些字符的乱码,此时需要手动修改相关字符的编码方式。如果您不确定如何进行 *** 作,建议咨询专业的软件工程师或相关技术支持人员。
javanetURLDecoderdecode("%E6%8D%A2%E4%B9","UTF-8")
前一参数是编码串,后一参数是编码方式名称。
注:不一定有效,有时编码用的不是UTF-8,java支持的编码种类有上百种。用错了编码方式结果不会正确的。
比如用UTF-8试验了几个链接中的编码串是正确的,但上面的编码串试验了所有编码方式,都是乱码。
编码方式 *** 作:
import javaniocharsetCharset;
取得本机支持的编码方式名称数组:
String[] charsets=CharsetavailableCharsets()keySet()toArray(new String[0]);
取得本机支持的编码方式数组:
Charset[] charsets=CharsetavailableCharsets()keySet()toArray(new Charset[0]);
取得本机默认的编码方式名称:
CharsetdefaultCharset()name()
补充:Java是一种可以撰写跨平台应用软件的面向对象的程序设计语言。Java 技术具有卓越的通用性、高效性、平台移植性和安全性,广泛应用于PC、数据中心、游戏控制台、科学超级计算机、移动电话和互联网,同时拥有全球最大的开发者专业社群。
以上就是关于java中处理中文输入,不需要用到的类是全部的内容,包括:java中处理中文输入,不需要用到的类是、技术问题:java中如何判断字符串内容是否是一种编码格式、Netty writeAndFlush解析等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)