Socket框架 c# 搭建简单的通讯服务器

时间:2019-01-19
本文章向大家介绍Socket框架 c# 搭建简单的通讯服务器,主要包括Socket框架 c# 搭建简单的通讯服务器使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

服务器端:

using System;
using System.Text;
using System.Net.Sockets;
using System.Net;

namespace TCPClient
{
    class Program
    {
        static void Main(string[] args)
        {
            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            clientSocket.Connect(new IPEndPoint(IPAddress.Parse("xxx.xxx.xxx.xxx"), 88));//建立连接
            byte[] data = new byte[1024];
            int count = clientSocket.Receive(data);
            string msg = Encoding.UTF8.GetString(data, 0, count);//转换数据
            Console.Write(msg);
            while (true)
            {
                string s = Console.ReadLine();
                if (s == "c")
                {
                    clientSocket.Close();
                    return;
                }
                clientSocket.Send(Encoding.UTF8.GetBytes(s));//需要转换编码格式
            }
            Console.ReadKey();
            clientSocket.Close();
        }
    }
}

客户端:

//本机xxx.xxx.xxx.xxx
using System.Net.Sockets;
using System.Net;
using System.Text;
using System;

namespace ServiceTerminal
{
    class Program
    {
        static void Main(string[] args)
        {
            StartServerAsync();
            Console.ReadKey();
        }
        static void StartServerAsync()//异步
        {
            Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//寻址方案,类型,协议
            IPAddress ipAddress = IPAddress.Parse("xxx.xxx.xxx.xxx");//绑定IP
            IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 88);//绑定端口号
            serverSocket.Bind(ipEndPoint);//绑定ip和端口号
            serverSocket.Listen(0);//挂起客户端数量队列为 0==无限 监听
            serverSocket.BeginAccept(AcceptCallBack, serverSocket);//异步等待客户端连接
        }
        static void AcceptCallBack(IAsyncResult ar)
        {
            Socket serverSocket = ar.AsyncState as Socket;
            Socket clientSocket = serverSocket.EndAccept(ar);
            string msg = "Hello Client!";
            byte[] data = Encoding.UTF8.GetBytes(msg);//根据UTF8转换编码格式
            clientSocket.Send(data);//向客户端发送消息
            clientSocket.BeginReceive(dataBuffer, 0, 1024, SocketFlags.None, ReceiveCallBack, clientSocket);//异步进行接受数据
            serverSocket.BeginAccept(AcceptCallBack, serverSocket);//递归 
        }
        static byte[] dataBuffer = new byte[1024];//设置数组最大字节
        static void ReceiveCallBack(IAsyncResult ar)
        {
            Socket clientSocket = null;
            try
            {
                clientSocket = ar.AsyncState as Socket;
                int count = clientSocket.EndReceive(ar);
                if (count == 0)//处理正常关闭情况
                {
                    clientSocket.Close();
                    return;
                }
                string msg = Encoding.UTF8.GetString(dataBuffer, 0, count);
                Console.WriteLine("从客户端接收到数据:" + count + msg);
                clientSocket.BeginReceive(dataBuffer, 0, 1024, SocketFlags.None, ReceiveCallBack, clientSocket);//回调 可再次接收消息
            }
            catch (Exception e)//处理非正常关闭情况
            {
                Console.WriteLine(e);
                if (clientSocket != null)
                {
                    clientSocket.Close();
                }
            }
        }
        static void StartServerSync()//同步
        {
            Socket serverSocker = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//寻址方案,类型,协议
            IPAddress ipAddress = IPAddress.Parse("10.0.117.245");//绑定IP
            IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 88);//绑定端口号
            serverSocker.Bind(ipEndPoint);//绑定ip和端口号
            serverSocker.Listen(0);//挂起客户端数量队列为 0==无限 监听
            serverSocker.Accept();//接收端口 代码到在这里会暂停 直到有客户端连入
            Socket clientSocket = serverSocker.Accept();//接受一个客户端连接
            string msg = "Hello Client!";
            byte[] data = Encoding.UTF8.GetBytes(msg);//根据UTF8转换编码格式
            clientSocket.Send(data);//向客户端发送消息
            byte[] dataBuffer = new byte[1024];//创建接受数据的数组大小
            int count = clientSocket.Receive(dataBuffer);//接收消息
            string msgReceive = Encoding.UTF8.GetString(dataBuffer, 0, count);//从dataBuffer数组中的0号位置开始 读取count个字节的数据 根据UTF8转换编码格式
            Console.WriteLine(msgReceive);
            clientSocket.Close();//关闭与客户端的连接
            serverSocker.Close();//关闭服务端
        }
    }
}