`
nbtlxx
  • 浏览: 253709 次
  • 性别: Icon_minigender_1
  • 来自: 宁波
社区版块
存档分类
最新评论

NIO中关于ByteBuffer的简单使用

阅读更多
1.和NIOServer建立连接new Socket(ip, port)
* 2.获得Scanner.next(System.in):输入内容
* 3. 将要发送的字符串内容进行处理
*    a. 获得int len = str.getByte().length
*    b. 将len 进行byte 处理,依次发给server
*    dos.write((byte)temps.length&0xff);
dos.write((byte)temps.length>>8&0xff);
*    c. 将数据本身发送给NioServer
*    注意:因为NIOserver使用ByteBuffer来接收数据,所以,必须在客户端采用字节流方式,并且进行Byte运算后,才可以发送到网络流

2. 服务器类比较多,此处至贴出相关byteBuffer处理的代码

客户端代码

/**
 * 
 */
package client;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;


/**
 * @author sean
 * 
 * 测试NIOServer的客户端类
 * 1.和NIOServer建立连接new Socket(ip, port) 
 * 2.获得Scanner.next(System.in):输入内容
 * 3. 将要发送的字符串内容进行处理
 *    a. 获得int len = str.getByte().length
 *    b. 将len 进行byte 处理,依次发给server
 *    	dos.write((byte)temps.length&0xff);
		dos.write((byte)temps.length>>8&0xff);
 *    c. 将数据本身发送给NioServer
 *    注意:因为NIOserver使用ByteBuffer来接收数据,所以,必须在客户端采用字节流方式,并且进行Byte运算后,才可以发送到网络流
 *    
 * *
 */
public class ClientDemo {

	static Socket socket;	
	static DataOutputStream dos;
	
	static DataInputStream dis;
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		try {
			socket = new Socket("127.0.0.1", 9999);		
			if(socket == null){
				System.exit(0);
			}
			dos = new DataOutputStream(socket.getOutputStream());
			dis = new DataInputStream(socket.getInputStream());	

			//获取一个屏幕读取类
			Scanner sc = new Scanner(System.in);			
			
			do{
				System.out.println("please enter content:");
				String msg = sc.next();
				System.out.println("length:" + msg.getBytes().length);
				
				//此处将内容采用utf-8方式得到字节数据
				byte temps[]=msg.getBytes("UTF-8");
				
				//将length进行位运算,整理成short型,代表将要发送字符串内容的长度,方便
				//server端根据长度来使用byte[]	来接收处理
				dos.write((byte)temps.length&0xff);
				dos.write((byte)temps.length>>8&0xff);
				dos.write(temps);
				System.out.println("printwrite send ok: " + msg);
				
				if(msg.equalsIgnoreCase("bye")){
					break;
				}
			}
			while(true);			
			
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			closeSocket();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			closeSocket();
		}		
	}

	/**
	 * 关闭当前socket
	 * 依次关闭is, os, socket
	 * socket通道最后关闭
	 */
	private static void closeSocket() {
		// TODO Auto-generated method stub
		if(dis != null){
			try {
				dis.close();
				dis = null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}			
		}
		
		if(dos != null){
			try {
				dos.close();
				dos = null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}			
		}
		
		if(socket != null){
			try {
				socket.close();
				socket = null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}
}





Server代码, 只是给出相关的代码
public void handleRead(SelectionKey key) {

// TODO Auto-generated method stub
if (this.selectionKey != key) {
closeChannel();
this.selectionKey = key;
this.channel = (SocketChannel) key.channel();
}

try {
int ret = channel.read(inBuffer);


if (ret < 0) {
closeChannel();
}

int result = parseInput(inBuffer);

if (result < 0) {
closeChannel();
return;
}

this.lastAccessTime = System.currentTimeMillis();

} catch (IOException e) {
// TODO Auto-generated catch block
closeChannel();
// e.printStackTrace();
}

}

/**
* byteBuffer变成message
* 并且调用logicprocess
* @param inBuffer
* @return
*/
private int parseInput(ByteBuffer inBuffer) {
// TODO Auto-generated method stub
int result = 0;
List<Message> list = server.getProtocol().parseDataInput(inBuffer, this);

if(list == null){
return -1;
}

for(int i=0; i<list.size(); i++){
server.getLogicProcess().serverProcess(list.get(i));
}

return result;
}

/**
*
*/
private void closeChannel() {
// TODO Auto-generated method stub
selectionKey.cancel();
try {
channel.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}


/* 
	 * 此处将ByteBuffer进行解析,
	 * 打包成message格式
	 */
	@Override
	public List<Message> parseDataInput(ByteBuffer inBuffer, SocketSession session) {
		// TODO Auto-generated method stub
		if(inBuffer == null){
			return null;
		}
		System.out.println(inBuffer);
		
		//此处注意需要复制出一个tempBuf,并且用flip(),否则报错underflowException
		ByteBuffer tempBuf = inBuffer.duplicate();
		inBuffer.flip();
		
		List<Message> list = new ArrayList<Message>();
		
		//判断是否还有剩余字节,并且字节长度不少于包头长度
		while(inBuffer.hasRemaining()){
			if(inBuffer.remaining() < HEAD_LEN){
				break;
			}
			
			//此处获得客户端发送内容的长度,构造相关长度的字节数组
			byte[] data = new byte[2];
			inBuffer.get(data);
			
			//此处将Byte数组,转换成short型
			int len = ChangeTools.ByteToInt2(data, 0);
			
			//读取整个内容的长度
			data = new byte[len];
			inBuffer.get(data);
			
			//包头数组,复制到包头数组
			byte[] headData = new byte[HEAD_LEN];
			System.arraycopy(data, 0, headData, 0, HEAD_LEN);
			
			HeadModel head = parseHead(headData);
			
			
			//获取包体数据
			byte[] bodyData = new byte[head.bodyLen];
			System.arraycopy(headData, 0, data, 0, headData.length);
			System.arraycopy(bodyData, 0, data, headData.length, bodyData.length);
			
			Message msg = MessageFactory.createServerMessage(session, data, headData, bodyData, head.cmdType,
					head.playerId,head.tag);
			
			if(msg == null){
				return null;
			}
			list.add(msg);			
		}
		
		//? 此处的作用需要加深理解
		if (list.size() > 0) {
			inBuffer.compact();
			inBuffer.clear();

			inBuffer.position(inBuffer.position());
			inBuffer.limit(inBuffer.limit());
		}
		
		return list;
	}

2
0
分享到:
评论

相关推荐

    Java NIO学习笔记——ByteBuffer用法

    本文主要关注的是Java NIO中的ByteBuffer,一个关键的数据容器,用于在通道(Channel)和缓冲区(Buffer)之间传输数据。ByteBuffer的用法是Java NIO学习中的核心内容。 首先,我们了解下ByteBuffer的基本概念。...

    NIO(byteBuffer)按行读取文件

    使用nio byteBuffer 实现按行读取文件(大文件) 在window/linux/macOS上均测试通过 对于中文乱码也已处理成功 完整注释,可随需求更改 有问题请邮件:mly610865580@126.com

    深入理解Apache Mina (6)---- Java Nio ByteBuffer与Mina ByteBuffer的区别

    在Mina中,ByteBuffer的使用是至关重要的,因为它提供了高效的数据读写机制。本篇将深入探讨Java NIO(非阻塞I/O)中的ByteBuffer和Mina库自定义的ByteBuffer之间的区别。 Java NIO的ByteBuffer是Java标准库提供的...

    Android中的ByteBuffer解析

    2. **直接缓冲区**:对于性能敏感的应用,可以使用`ByteBuffer.allocateDirect(int capacity)`创建直接缓冲区,它直接在物理内存中分配空间,减少了Java对象头的开销,但可能涉及内存复制。 三、ByteBuffer的主要...

    基于nio的简易聊天室

    本项目"基于nio的简易聊天室"旨在通过NIO技术实现一个简单的聊天室服务端和客户端,其特点是有图形用户界面(GUI)供用户交互。 NIO的核心组件包括通道(Channels)、缓冲区(Buffers)和选择器(Selectors)。在这...

    java NIO原理和使用

    下面是一个简单的 Java NIO 示例,展示了如何使用 `FileChannel` 和 `ByteBuffer` 进行文件复制: ```java package nio; import java.io.FileInputStream; import java.io.FileOutputStream; import java.nio....

    Android在JNI中使用ByteBuffer的方法

    下面将详细介绍在Android JNI中使用ByteBuffer的方法及其相关知识点。 首先,了解ByteBuffer的基本概念。ByteBuffer是一个固定大小的列表,用于存储基本数据类型,如字节、短整型、整型、长整型等。它有四个核心...

    JAVA NIO 按行读取大文件支持 GB级别-修正版

    设计思想: 每次通过nio读取字节到 fbb中 然后对fbb自己中的内容进行行判断即 10 回车 13 行号 0 文件结束 这样字节的判断,然后 返回行 如果 到达 fbb的结尾 还没有结束,就再通过nio读取一段字节,继续处理。 ...

    基于Groovy的NIO框架,仅供学习Java NIO使用。.zip

    Java NIO提供了ByteBuffer、CharBuffer、DoubleBuffer、FloatBuffer、IntBuffer和LongBuffer等类型。 3. **选择器(Selectors)**:选择器用于监视多个通道的状态,当通道准备就绪进行读写操作时,选择器会通知我们...

    NIO 入门.chm,NIO 入门.chm

    **NIO(New Input/Output)是Java编程语言中用于替代标准I/O(BIO,Blocking I/O)的一组API,它提供了非阻塞式的I/O操作方式,极大地提升了Java在处理I/O密集型应用时的性能。NIO在Java 1.4版本中被引入,之后在...

    Java NIO 中英文版

    在传统的Java I/O中,使用的是Blocking I/O,即阻塞式I/O,这种模型下,线程在等待数据就绪时会被挂起,直到数据准备好才能继续执行,这在处理大量并发连接时效率较低。而Java NIO则引入了选择器(Selectors)和通道...

    Java-NIO-Programming-Cookbook(含源码)

    直接缓冲区在Java中使用JNI(Java Native Interface)直接在物理内存中分配,而不需要经过Java堆,这通常能提高性能,尤其是在大量I/O操作时。 `DirectByteBufferExample.java`这个文件很可能是书中一个示例程序,...

    NIO复制文件

    2. **ByteBuffer**:`java.nio.ByteBuffer`是NIO中最重要的缓冲区类型,它可以被映射到文件,也可以作为网络I/O的数据容器。在复制文件时,我们用它来存储从源文件读取或写入目标文件的数据。 下面是一个简单的文件...

    浅谈java中nio的使用方式

    以下是一个简单的NIO服务器示例,展示了如何使用Selector、Channel和Buffer处理客户端连接: ```java public class Server { private Selector selector; private ServerSocketChannel serverSocketChannel; ...

    使用NIO方式完成简单的通信

    本教程将介绍如何使用NIO来实现简单的通信,包括消息头和消息体的设计。 首先,我们需要了解NIO的基本组件。NIO的核心类包括`Selector`、`Channel`和`Buffer`。`Selector`用于监控多个`Channel`的事件,如读写就绪...

    java NIO.zip

    Java NIO提供了诸如ByteBuffer、CharBuffer、IntBuffer等类型,对应于不同的数据类型。缓冲区具有读写位置,可以通过flip()、clear()和rewind()等方法来管理缓冲区的状态,从而高效地进行数据读写。 3. **选择器...

    java NIO 写文件

    下面是一个简单的示例,展示了如何使用NIO写文件: ```java import java.io.RandomAccessFile; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; public class FileNioWrite { public static ...

    java nio 读文件

    在Java NIO中,读取文件主要涉及FileChannel和ByteBuffer。以下是一个简单的示例: ```java import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.nio....

Global site tag (gtag.js) - Google Analytics