当前访客身份:游客 [ 登录  | 注册加入尚学堂]
直播

你在哪儿呀

拥有积分:3
这家伙太懒,还没有签名!

博客分类

笔记中心

课题中心

提问中心

答题中心

解答题中心

java apache mina 2.0 发送和接收 字节数组 byte[]

你在哪儿呀 发表于 2年前 (2014-09-27 11:19:07)  |  评论(1)  |  阅读次数(1825)| 0 人收藏此文章,   我要收藏   
java apache mina 2.0 发送和接收 字节数组 byte[]
2011-06-22 11:22

客户端:

public class ByteClient
{
    
    public static void main(String[] args) throws InterruptedException {  

        byte [] message="aaaaaaaaaaaaa".getBytes();
        try {
            MinaClient.sendMessage("127.0.0.1:8800", message);
          

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    }

MinaClient:

import java.net.InetSocketAddress;
import java.nio.charset.Charset;

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

public class MinaClient {
 
 static ConnectFuture cf=null;
 /**
  * 创建连接
  * @param address
  * @param port
  */
 static void getconnect(String address,int port){
  NioSocketConnector connector = new NioSocketConnector();
  connector.getFilterChain().addLast("logger", new LoggingFilter());
  connector.getFilterChain().addLast(
    "codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8")))); // 设置编码过滤器
  connector.setConnectTimeout(300);
  connector.setHandler(new ClientHandler());// 设置事件处理器
  cf = connector.connect(new InetSocketAddress(address,port));// 建立连接
 }
 /**
  * 发送报文
  * @param serviceAddress
  * @param message
  * @throws Exception
  */
 public static void sendMessage(String serviceAddress,byte[] message) throws Exception{
  String[] address = serviceAddress.split(":");
  int port =0;
  try {
   port = Integer.valueOf(address[1]);
  } catch (NumberFormatException e) {
   e.printStackTrace();
   throw new Exception("服务器地址错误!");
  }
  if(cf==null){
   getconnect(address[0],port);
  }

  cf.awaitUninterruptibly();// 等待连接创建完成  
  cf.getSession().write(IoBuffer.wrap(message));// 发送消息 这里是发送字节数组的重点
  cf.getSession().getCloseFuture().awaitUninterruptibly();// 等待连接断开
 }
 
    /**
     * 发送报文String
     * @param serviceAddress
     * @param message
     * @throws Exception
     */
    public static void sendMessage(String serviceAddress,String message) throws Exception{
        String[] address = serviceAddress.split(":");
        int port =0;
        try {
            port = Integer.valueOf(address[1]);
        } catch (NumberFormatException e) {
            e.printStackTrace();
            throw new Exception("服务器地址错误!");
        }
        if(cf==null){
            getconnect(address[0],port);
        }
        cf.awaitUninterruptibly();// 等待连接创建完成
        cf.getSession().write(message);// 发送消息
        cf.getSession().getCloseFuture().awaitUninterruptibly();// 等待连接断开
    }
 
 /**
  * 回复报文
  * @param serviceAddress
  * @param message
  * @throws Exception
  */
 public static void returnMessage(String serviceAddress,String message) throws Exception{
  String[] address = serviceAddress.split(":");
  int port =0;
  try {
   port = Integer.valueOf(address[1]);
  } catch (NumberFormatException e) {
   e.printStackTrace();
   throw new Exception("服务器地址错误!");
  }
  if(cf==null){
   getconnect(address[0],port);
  }
  cf.awaitUninterruptibly();// 等待连接创建完成
  cf.getSession().write(message);// 发送消息
  cf.getSession().getCloseFuture().awaitUninterruptibly();// 等待连接断开
 }
}

服务端:

 /**
  * 创建byte处理服务器
  * @param port端口号 time超时时间
  * @throws IOException
  */
 public static void startByteService(int port,int time) throws IOException{
  // 创建服务器监听
  IoAcceptor acceptor = new NioSocketAcceptor();
  // 增加日志过滤器
  acceptor.getFilterChain().addLast("logger", new LoggingFilter());

//这里不添加字符编码过滤器
  // 指定业务逻辑处理器
  acceptor.setHandler(new byteServerHandler());
  // 设置buffer的长度
  acceptor.getSessionConfig().setReadBufferSize(2048);
  // 设置连接超时时间
  acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, time);
  // 绑定端口
  acceptor.bind(new InetSocketAddress(port));
  System.out.println("服务器在端口:"+port+"已经启动");
 }

byteServerHandler:

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

/**
 * 自定义的消息处理器,必须实现IoHandlerAdapter类
 * @author 何明
 *
 */
public class byteServerHandler extends IoHandlerAdapter{

 private int count = 0;
 
 /**
  * 当一个客户端连接进入时
  */
 @Override
 public void sessionOpened(IoSession session) throws Exception {

  System.out.println("incoming client: " + session.getRemoteAddress());

 }

 /**
  * 当一个客户端关闭时
  */
 @Override
 public void sessionClosed(IoSession session) throws Exception {

  System.out.println(session.getRemoteAddress() + "is Disconnection");

 }

 @Override
 public void messageReceived(IoSession session, Object message)
   throws Exception {

       IoBuffer ioBuffer = (IoBuffer)message;   
       byte[] b = new byte[ioBuffer.limit()];   
       ioBuffer.get(b);  
     
  String msg=new String(b);

  System.out.println("收到客户端发来的消息为" + "  " + msg);
  
  //将测试消息会送给客户端
  //session.write(str + count);
 }

}

运行结果:

服务器在端口:8800已经启动
incoming client: /127.0.0.1:1353
收到客户端发来的消息长度为  13
收到客户端发来的消息为  aaaaaaaaaaaaa

分享到:0
关注微信,跟着我们扩展技术视野。每天推送IT新技术文章,每周聚焦一门新技术。微信二维码如下:
微信公众账号:尚学堂(微信号:bjsxt-java)
声明:博客文章版权属于原创作者,受法律保护。如果侵犯了您的权利,请联系管理员,我们将及时删除!
(邮箱:webmaster#sxt.cn(#换为@))
北京总部地址:北京市海淀区西三旗桥东建材城西路85号神州科技园B座三层尚学堂 咨询电话:400-009-1906 010-56233821
Copyright 2007-2015 北京尚学堂科技有限公司 京ICP备13018289号-1 京公网安备11010802015183