public class MessageHead{public const int HeadLength = 8;public MessageHead() { }public MessageHead(int bodyLen, int msgType){this.bodyLength = bodyLen;this.messageType = msgType;}private int bodyLength;/// <summary>/// 消息体长度/// </summary>public int BodyLength{get { return bodyLength; }set { bodyLength = value; }}private int messageType;/// <summary>/// 消息类型/// </summary>public int MessageType{get { return messageType; }set { messageType = value; }}public byte[] ToStream(){byte[] buff = new byte[MessageHead.HeadLength];byte[] bodyLenBuff = BitConverter.GetBytes(this.bodyLength) ;byte[] msgTypeBuff = BitConverter.GetBytes(this.messageType) ;Buffer.BlockCopy(bodyLenBuff,0,buff,0,bodyLenBuff.Length) ;Buffer.BlockCopy(msgTypeBuff,0,buff,4,msgTypeBuff.Length) ;return buff;}}

    public static class MessageType{/// <summary>/// 加法请求/// </summary>public const int Add = 0;/// <summary>/// 乘法请求/// </summary
        public const int Multiple = 1;/// <summary>/// 运算结果回复/// </summary
        public const int Result = 2;        }

    [Serializable]public class RequestContract{public RequestContract() { }public RequestContract(int num1, int num2){this.number1 = num1;this.number2 = num2;}private int number1;/// <summary>/// 运算的第一个数。/// </summary>public int Number1{get { return number1; }set { number1 = value; }}private int number2;/// <summary>/// 运算的第二个数。/// </summary>public int Number2{get { return number2; }set { number2 = value; }}}[Serializable]public class ResponseContract{public ResponseContract() { }public ResponseContract(int num1, int num2 ,string opType,int res){this.number1 = num1;this.number2 = num2;this.operationType = opType;this.result = res;}private int number1;/// <summary>/// 运算的第一个数。/// </summary>public int Number1{get { return number1; }set { number1 = value; }}private int number2;/// <summary>/// 运算的第二个数。/// </summary>public int Number2{get { return number2; }set { number2 = value; }}private string operationType;/// <summary>/// 运算类型。/// </summary>public string OperationType{get { return operationType; }set { operationType = value; }}private int result;/// <summary>/// 运算结果。/// </summary>public int Result{get { return result; }set { result = value; }}}

void tcpServerEngine_MessageReceived(IPEndPoint client, byte[] bMsg)
{//获取消息类型int msgType = BitConverter.ToInt32(bMsg, 4);//消息类型是 从offset=4处开始 的一个整数//解析消息体RequestContract request = (RequestContract)SerializeHelper.DeserializeBytes(bMsg, MessageHead.HeadLength, bMsg.Length - MessageHead.HeadLength); int result = 0;string operationType = "";if (msgType == MessageType.Add){result = request.Number1 + request.Number2;operationType = "加法";}else if (msgType == MessageType.Multiple){result = request.Number1 * request.Number2;operationType = "乘法";}else{operationType = "错误的操作类型";}//显示请求string record = string.Format("请求类型：{0}，操作数1：{1}，操作数2：{2}", operationType, request.Number1 , request.Number2);this.ShowClientMsg(client, record);//回复消息体ResponseContract response = new ResponseContract(request.Number1, request.Number2, operationType, result);byte[] bReponse = SerializeHelper.SerializeObject(response);      //回复消息头MessageHead head = new MessageHead(bReponse.Length, MessageType.Result);byte[] bHead = head.ToStream();//构建回复消息byte[] resMessage = new byte[bHead.Length + bReponse.Length];Buffer.BlockCopy(bHead, 0, resMessage, 0, bHead.Length);Buffer.BlockCopy(bReponse, 0, resMessage, bHead.Length, bReponse.Length);//发送回复消息this.tcpServerEngine.PostMessageToClient(client, resMessage);
}

    private void button1_Click(object sender, EventArgs e){this.label_result.Text = "-";int msgType = this.comboBox1.SelectedIndex == 0 ? MessageType.Add : MessageType.Multiple;//请求消息体RequestContract contract = new RequestContract(int.Parse(this.textBox1.Text), int.Parse(this.textBox2.Text));            byte[] bBody = SerializeHelper.SerializeObject(contract);//消息头MessageHead head = new MessageHead(bBody.Length,msgType) ;byte[] bHead = head.ToStream();//构建请求消息byte[] reqMessage = new byte[bHead.Length + bBody.Length];Buffer.BlockCopy(bHead, 0, reqMessage, 0, bHead.Length);Buffer.BlockCopy(bBody, 0, reqMessage, bHead.Length, bBody.Length);//发送请求消息this.tcpPassiveEngine.PostMessageToServer(reqMessage);}

    void tcpPassiveEngine_MessageReceived(System.Net.IPEndPoint serverIPE, byte[] bMsg){//获取消息类型int msgType = BitConverter.ToInt32(bMsg, 4);//消息类型是 从offset=4处开始 的一个整数if (msgType != MessageType.Result){return;}//解析消息体ResponseContract response = (ResponseContract)SerializeHelper.DeserializeBytes(bMsg, MessageHead.HeadLength, bMsg.Length - MessageHead.HeadLength);string result = string.Format("{0}与{1}{2}的答案是 {3}" ,response.Number1,response.Number2,response.OperationType,response.Result);this.ShowResult(result);}