Mina自定义编解码
協(xié)議編解碼器是在使用Mina 的時候你最需要關(guān)注的對象，因為在網(wǎng)絡(luò)傳輸?shù)臄?shù)據(jù)都是二進制數(shù)據(jù)（byte），而你在程序中面向的是JAVA 對象，這就需要你實現(xiàn)在發(fā)送數(shù)據(jù)時將JAVA 對象編碼二進制數(shù)據(jù)，而接收數(shù)據(jù)時將二進制數(shù)據(jù)解碼為JAVA 對象（這個可不是JAVA 對象的序列化、反序列化那么簡單的事情）
Mina 中的協(xié)議編解碼器通過過濾器ProtocolCodecFilter 構(gòu)造，這個過濾器的構(gòu)造方法需要一個ProtocolCodecFactory,
ProtocolCodecFactory 中有如下兩個方法：
public interface ProtocolCodecFactory {
ProtocolEncoder getEncoder(IoSession session) throws Exception;
ProtocolDecoder getDecoder(IoSession session) throws Exception;
}
ProtocolEncoder是自定義編碼器要實現(xiàn)的接口，ProtocolDecoder是自定義解碼器要實現(xiàn)的接口。
下面是示例代碼：（模擬手機信息的編解碼，消息格式；有報頭，發(fā)送人，接收人，內(nèi)容長度，內(nèi)容信息）
MsgObject.java: 消息實體類
1 public class MsgObject {
2 //發(fā)送者
3 private String sender;
4 //接收者
5 private String receiver;
6 //信息內(nèi)容
7 private String content;
8
9 public String getSender() {
10 return sender;
11 }
12
13 public void setSender(String sender) {
14 this.sender = sender;
15 }
16
17 public String getReceiver() {
18 return receiver;
19 }
20
21 public void setReceiver(String receiver) {
22 this.receiver = receiver;
23 }
24
25 public String getContent() {
26 return content;
27 }
28
29 public void setContent(String content) {
30 this.content = content;
31 }
32
33 }
MessageEncoder.java: 消息編碼器
1 //消息編碼器
2 public class MessageEncoder extends ProtocolEncoderAdapter {
3 private Charset charset;
4
5 public MessageEncoder(Charset charset)
6 {
7 this.charset = charset;
8 }
9
10 @Override
11 public void encode(IoSession arg0, Object arg1, ProtocolEncoderOutput arg2)
12 throws Exception {
13 MsgObject msg = (MsgObject) arg1;
14 //生成字符編碼器
15 CharsetEncoder charsetEncoder = charset.newEncoder();
16 //得到要發(fā)送對象屬性內(nèi)容，準(zhǔn)備進行編碼
17 String status = "M sip:wap.fetion.com.cn SIP-C/2.0";
18 String sender = msg.getSender();
19 String receiver = msg.getReceiver();
20 String content = msg.getContent();
21 //開辟一個緩存空間，設(shè)置為自動調(diào)整大小
22 IoBuffer ioBuffer = IoBuffer.allocate(100);
23 ioBuffer.setAutoExpand(true);
24 //將要發(fā)送的信息放入緩存空間
25 //消息頭
26 ioBuffer.putString(status + "\n", charsetEncoder);
27 //消息發(fā)送者
28 ioBuffer.putString("S: " + sender + "\n", charsetEncoder);
29 //消息接收者
30 ioBuffer.putString("R: " + receiver + "\n", charsetEncoder);
31 //消息內(nèi)容長度
32 ioBuffer.putString("L: " + content.getBytes(charset).length + "\n", charsetEncoder);
33 //消息內(nèi)容
34 ioBuffer.putString(content + "\n", charsetEncoder);
35 //編碼后的信息已放入ioBuffer中，進行寫回
36 ioBuffer.flip();
37 arg2.write(ioBuffer);
38 }
39
40 }
MessageDecoder.java: 消息解碼器
1 //消息解碼器
2 public class MessageDecoder extends CumulativeProtocolDecoder {
3 private Charset charset;
4
5 public MessageDecoder(Charset charset) {
6 this.charset = charset;
7 }
8
9 @Override
10 protected boolean doDecode(IoSession arg0, IoBuffer arg1,
11 ProtocolDecoderOutput arg2) throws Exception {
12 CharsetDecoder charDecoder = charset.newDecoder();
13 IoBuffer buffer = IoBuffer.allocate(100).setAutoExpand(true);
14 // 接收解碼后的信息
15 String status = "";
16 String sender = "";
17 String receiver = "";
18 String contentLen = "";
19 String content = "";
20
21 int textLineNumber = 1;
22 int columnNumber = 0;
23 // 如果緩存區(qū)還有消息
24 while (arg1.hasRemaining()) {
25 byte bt = arg1.get();
26 buffer.put(bt);
27 //換行
28 if (bt == 10 && textLineNumber < 5) {
29 columnNumber++;
30 if (textLineNumber == 1) {
31 buffer.flip();
32 status = buffer.getString(columnNumber, charDecoder);
33 status = status.substring(0, status.length() - 1);
34 columnNumber = 0;
35 buffer.clear();
36 }
37 if (textLineNumber == 2) {
38 buffer.flip();
39 sender = buffer.getString(columnNumber, charDecoder);
40 sender = sender.substring(0, sender.length() - 1);
41 columnNumber = 0;
42 buffer.clear();
43 }
44 if (textLineNumber == 3) {
45 buffer.flip();
46 receiver = buffer.getString(columnNumber, charDecoder);
47 receiver = receiver.substring(0, receiver.length() - 1);
48 columnNumber = 0;
49 buffer.clear();
50 }
51 if (textLineNumber == 4) {
52 buffer.flip();
53 contentLen = buffer.getString(columnNumber, charDecoder);
54 contentLen = contentLen.substring(0,
55 contentLen.length() - 1);
56 columnNumber = 0;
57 buffer.clear();
58 }
59 textLineNumber++;
60 } else if (textLineNumber == 5) {
61 columnNumber++;
62 if (columnNumber == Long.parseLong(contentLen.split(": ")[1])) {
63 buffer.flip();
64 content = buffer.getString(columnNumber, charDecoder);
65 textLineNumber++;
66 break;
67 }
68 } else {
69 columnNumber++;
70 }
71
72 }
73 MsgObject smsObject = new MsgObject();
74 smsObject.setSender(sender.split(": ")[1]);
75 smsObject.setReceiver(receiver.split(": ")[1]);
76 smsObject.setContent(content);
77 arg2.write(smsObject);
78 return false;
79 }
80 }
關(guān)于IoBuffer的讀操作，需要了解一下原理，可參考文章：Mina框架研究（2）
MessageProtocolCodecFactory.java:生成消息編解碼器工廠
1 //編解碼器生成工產(chǎn)
2 public class MessageProtocolCodecFactory implements ProtocolCodecFactory {
3 private ProtocolEncoder encoder;
4 private ProtocolDecoder decoder;
5
6 public MessageProtocolCodecFactory()
7 {
8 this(Charset.forName("UTF-8"));
9 }
10
11 public MessageProtocolCodecFactory(Charset charset)
12 {
13 encoder = new MessageEncoder(charset);
14 decoder = new MessageDecoder(charset);
15 }
16
17 @Override
18 public ProtocolDecoder getDecoder(IoSession arg0) throws Exception {
19 return decoder;
20 }
21
22 @Override
23 public ProtocolEncoder getEncoder(IoSession arg0) throws Exception {
24 return encoder;
25 }
26
27 }
接著就是調(diào)用這些編解碼器來進行對象的傳輸了，服務(wù)器端和客戶端的主程序編寫可參考Mina框架HelloWorld入門
溫馨提示：
上面的消息解碼器(MessageDecoder.java)中的解碼考慮的情況是消息一次性從服務(wù)器發(fā)送過來，但有時消息可能不是一次性從服務(wù)器發(fā)送過來，而是分成了幾次分批過來，這時就會重復(fù)調(diào)用解碼器的deCode()方法，這時狀態(tài)變量textLineNumber和columnNumber就會被重置，所以要把狀態(tài)變量保存起來?？赡苣銜氲綄顟B(tài)變量保存在解碼器的成員變量中，但是Mina不保證每次調(diào)用deCode()方法的都是同一個線程，所以狀態(tài)變量不是線程安全的。所以要將狀態(tài)變量保存到IoSession中,因為IoSession用了一個同步的HashMap保存對象。
在IoSession中保存狀態(tài)變量:
// 保存數(shù)據(jù)狀態(tài)對象的key值
private final AttributeKey CONTEXT = new AttributeKey(getClass(), "context");
通過IoSession.setAttribute和IoSession.getAttribute的保存和得到保存數(shù)據(jù)的對象
如下：
1 private MsgContext getContext(IoSession session) {
2 MsgContext context = (MsgContext) session.getAttribute(CONTEXT);
3 if (null == context) {
4 context = new MsgContext();
5 session.setAttribute(CONTEXT, context);
6 }
7 return context;
8 }
一顆平常心，踏踏實實，平靜對待一切
總結(jié)
以上是生活随笔為你收集整理的Mina自定义编解码的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： pdvmoo手机是什么型号
- 下一篇： 百分之3怎么算