【sharpsocket】分享C# socket网络编程tcp udp都支持收发任意数据

【实例截图】

【核心代码】

using System;
using System.Windows.Forms;
using System.Net;
using CoreDll;
using SharpSocket;
using SharpSocket.Interface;

namespace UDPServer
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();            
        }

        #region 变量
        private IUdp udpServerInstance = null;
        #endregion

        #region UI事件
        private void Form1_Load(object sender, EventArgs e)
        {
            #region 设置授权,试用版直接使用Test即可。正式授权请访问http://sharpsocket.zzsgzn.com
            KeyMgr.SetKey("Test", "Test");
            #endregion
        }

        private void btnStart_Click(object sender, EventArgs e)
        {
            try
            {
                //创建一个接口实例，然后就可以操作它了
                udpServerInstance = SocketFactory.GetUdp();

                //设置本端使用的端口号
                udpServerInstance.Port = int.Parse(this.edtPort.Text);

                //订阅本接口的收到数据的事件通知，当收到数据后，自动回调您注册的方法
                udpServerInstance.MessageReceived  = new SGDelegate<IPEndPoint, byte[]>(MessageReceived);

                //启动即可
                udpServerInstance.Initialize();

                lblStatus.Text = "已启动...";

                //显示
                lblStatusPort.Text = udpServerInstance.Port.ToString();

                edtPort.Enabled = false;
                btnStart.Enabled = false;
            }
            catch (Exception ee)
            {
                MessageBox.Show(ee.Message);
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
            System.Diagnostics.Process.Start("http://sharpsocket.zzsgzn.com");
        }

        private void button2_Click(object sender, EventArgs e)
        {
            System.Diagnostics.Process.Start("http://www.zzsgzn.com");
        }

        private void button3_Click(object sender, EventArgs e)
        {
            System.Diagnostics.Process.Start("http://wpa.qq.com/msgrd?v=3&uin=3535600244&site=qq&menu=yes");
        }
        #endregion

        #region IUDP的事件
        private void MessageReceived(IPEndPoint client, byte[] bMsg)
        {
            #region 获取消息类型,消息类型是 从offset=4处开始 的一个int值
            int msgType = BitConverter.ToInt32(bMsg, 4);
            #endregion

            #region 解析消息体
            RequestFormat request = (RequestFormat)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 = "错误的操作类型";
            }
            #endregion

            #region 显示请求
            string msg = string.Format("请求类型：{0}，操作数1：{1}，操作数2：{2}", operationType, request.Number1 , request.Number2);
            ShowStr(client, msg);
            #endregion

            #region 回复消息体
            ResponseFormat response = new ResponseFormat(request.Number1, request.Number2, operationType, result);
            byte[] bReponse = SerializeHelper.SerializeObject(response); 
            #endregion

            #region 回复消息头
            MessageHead head = new MessageHead(bReponse.Length, MessageType.Result);
            byte[] bHead = head.ToStream();
            #endregion

            #region 构建回复消息
            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);
            #endregion

            #region 发送回复消息
            udpServerInstance.SendData(client, resMessage);
            #endregion
        }

        #endregion


        #region 功能
        private void ShowStr(IPEndPoint client, string msg)
        {
            if (this.InvokeRequired)
            {
                this.BeginInvoke(new SGDelegate<IPEndPoint, string>(ShowStr), client, msg);
            }
            else
            {
                ListViewItem item = new ListViewItem(new string[] { DateTime.Now.ToString(), client.ToString(), msg });
                this.listView1.Items.Insert(0, item);
            }
        }

        #endregion

        
    }

}