一个简单的自定义通信协议（socket）

一直不知道socket通信时候自定义数据包是什么样子的，偶然做了个小例子。

?

先来说说数据包的定义，我这里是包头+内容 组成的：其中包头内容分为包类型+包长度， 那就是 消息对象=包类型+包长度+消息体

?

包类型 byte 型

包长度 int 型

消息体 byte[]

?

包总长度为 1 + 4 +??消息体.getBytes().length

?

发包方法如下：

private void sendTextMsg(DataOutputStream out,String msg ) throws IOException {byte[] bytes= msg.getBytes();int totalLen = 1 + 4 + bytes.length;                                out.writeByte(1);out.writeInt(totalLen);out.write(bytes);out.flush();}

?

?

客户端发送消息类为：

?

import java.io.DataOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.Socket;import java.net.UnknownHostException;import java.util.Scanner;public class MsgClient {private DataOutputStream outs;public static void main(String[] args) {try {MsgClient client = new MsgClient();client.connServer("127.0.0.1", 9292);} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}private void sendTextMsg(DataOutputStream out,String msg ) throws IOException {byte[] bytes= msg.getBytes();int totalLen = 1 + 4 + bytes.length;        out.writeByte(1);out.writeInt(totalLen);out.write(bytes);out.flush();}public void connServer(String ip,int port) throws UnknownHostException, IOException {Socket client = new Socket(ip,port);InputStream in = client.getInputStream();OutputStream out = client.getOutputStream();outs = new DataOutputStream(out);while(true) {Scanner scaner = new Scanner(System.in);sendTextMsg(outs, "测试消");}}

?

?

服务端接收类为：

?

import java.io.DataInputStream;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;public class MsgServer {public static void main(String[] args) {try {MsgServer server = new MsgServer();server.setUpServer(9090);} catch (IOException e) {e.printStackTrace();}}public void setUpServer(int port) throws IOException {ServerSocket server = new ServerSocket(port);while(true) {Socket client = server.accept();System.out.println("客户端IP："+client.getRemoteSocketAddress());processMesage(client);}}private void processMesage(Socket client) throws IOException {InputStream ins = client.getInputStream();DataInputStream dins = new DataInputStream(ins);//服务端解包过程while(true) {int totalLen = dins.readInt();byte flag = dins.readByte();System.out.println("接收消息类型"+flag);byte[] data = new byte[totalLen - 4 - 1];dins.readFully(data);String msg = new String(data);System.out.println("发来的内容是:"+msg);}}}

?

?

?

这样就基本完成了，但实际还有好多问题，比如说服务端用如何用多线程服务来完成客户端的请求已提高效率，如果是NIO方式怎么来实现？多个消息类型时候怎么抽象？这些都没有考虑

?

另外有两个开源的框架不错，一个是apache? mina 还有个是netty ，有机会试试。

?

?

?

?

?

?

?