频道栏目
首页 > 程序开发 > 软件开发 > C# > 正文
C#实现Socket通信
2011-11-24 13:44:50           
收藏   我要投稿

 

1、     首先打开VS新建两个控制台应用程序:ConsoleApplication_socketServer和ConsoleApplication_socketClient。

 

2、     在ConsoleApplication_socketClient中输入以下代码:

 

using System; 

using System.Collections.Generic; 

using System.Linq; 

using System.Text; 

using System.Net; 

using System.Net.Sockets;  

 

namespace ConsoleApplication_socketClient 

    class Program 

    { 

        static Socket clientSocket;  

        static void Main(string[] args) 

        { 

            //将网络端点表示为IP地址和端口 用于socket侦听时绑定    

            IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("*.*.*.*"), 3001); //填写自己电脑的IP或者其他电脑的IP,如果是其他电脑IP的话需将ConsoleApplication_socketServer工程放在对应的电脑上。  

            clientSocket = new Socket(ipep.AddressFamily,SocketType.Stream,ProtocolType.Tcp);    

            //将Socket连接到服务器    

            try 

            { 

                clientSocket.Connect(ipep); 

                String outBufferStr; 

                Byte[] outBuffer = new Byte[1024]; 

                Byte[] inBuffer = new Byte[1024]; 

                while (true) 

                { 

                    //发送消息   

                    outBufferStr = Console.ReadLine(); 

                    outBuffer = Encoding.ASCII.GetBytes(outBufferStr); 

                    clientSocket.Send(outBuffer, outBuffer.Length, SocketFlags.None); 

                     

                    //接收服务器端信息                

                    clientSocket.Receive(inBuffer, 1024, SocketFlags.None);//如果接收的消息为空 阻塞 当前循环  

                    Console.WriteLine("服务器说:"); 

                    Console.WriteLine(Encoding.ASCII.GetString(inBuffer)); 

                } 

            } 

            catch 

            { 

                Console.WriteLine("服务未开启!"); 

                Console.ReadLine(); 

            } 

        } 

    } 

3、在ConsoleApplication_socketServer中输入以下代码:

 

 

using System; 

using System.Collections.Generic; 

using System.Linq; 

using System.Text; 

using System.IO; 

using System.Net; 

using System.Net.Sockets; 

using System.Threading; 

 

namespace ConsoleApplication_socketServer 

    class Program 

    { 

        static Socket serverSocket; 

        static Socket clientSocket; 

        static Thread thread; 

        static void Main(string[] args) 

        { 

            IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 3001); 

            serverSocket = new Socket(ipep.AddressFamily, SocketType.Stream, ProtocolType.Tcp); 

            serverSocket.Bind(ipep); 

            serverSocket.Listen(10); 

            while (true) 

            { 

                clientSocket = serverSocket.Accept(); 

                thread = new Thread(new ThreadStart(doWork)); 

                thread.Start(); 

            } 

        } 

        private static void doWork() 

        { 

            Socket s = clientSocket;//客户端信息 

            IPEndPoint ipEndPoint = (IPEndPoint)s.RemoteEndPoint; 

            String address = ipEndPoint.Address.ToString(); 

            String port = ipEndPoint.Port.ToString(); 

            Console.WriteLine(address + ":" + port + " 连接过来了"); 

            Byte[] inBuffer = new Byte[1024]; 

            Byte[] outBuffer = new Byte[1024]; 

            String inBufferStr; 

            String outBufferStr; 

            try 

            { 

                while (true) 

                { 

                    s.Receive(inBuffer, 1024, SocketFlags.None);//如果接收的消息为空 阻塞 当前循环  

                    inBufferStr = Encoding.ASCII.GetString(inBuffer); 

                    Console.WriteLine(address + ":" + port + "说:"); 

                    Console.WriteLine(inBufferStr); 

                    outBufferStr = Console.ReadLine(); 

                    outBuffer = Encoding.ASCII.GetBytes(outBufferStr); 

                    s.Send(outBuffer, outBuffer.Length, SocketFlags.None); 

                } 

            } 

            catch 

            { 

                Console.WriteLine("客户端已关闭!"); 

            } 

        } 

    } 

 

4、先运行ConsoleApplication_socketServer,后运行ConsoleApplication_socketClient就可以通信了。

 

5、时间有限,希望大家都以上代码进行优化,因为其中存在不足:比如发言的顺序之类的

 

作者 liyongquanlongliang

点击复制链接 与好友分享!回本站首页
相关TAG标签
上一篇:C# 无法解析程序集
下一篇:C#跨窗体操作(引用传递)
相关文章
图文推荐
点击排行

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站