flash发送socket,java netty端部分汉字乱码

0 0

flash发送socket,java netty端部分汉字乱码5

我现在用flash使用socket发送一点简单的数字，发送嗲吗如下

socket.writeInt(frame.opcode);
			socket.writeInt(6);
			socket.writeInt(201);
			socket.writeUTFBytes("123456");
			socket.writeBytes("隐藏了");

java端使用 netty ,主要部分代码如下

NioServerSocketChannelFactory factory = new NioServerSocketChannelFactory(
				Executors.newCachedThreadPool(), Executors.newCachedThreadPool());
		ServerBootstrap bootstrap = new ServerBootstrap(factory);
		bootstrap.setPipelineFactory(new server.net.ServerPipelineFactory());
		bootstrap.bind(new InetSocketAddress("192.168.66.123",8081));
		logger.info("Ready and Listening");

ServerPipelineFactory类的代码如下:

package server.net;

import static org.jboss.netty.channel.Channels.*;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;

import server.handlers.ServerDecoder;
import server.handlers.ServerEncoder;
import server.handlers.ServerHandler;

public class ServerPipelineFactory implements ChannelPipelineFactory{
	@Override
	public ChannelPipeline getPipeline() throws Exception {
		ChannelPipeline pipeline = pipeline();
		pipeline.addLast("decoder",new ServerDecoder());
		pipeline.addLast("encoder",new ServerEncoder());
		pipeline.addLast("handler",new ServerHandler());
		return pipeline;
	}
}

其中ServerDecoder是负责解析flash传送过来的数据的，乱码就发生在这里
代码如下

package server.handlers;

import java.io.UnsupportedEncodingException;

import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.handler.codec.frame.FrameDecoder;
import org.jboss.netty.util.CharsetUtil;

import server.socketstruct.MsgBody;
import server.Server;

public class ServerDecoder extends FrameDecoder {

	@Override
	protected Object decode(ChannelHandlerContext ctx, Channel chl,
			ChannelBuffer buf) throws Exception {
		MsgBody msg=new MsgBody();
		int touserlength;//发送消息对象的人的长度
		msg.opcode=buf.readInt();
		touserlength=buf.readInt();
		msg.msgtype=buf.readInt();
		byte[] touserby=new byte[touserlength];
		for(int i = 0; i < touserby.length; i++) {
			touserby[i] = buf.readByte();
		}
		
		byte[] contentbs=new byte[buf.capacity()-12-touserlength];
		for(int i = 0; i < contentbs.length; i++) {
			contentbs[i] = buf.readByte();
			
		}
		
		String b1=new String(touserby);
		String b2=new String(contentbs);
		try {
			msg.tousers=new String(b1.getBytes(),"utf-8");
			msg.content=new String(b2.getBytes(),"utf-8");
			
		} catch (UnsupportedEncodingException e1) {
			e1.printStackTrace();
		}
		return msg;
	}
	
	@Override
	public void channelOpen(
            ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        super.channelOpen(ctx,e);
        Server.allchannelgrp.add(e.getChannel());
    }

}

msg.content就成了"隐藏??",其他汉字也是，部分乱码

netty