浏览 4891 次
|
锁定老帖子 主题：as3和java nio通信的完美例子
精华帖 (0) :: 良好帖 (0) :: 新手帖 (0) :: 隐藏帖 (0)
|
|
|---|---|
| 作者 | 正文 |
|
发表时间：2011-12-30
这一块资料很少,特此整理了一下:
package astest;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
/**
* ByteArray数据包
* @author zkpursuit
*/
public class Packet {
private ByteBuffer buff;
private int length;
/**
* 默认构造方法
* 开辟2M的缓存区
*/
public Packet(){
this(1024);
}
public Packet(int size){
length=size;
buff = ByteBuffer.allocate(length);
}
public Packet(ByteBuffer buffer){
buff=buffer;
length=buffer.limit();
}
//写入数据
public void writeChar(char value){
buff.putChar(value);
}
public void writeByte(byte value){
buff.put(value);
}
public void writeFloat(float value){
buff.putFloat(value);
}
public void writeLong(long value){
buff.putLong(value);
}
public void writeDouble(double value){
buff.putDouble(value);
}
public void writeInt(int value){
buff.putInt(value);
}
public void writeShort(short value){
buff.putShort(value);
}
public void writeBytes(byte[] bytes){
buff.put(bytes);
}
public void writeString(String str){
byte[] str_bytes=str.getBytes();
short len=(short)(str_bytes.length);
writeShort(len);
writeBytes(str_bytes);
}
public void writeString(String str,String charset){
try {
byte[] str_bytes=str.getBytes(charset);
short len=(short)(str_bytes.length);
writeShort(len);
writeBytes(str_bytes);
} catch (UnsupportedEncodingException e) {
System.out.println("不能识别的字符编码");
e.printStackTrace();
System.exit(0);
}
}
//读取数据
public char readChar(){
return buff.getChar();
}
public byte readByte(){
return buff.get();
}
public float readFloat(){
return buff.getFloat();
}
public long readLong(){
return buff.getLong();
}
public double readDouble(){
return buff.getFloat();
}
public int readInt(){
return buff.getInt();
}
public short readShort(){
return buff.getShort();
}
public String readString(){
short len=buff.getShort();
byte[] _bytes=new byte[len];
buff.get(_bytes, 0, len);
return new String(_bytes);
}
public String readString(String charset){
short len=buff.getShort();
byte[] _bytes=new byte[len];
buff.get(_bytes, 0, len);
try {
return new String(_bytes,charset);
} catch (UnsupportedEncodingException e) {
System.out.println("不能识别的字符编码");
e.printStackTrace();
System.exit(0);
}
return new String(_bytes);
}
public ByteBuffer byteBuffer(){
return buff;
}
public ByteBuffer pack(){
int l=length();
ByteBuffer buffer=ByteBuffer.allocate(l);
if(position()>0){
flip();
}
buffer.put(array(), 0, l);
buffer.flip();
return buffer;
}
public byte[] array(){
return buff.array();
}
public int position(){
return buff.position();
}
public void flip(){
buff.flip();
}
public void clear(){
buff.clear();
length=0;
}
/**
* 实际存在有用数据的长度
* @return
*/
public int length(){
return length-buff.remaining();
}
/**
* 预定义的长度
* @return
*/
public int totalSize(){
return length;
}
public void outInfo(byte[] bytes){
for(int i=0;i<bytes.length;i++){
System.out.println("---------"+bytes[i]);
}
}
}
package astest;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CharsetEncoder;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
/**
*
* @author Jeff
*
*/
public class NIOServer {
private static int BLOCK = 1024;
private static String name = "";
public Selector selector;
protected ByteBuffer clientBuffer = ByteBuffer.allocate(BLOCK);
protected CharsetDecoder decoder;
public static CharsetEncoder encoder = Charset.forName("GB2312").newEncoder();
public HashMap<Integer,SelectionKey> rooms=new HashMap<Integer,SelectionKey>();
public List<Integer> ids=new ArrayList<Integer>();
private HashMap<Integer,ICommand> commands=new HashMap<Integer,ICommand>();
public final int CONNECT=1000;
public final int SELECT_ROOM=1005;
public final int START=1010;
public final int RECEIVE_DATA=1015;
public final int CONNECT_SUCCESS=2000;
public final int SEND_DATA=2005;
public NIOServer(int port) throws IOException {
selector = this.getSelector(port);
Charset charset = Charset.forName("GB2312");
decoder = charset.newDecoder();
}
public void registerCommand(int commandID,ICommand command){
if(!commands.containsKey(commandID)){
System.out.println("registeCommand "+commandID+" , "+command);
commands.put(commandID, command);
}
}
// 获取Selector
protected Selector getSelector(int port) throws IOException {
ServerSocketChannel server = ServerSocketChannel.open();
Selector selector = Selector.open();
server.socket().bind(new InetSocketAddress(port));
server.configureBlocking(false);
server.register(selector, SelectionKey.OP_ACCEPT);
return selector;
}
// 监听端口
public void listen() {
try {
while(true){
int num=selector.select();
Iterator<SelectionKey> iter = selector.selectedKeys().iterator();
while (iter.hasNext()) {
SelectionKey key = iter.next();
iter.remove();
process(key);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
// 处理事件
protected void process(SelectionKey key) throws IOException {
if (key.isAcceptable()) { // 接收请求
ServerSocketChannel server = (ServerSocketChannel) key.channel();
SocketChannel channel = server.accept();
// 设置非阻塞模式
channel.configureBlocking(false);
channel.register(selector, SelectionKey.OP_READ);
} else if (key.isReadable()) { // 读信息
read(key);
//clientBuffer.clear();
} else if (key.isWritable()) { // 写事件
if(key.isValid()){
//SocketChannel channel = (SocketChannel) key.channel();
Packet p=new Packet(100);
p.writeInt(300);
p.writeInt(400);
p.writeString("野草工革革", "utf-8");
send(key,p);
//int attachment=(Integer)key.attachment();
}
}
}
/**
* 读取数据
* @param channel
* @throws IOException
*/
public void read(SelectionKey key) throws IOException{
SocketChannel channel = (SocketChannel) key.channel();
int count = channel.read(clientBuffer);
if(count>0){
clientBuffer.flip();
Packet packet=new Packet(clientBuffer);
//读取包长
int data_len=packet.readInt();
//读取命令号
int command=packet.readShort();
if(commands.containsKey(command)){
ICommand comm=commands.get(command);
int result=comm.execute(this, channel, packet);
key.attach(result);
//System.out.println("attachment "+key.attachment().getClass());
}
clientBuffer.clear();
}
}
/**
* 发送数据
* @param channel
* @param packet
* @throws IOException
*/
public int send(SelectionKey key,Packet packet) throws IOException{
return send(key,packet.byteBuffer());
}
/**
* 发送数据
* @param key
* @param buffer
* @return 发出Bytes的总长度
* @throws IOException
*/
public int send(SelectionKey key,ByteBuffer buffer) throws IOException{
SocketChannel channel = (SocketChannel) key.channel();
//发送数据的实际长度
int dataLen=buffer.limit()-buffer.remaining();
if(buffer.position()>0){
buffer.flip();
}
//发送的bytes，4为数据包的长度信息，为int型，占用4个字节
ByteBuffer bts=ByteBuffer.allocate(dataLen+4);
//写入数据包的长度
bts.putInt(dataLen);
//写入数据内容
bts.put(buffer);
if(bts.position()>0){
bts.flip();
}
int l=channel.write(bts);
bts.clear();
buffer.clear();
//注册读事件
channel.register(selector, SelectionKey.OP_READ);
//注销写事件
key.interestOps(key.interestOps()&~SelectionKey.OP_WRITE);
return l;
}
public static void main(String[] args) {
int port = 8088;
try {
NIOServer server = new NIOServer(port);
server.registerCommand(1000,new ConnectCommand());
System.out.println("listening on " + port);
server.listen();
} catch (IOException e) {
e.printStackTrace();
}
}
}
package astest;
import java.nio.channels.SocketChannel;
public interface ICommand {
public int execute(NIOServer server,SocketChannel channel,Packet packet);
public void write();
}
package astest;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
public class ConnectCommand implements ICommand {
public int execute(NIOServer server,SocketChannel channel,Packet packet){
int playerId=packet.readInt();
Iterator<Integer> iters=server.ids.iterator();
boolean sucessed=false;
while(iters.hasNext()){
int id=iters.next();
if(id==playerId){
System.out.println("此用户已连接！！！");
sucessed=true;
break;
}
}
if(!sucessed){
server.ids.add(playerId);
System.out.println("来自 "+playerId+" 连接");
try {
channel.register(server.selector,SelectionKey.OP_WRITE);
} catch (ClosedChannelException e) {
e.printStackTrace();
}
}
return 2000;
}
public void write(){
}
}
AS部分
package
{
import flash.display.Sprite;
import flash.text.TextField;
import flash.text.TextFieldType;
import flash.display.Sprite;
import flash.events.Event;
import flash.events.MouseEvent;
import flash.events.IOErrorEvent;
import flash.events.SecurityErrorEvent;
import flash.events.ProgressEvent;
/**
* ...
* @author zkpursuit
*/
[SWF(width=400,height=500)]
public class Main extends Sprite
{
private var registPanel:RegistPanel;
private var client:NetClient;
private var tf:TextField=new TextField();
public function Main()
{
stage.scaleMode = "noScale";
client = new NetClient();
client.buildConnection();
client.addEventListener(NetEvent.READED_DATA, onReadedDataHandler);
client.addEventListener(Event.CONNECT, onConnectServerHandler);
registPanel = new RegistPanel();
addChild(registPanel);
registPanel.addEventListener(NetEvent.NET_CONNECT, requestConnectServer);
tf.border = true;
tf.width = 300;
tf.height = 400;
tf.x=50;
tf.y = 50;
tf.type = TextFieldType.INPUT;
addChild(tf);
}
private function requestConnectServer(e:NetEvent):void {
var p:Packet = new Packet();
p.writeShort(1000);
p.writeInt(e.playerID);
trace(e.playerID);
client.sendPacket(p);
}
private function onConnectServerHandler(e:Event):void {
tf.appendText("已建立连接\n");
}
private function onReadedDataHandler(e:NetEvent):void {
var p:Packet=new Packet(e.bytesData);
var info:String = "---" + p.readInt() + "---" + p.readInt()+"---"+p.readString()+"\n";
tf.appendText(info);
}
}
}
package
{
import flash.display.Sprite;
import flash.events.MouseEvent;
import flash.text.TextField;
import flash.text.TextFieldType;
/**
* ...
* @author zkpursuit
*/
public class RegistPanel extends Sprite
{
private var tf:TextField;
private var bt:Button;
public function RegistPanel()
{
//this.graphics.beginFill(0xcc9933);
//this.graphics.drawRect(0, 0, 200, 200);
//this.graphics.endFill();
tf = new TextField();
tf.border = true;
tf.type = TextFieldType.INPUT;
tf.width = 100;
tf.height = 20;
addChild(tf);
bt = new Button(40, 20);
bt.x = tf.width + 10;
addChild(bt);
bt.addEventListener(MouseEvent.CLICK, onClickHandler);
}
private function onClickHandler(e:MouseEvent):void {
//if (!int(tf.text)) {
var event:NetEvent = new NetEvent(NetEvent.NET_CONNECT);
event.playerID = (int)(tf.text);
dispatchEvent(event);
//}
}
}
}
代码分别打开flex builder和eclipse,运行java服务端,然后运行as3客户端 声明：ITeye文章版权属于作者，受法律保护。没有作者书面许可不得转载。
推荐链接
|
| 返回顶楼 | |
|
发表时间：2012-06-11
as 部分没有 writeLong 和 readLong 呀。
|
| 返回顶楼 | |
