mina2.0-白红宇

mina2.0

阅读量：6273 次

发布时间：2019-06-22

本文共 9483 字，大约阅读时间需要 31 分钟。

package com.allinpay.mina;

import java.net.InetSocketAddress;

import org.apache.mina.filter.codec.ProtocolCodecFilter;

import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory;

import org.apache.mina.filter.executor.ExecutorFilter;

import org.apache.mina.filter.executor.OrderedThreadPoolExecutor;

import org.apache.mina.filter.logging.LoggingFilter;

import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class MyServer {

private NioSocketAcceptor acceptor;

public MyServer() {

try {

acceptor = new NioSocketAcceptor();

acceptor.getFilterChain().addLast("threadPool",

new ExecutorFilter(new OrderedThreadPoolExecutor()));// 设置线程池，以支持多线程

acceptor.getFilterChain().addLast("logger", new LoggingFilter());

// acceptor.getFilterChain().addLast(

// "codec",

// new ProtocolCodecFilter(new TextLineCodecFactory(Charset

// .forName("UTF-8"))));// 指定编码过滤器

DemuxingProtocolCodecFactory pcf = new DemuxingProtocolCodecFactory();

// 自定义编码器

pcf.addMessageEncoder(String.class, new MyMessageEncoder());

// 自定义×××

pcf.addMessageDecoder(new MyMessageDecoder());

ProtocolCodecFilter codec = new ProtocolCodecFilter(pcf);

acceptor.getFilterChain().addLast("codec", codec);// 指定编码过滤器

acceptor.setReuseAddress(true);

acceptor.setHandler(new ServerIoHandler());// 指定业务逻辑处理器

acceptor.setDefaultLocalAddress(new InetSocketAddress(10000));// 设置端口号

acceptor.bind();// 启动监听

} catch (Exception e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

new MyServer();

}

}

package com.allinpay.mina;

import org.apache.mina.core.service.IoHandler;

import org.apache.mina.core.session.IdleStatus;

import org.apache.mina.core.session.IoSession;

public class ServerIoHandler implements IoHandler {

public void exceptionCaught(IoSession session, Throwable pArg1)

throws Exception {

}

public void messageReceived(IoSession session, Object obj) throws Exception {

// 收到的信息

System.out.println(obj.toString());

}

public void messageSent(IoSession session, Object pArg1) throws Exception {

}

public void sessionClosed(IoSession session) throws Exception {

}

public void sessionCreated(IoSession session) throws Exception {

}

public void sessionIdle(IoSession session, IdleStatus pArg1)

throws Exception {

}

public void sessionOpened(IoSession session) throws Exception {

session.write("[Server: Client,I'm server.][Server: Client,I'm server.]");

}

}

package com.allinpay.mina;

import java.net.InetSocketAddress;

import java.util.Date;

import java.util.Timer;

import java.util.TimerTask;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;

import org.apache.mina.core.future.ConnectFuture;

import org.apache.mina.filter.codec.ProtocolCodecFilter;

import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory;

import org.apache.mina.filter.logging.LoggingFilter;

import org.apache.mina.transport.socket.nio.NioSocketConnector;

public class MyClient {

private NioSocketConnector connector;

public MyClient() {

connector = new NioSocketConnector();

connector.setHandler(new ClientIoHandler());

// 配置过滤器

DefaultIoFilterChainBuilder chain = connector.getFilterChain();

// 增加日志过滤器

chain.addLast("logger", new LoggingFilter());

// 增加字符编码过滤器以及设置编码器和×××

// chain.addLast("codec", new ProtocolCodecFilter(new

// TextLineCodecFactory(Charset.forName("UTF-8"))));

// acceptor.getFilterChain().addLast(

// "codec",

// new ProtocolCodecFilter(new TextLineCodecFactory(Charset

// .forName("UTF-8"))));// 指定编码过滤器

DemuxingProtocolCodecFactory pcf = new DemuxingProtocolCodecFactory();

// 自定义编码器

pcf.addMessageEncoder(String.class, new MyMessageEncoder());

// 自定义×××

pcf.addMessageDecoder(new MyMessageDecoder());

ProtocolCodecFilter codec = new ProtocolCodecFilter(pcf);

chain.addLast("codec", codec);// 指定编码过滤器

// 设置默认连接的地址和端口

connector.setDefaultRemoteAddress(new InetSocketAddress("localhost",

10000));

new Timer().schedule(new TimerTask() {

@Override

public void run() {

if (null != connector && !connector.isActive()) {

try {

// 尝试连接默认的地址和端口

ConnectFuture connFuture = connector.connect();

connFuture.awaitUninterruptibly();

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

}

}

}, new Date(), 30 * 1000);

}

public static void main(String[] args) {

new MyClient();

}

}

package com.allinpay.mina;

import org.apache.mina.core.service.IoHandler;

import org.apache.mina.core.session.IdleStatus;

import org.apache.mina.core.session.IoSession;

public class ClientIoHandler implements IoHandler {

public void exceptionCaught(IoSession session, Throwable throwable)

throws Exception {

}

public void messageReceived(IoSession session, Object obj) throws Exception {

// 收到的内容

System.out.println(obj.toString());

}

public void messageSent(IoSession session, Object obj) throws Exception {

}

public void sessionClosed(IoSession session) throws Exception {

}

public void sessionCreated(IoSession session) throws Exception {

}

public void sessionIdle(IoSession session, IdleStatus status)

throws Exception {

}

public void sessionOpened(IoSession session) throws Exception {

session.write("[Client: Server,I'm client.][Client: Server,I'm client.]");

}

}

package com.allinpay.mina;

import org.apache.mina.core.buffer.IoBuffer;

import org.apache.mina.core.session.IoSession;

import org.apache.mina.filter.codec.ProtocolDecoderOutput;

import org.apache.mina.filter.codec.demux.MessageDecoder;

import org.apache.mina.filter.codec.demux.MessageDecoderResult;

public class MyMessageDecoder implements MessageDecoder {

// // 消息的开始

// private int flag = 0;

// // 消息的长度

// private int length = 0;

// // 消息的结尾

// private int flaglast = 0;

// // 不是第一条消息

// private boolean notfirstmessage = false;

// public MessageDecoderResult decodable(IoSession session, IoBuffer in) {

// int rem = in.remaining();

// int fornumber;

// byte aa;

// if (notfirstmessage) {

// flag++;

// fornumber = rem + flag;

// } else {

// flag = 0;

// fornumber = rem + flag;

// }

// try {

// for (int i = flag; i < fornumber; i++) {

// aa = in.get(i);

// if (']' == aa) {

// flaglast = flag;

// flag = i;

// length = flag - flaglast;

// notfirstmessage = true;

// return MessageDecoderResult.OK;

// }

// }

// } catch (Exception e) {

// e.printStackTrace();

// }

// notfirstmessage = false;

// return MessageDecoderResult.NEED_DATA;

// }

// public MessageDecoderResult decode(IoSession session, IoBuffer in,

// ProtocolDecoderOutput out) throws Exception {

// try {

// if (length == 0 || length == 1) {

// in.get();

// out.write("");

// return MessageDecoderResult.OK;

// }

// length++;

// byte[] result = new byte[length];

// for (int i = 0; i < length; i++) {

// result[i] = in.get();

// }

// if (0 == in.remaining()) {

// notfirstmessage = false;

// }

// String cont = new String(result, "us-ascii");

// out.write(cont.trim());

// return MessageDecoderResult.OK;

// } catch (Exception e) {

// e.printStackTrace();

// }

// return MessageDecoderResult.OK;

// }

public void finishDecode(IoSession session, ProtocolDecoderOutput out)

throws Exception {

}

public MessageDecoderResult decodable(IoSession session, IoBuffer in) {

String string = MinaUtil.ioBufferToString(in);

if(null==string || "".equals(string)){

return MessageDecoderResult.NEED_DATA;

}

return MessageDecoderResult.OK;

}

public MessageDecoderResult decode(IoSession session, IoBuffer in,

ProtocolDecoderOutput out) throws Exception {

String string = MinaUtil.ioBufferToString(in);

out.write(string);

return MessageDecoderResult.OK;

}

}

package com.allinpay.mina;

import org.apache.mina.core.buffer.IoBuffer;

import org.apache.mina.core.session.IoSession;

import org.apache.mina.filter.codec.ProtocolEncoderOutput;

import org.apache.mina.filter.codec.demux.MessageEncoder;

public class MyMessageEncoder implements MessageEncoder<String> {

public void encode(IoSession session, String msg, ProtocolEncoderOutput out)

throws Exception {

IoBuffer buf = IoBuffer.allocate(msg.getBytes().length);

buf.put(msg.getBytes());

buf.flip();

out.write(buf);

}

}

package com.allinpay.mina;

import org.apache.mina.core.buffer.IoBuffer;

* MINA中IoBuffer、byte[]、String之间转换

* @author huangyh1

public class MinaUtil {

* 将byte[]转换成string

* @param butBuffer

public static String byteToString(byte [] b)

{

StringBuffer stringBuffer = new StringBuffer();

for (int i = 0; i < b.length; i++)

{

stringBuffer.append((char) b [i]);

}

return stringBuffer.toString();

}

* 将bytebuffer转换成string

* @param str

public static IoBuffer stringToIoBuffer(String str)

{

byte bt[] = str.getBytes();

IoBuffer ioBuffer = IoBuffer.allocate(bt.length);

ioBuffer.put(bt, 0, bt.length);

ioBuffer.flip();

return ioBuffer;

}

* 将IoBuffer转换成string

* @param str

public static IoBuffer byteToIoBuffer(byte [] bt,int length)

{

IoBuffer ioBuffer = IoBuffer.allocate(length);

ioBuffer.put(bt, 0, length);

ioBuffer.flip();

return ioBuffer;

}

* 将IoBuffer转换成byte

* @param str

public static byte [] ioBufferToByte(Object message)

{

if (!(message instanceof IoBuffer))

{

return null;

}

IoBuffer ioBuffer = (IoBuffer)message;

byte[] b = new byte[ioBuffer.limit()];

ioBuffer.get(b);

return b;

}

* 将IoBuffer转换成string

* @param butBuffer

public static String ioBufferToString(Object message)

{

if (!(message instanceof IoBuffer))

{

return "";

}

IoBuffer ioBuffer = (IoBuffer) message;

byte[] b = new byte [ioBuffer.limit()];

ioBuffer.get(b);

StringBuffer stringBuffer = new StringBuffer();

for (int i = 0; i < b.length; i++)

{

stringBuffer.append((char) b [i]);

}

return stringBuffer.toString();

}

}

转载于:https://blog.51cto.com/steveskylook/760920

你可能感兴趣的文章

httpd – 对Apache的DFOREGROUND感到困惑

查看>>

分布式锁的一点理解

查看>>

idea的maven项目,install下载重复下载本地库中已有的jar包,而且下载后jar包都是lastupdated问题...

查看>>

2019测试指南-web应用程序安全测试（二）指纹Web服务器

5-4 8 管道符作业控制 shell变量环境变量配置

查看>>

Enumberable

查看>>

开发者论坛一周精粹(第五十四期) 求购备案服务号1枚！

javascript 中出现missing ) after argument list的错误

查看>>

RSA 加密解密

查看>>

Cause: org.apache.ibatis.ognl.ExpressionSyntaxException: Malformed OGNL expression:......

查看>>