首页 文章 精选 留言 我的

C# Socket编程

2017-11-11 561

在.NET技术大系当中，有很多服务编程的技术，比如socket、windows service、.net remoting、message queue、web service、wcf等等，这些技术都往往与网络知识紧密相关，有时还会结合多线程等技术，实现特定的需求。这里只以Socket为例，看如何运用C#进行网络编程。

熟悉Socket编程的应该都不陌生，要实现Socket，需要一个服务端程序以及一个客户端程序，服务端程序绑定IP、Port，建立侦听；客户端程序建立连接，向服务端抛出请求，通过TCP或UDP协议，获得服务端的反馈，这是一个双工通信的过程。而且最重要的是，Socket通信与具体编程语言无关，C、C++、JAVA、C#、PHP、Flex等高级编程语言都提供了相应的实现。

下面这个是个客户端Socket的简单例子，也是实际工作中曾经用过的。当时的情况是Socket服务端是用Java开发的一个程序，通过使用Socket，让两台不同网络的的机器通过前置机获取对方的信息。通过客户端发起请求，服务端监听收到请求后，进行响应处理，并把封装好的XML文档返回客户端。客户端收到XML数据后进行解析处理即可。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
/// <summary>
/// 获取通讯中间件通过socket发送的数据，DataTable
/// </summary>
/// <param name="requestCode">请求code</param>
/// <param name="array">查询的条件，封装在数组里</param>
/// <param name="errMsg">错误提示</param>
/// <returns>经过一系列处理过后的DataTable</returns>
public  DataTable GetDataTable( string  requestCode, IList< string > list,  out  string  errMsg)
{
     try
     {
         string  ip = ConfigurationManager.AppSettings[ "ip" ].ToString().Trim(); //中间件的ip地址
         int  port = Convert.ToInt32(ConfigurationManager.AppSettings[ "port" ].ToString().Trim()); //中间件的端口号
         IPEndPoint serverip =  new  IPEndPoint(IPAddress.Parse(ip), port);
         using  (Socket clientSocket =  new  Socket(serverip.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
         {
             clientSocket.Connect(serverip); //socket连接指定中间件前置机
             string  outBufferString =  string .Empty; //准备发送的报文
             switch  (requestCode)
             {
                 case  "111001" :
                     outBufferString = PrepareSendPackets( "111001" , list);
                     break ;
                 case  "111002" :
                     outBufferString = PrepareSendPackets( "111002" , list);
                     break ;
                 case  "111003" :
                     outBufferString = PrepareSendPackets( "111003" , list);
                     break ;
                 default :
                     break ;
             }
             byte [] outBuffer =  new  byte [2048];
             outBuffer = Encoding.GetEncoding( "gbk" ).GetBytes(outBufferString);
             clientSocket.Send(outBuffer, outBuffer.Length, 0); //发送报文
                            
             byte [] inBuffer =  new  byte [51200];
             clientSocket.Receive(inBuffer, inBuffer.Length, 0); //接收报文
             string  inBufferString =  "<?xml version='1.0' encoding='gb2312' ?> " ;
             inBufferString += Encoding.GetEncoding( "gbk" ).GetString(inBuffer);
             DataTable dt = ParsingPackets(requestCode, inBufferString,  out  errMsg);
             return  dt;
         }
     }
     catch  (Exception ex)
     {
         throw  ex;
     }
}

再附一个完整一点的小例子。

这个程序简单实现了客户端发送消息，服务端接收消息并反馈给客户端消息的过程。用了同步模式，是最简单的socket通信模型。

服务端控制台：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
static  void  Main( string [] args)
     {
         //定义一个字典用于存放用户列表
         Dictionary< string ,  string > users =  new  Dictionary< string ,  string >();
                        
         using  (Socket socket =  new  Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
         {
             IPEndPoint ipe =  new  IPEndPoint(IPAddress.Parse( "192.168.1.7" ), 1234);
             socket.Bind(ipe);
             socket.Listen(10);
                        
             Console.WriteLine( "socket start!" );
                        
             while  ( true ) //服务端死循环，不断提供socket服务
             {
                 Socket clientSocket = socket.Accept(); //等待客户端请求
                        
                 IPEndPoint ip = (IPEndPoint)clientSocket.RemoteEndPoint;
                 string  remoteAddress = ip.Address.ToString(); //远程IP地址
                        
                 byte [] revBytes =  new  byte [512];
                 clientSocket.Receive(revBytes); //接收客户端发送的消息
                 string  user = Encoding.Default.GetString(revBytes);
                        
                 if  (!users.ContainsKey(remoteAddress))
                 {
                     users.Add(remoteAddress, user);
                 }
                 Console.WriteLine( "来自于"  + remoteAddress +  "的用户："  + user);
                 string  content =  "欢迎来到socket的世界！" ;
                 byte [] bytes = Encoding.Default.GetBytes(content);
                 clientSocket.Send(bytes); //发送服务端消息到客户端
                        
                 clientSocket.Shutdown(SocketShutdown.Both);
                 clientSocket.Close();
             }
         }
     }

客户端WPF：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
public  MainWindow()
     {
         InitializeComponent();
     }
                   
     private  string  ip; //传入的ip
     private  string  username; //传入的用户名
                   
     public  MainWindow( string  ip,  string  username)
     {
         InitializeComponent();
                   
         this .ip = ip;
         this .username = username;
     }
                   
     private  void  button1_Click( object  sender, RoutedEventArgs e)
     {
         SendSocketPackge();
     }
                   
     private  static  Socket client; //socket对象
                   
     /// <summary>
     /// 发送数据包
     /// </summary>
     private  void  SendSocketPackge()
     {
         //建立1个Socket对象发起TCP连接
         client =  new  Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
         client.Connect(IPAddress.Parse( "192.168.1.7" ), 1234); //连接到服务器指定IP及Port
         string  userSays = username +  "说："  +  this .textBox1.Text; //username自己用一个字符串代替
         client.Send(Encoding.Default.GetBytes(userSays)); //将当前的用户名发送给服务器端
                   
         byte [] bytes =  new  byte [512];
         client.Receive(bytes); //接收服务端发送的消息
         client.Shutdown(SocketShutdown.Both);
         client.Close();
                   
         string  content =  string .Join( " " , DateTime.Now.ToString(), Encoding.Default.GetString(bytes));
         listBox1.Items.Add(content); //将消息加载到listbox列表
     }
                   
     private  void  Window_Loaded( object  sender, RoutedEventArgs e)
     {
         ip = Dns.GetHostAddresses(Dns.GetHostName())[0].ToString();
         this .Title =  "来自："  + ip +  "的用户："  + username;
     }
                   
     private  void  Window_Closing( object  sender, System.ComponentModel.CancelEventArgs e)
     {
         if  (client !=  null  && client.Connected)
         {
             client.Shutdown(SocketShutdown.Both);
             client.Close();
         }
     }

效果图：

服务启动时：

Center

客户端界面：

Center

点击发送后，服务端显示的消息：

Center
由于代码比较简单，就不上传项目文件了，这里简单演示了一下C#Socket通信的核心代码。读者可以在此基础上不断扩展。


本文转自 guwei4037  51CTO博客，原文链接:http://blog.51cto.com/csharper/1345244
上一篇 下一篇
优秀的个人博客,低调大师

微信关注我们

原文链接：https://yq.aliyun.com/articles/481289

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

tomcat 之APR优化

从操作系统级别来解决异步的IO问题,大幅度的提高性能。 1.生产环境安装优化步奏： tomcat 版本： apache-tomcat-7.0.68.tar.gz jdk版本： java-1.7.0_55.tar 2.下载相关软件包： cd /aliyun/soft/ rz -y apr-1.5.0.tar.gz apr-util-1.5.3.tar.gz apr-iconv-1.2.1.tar.gz tomcat-native-1.1.34-src.tar.gz 3.yum安装需要的依赖： yum install -y apr-devel openssl-devel gcc openssl (需要的话得安装) 4.编译安装apr软件包 tar xf apr-1.5.0.tar.gz -C /aliyun/ cd /aliyun/apr-1.5.0/ ./configure --prefix=/aliyun/apr make &&make install 5.编译安装apr-iconv软件包 tar xf /aliyun/soft/apr-iconv-1.2.1.tar....
2017-11-12
613
上一篇

Linux内核虚拟机 学习KVM架构及其优点

虚拟化概念很早就已出现。简单来说，虚拟化就是使用某些程序，并使其看起来类似于其他程序的过程。将这个概念应用到计算机系统中可以让不同用户看到不同的单个系统（例如，一台计算机可以同时运行 Linux 和 Microsoft® Windows®）。这通常称为全虚拟化（full virtualization）。 虚拟化也可以使用更加复杂的格式，其中单个计算机看上去具有多个架构（对于一个用户来说，它是一个标准的 x86 平台；对于另外一个用户来说，它是 IBM Power PC® 平台）。这种虚拟化形式通常被称为硬件仿真。 最后，更加简单的一种虚拟化是操作系统虚拟化，其中一台计算机可以运行相同类型的多个操作系统。这种虚拟化可以将一个操作系统的多个服务器隔离开来（这意味着全都必须使用相同类型和版本的操作系统）。 虚拟化和准虚拟化（para-virtualization） 虚拟化最常使用的两种方法是全虚拟化和准虚拟化。使用全虚拟化，在虚拟化的操作系统和硬件之间存在一个层，用于决定访问。这个层称为系统管理程序或虚拟机监视器（VMM）。准虚拟化与之类似，但是系统管理程序会以一种更具协作性的方式进行操作。...
2017-11-12
573
下一篇

相关文章

发表评论

资源下载

更多资源
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

时间: 2025-12-12 大小: 211.28KB 下载: 54次
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

时间: 2025-12-28 大小: 1MB 下载: 4次
Spring

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

时间: 2025-12-17 大小: 5MB 下载: 1次
Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

时间: 2025-12-03 大小: 9.84MB 下载: 39次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
Gemini3 HarmonyOS6 SpringBoot4 SpringCloud Rocky Jdk25 Service Mesh Kubernetes Nacos3 Docker Redis DeepSeek OpenAi

欢迎您来访！

登录后，您将获得更多功能！
热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273

用户登录
用户注册