`

C#使用SOCKET编程实现服务器+客户端的聊天程序示例(转)

    博客分类:
  • C#
阅读更多



1 C#使用SOCKET编程实现服务器+客户端的聊天程序示例
[日期:2009-12-28] 来源:     作者: [字体:大 中 小]


本文使用SOCKET编程实现聊天程序,不基于P2P技术。

首先,本文主要是针对那些刚接触SOCKET编程的朋友,将介绍的是一个服务器端+客户端的聊天系统,比较简单,入门级别的,先来看下效果界面.
上面是服务器端运行界面;下面把客户端界面贴给大家看下:

功能看起来是比较简单。服务器的端口号可以在“系统菜单”里面的参数配置进行修改的。

下面开始讲下如何实现上面聊天的功能吧。直接上代码:

服务端代码如下:


C# Code [http://www.oeedu.com]


1 using System;
  2 using System.Collections.Generic;
  3 using System.ComponentModel;
  4 using System.Data;
  5 using System.Drawing;
  6 using System.Text;
  7 using System.Windows.Forms;
  8
  9 using System.Net;
10 using System.Net.Sockets;
11 using System.Threading;
12 using System.Xml;
13
14 namespace Server
15 {
16     public partial class ServerMain : Form
17     {
18         public ServerMain()
19         {
20             InitializeComponent();
21         }
22
23         private void ServerMain_Load(object sender, EventArgs e)
24         {
25             this.CmdStar.Enabled = true;
26             this.CmdStop.Enabled = false;
27         }
28
29         private void 配置参数ToolStripMenuItem_Click(object sender, EventArgs e)
30         {
31             Set TSet = new Set();
32             TSet.ShowDialog();
33         }
34
35         private void 关于ToolStripMenuItem_Click(object sender, EventArgs e)
36         {
37             About TAbout = new About();
38             TAbout.Show();
39         }
40         /// <summary>
41         /// 获得XML文件中的端口号
42         /// </summary>
43         /// <returns></returns>
44         private int GetPort()
45         {
46             try
47             {
48                 XmlDocument TDoc = new XmlDocument();
49                 TDoc.Load("Settings.xml");
50                 string TPort = TDoc.GetElementsByTagName("ServerPort")[0].InnerXml;
51                 return Convert.ToInt32(TPort);
52
53             }
54             catch { return 6600; }//默认是6600
55         }
56
57         //声明将要用到的类
58         private IPEndPoint ServerInfo;//存放服务器的IP和端口信息
59         private Socket ServerSocket;//服务端运行的SOCKET
60         private Thread ServerThread;//服务端运行的线程
61         private Socket[] ClientSocket;//为客户端建立的SOCKET连接
62         private int ClientNumb;//存放客户端数量
63         private byte[] MsgBuffer;//存放消息数据
64
65         private void CmdStar_Click(object sender, EventArgs e)
66         {
67             ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
68             ServerInfo=new IPEndPoint(IPAddress.Any,this.GetPort());
69             ServerSocket.Bind(ServerInfo);//将SOCKET接口和IP端口绑定
70             ServerSocket.Listen(10);//开始监听,并且挂起数为10
71
72             ClientSocket = new Socket[65535];//为客户端提供连接个数
73             MsgBuffer = new byte[65535];//消息数据大小
74             ClientNumb = 0;//数量从0开始统计
75
76             ServerThread = new Thread(RecieveAccept);//将接受客户端连接的方法委托给线程
77             ServerThread.Start();//线程开始运行
78
79             CheckForIllegalCrossThreadCalls = false;//不捕获对错误线程的调用
80
81             this.CmdStar.Enabled = false;
82             this.CmdStop.Enabled = true;
83             this.StateMsg.Text = "服务正在运行" "  运行端口:" this.GetPort().ToString();
84             this.ClientList.Items.Add("服务于 "   DateTime.Now.ToString()   " 开始运行.");
85         }
86        
87         //接受客户端连接的方法
88         private void RecieveAccept()
89         {
90             while (true)
91             {
92                 ClientSocket[ClientNumb] = ServerSocket.Accept();
93                 ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack),ClientSocket[ClientNumb]);
94                 this.ClientList.Items.Add(ClientSocket[ClientNumb].RemoteEndPoint.ToString() " 成功连接服务器.");
95                 ClientNumb  ;
96             }
97         }
98
99         //回发数据给客户端
100         private void RecieveCallBack(IAsyncResult AR)
101         {
102             try
103             {
104                 Socket RSocket = (Socket)AR.AsyncState;
105                 int REnd = RSocket.EndReceive(AR);
106                 for (int i = 0; i < ClientNumb; i  )
107                 {
108                     if (ClientSocket[i].Connected)
109                     {
110                         ClientSocket[i].Send(MsgBuffer, 0, REnd,0);
111                     }
112                     RSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack), RSocket);
113
114                 }
115             }
116             catch { }
117
118         }
119
120         private void CmdStop_Click(object sender, EventArgs e)
121         {
122             ServerThread.Abort();//线程终止
123             ServerSocket.Close();//关闭SOCKET
124
125             this.CmdStar.Enabled = true;
126             this.CmdStop.Enabled = false;
127             this.StateMsg.Text = "等待运行";
128             this.ClientList.Items.Add("服务于 "   DateTime.Now.ToString()   " 停止运行.");
129         }
130
131
132
133     }
134 }



好,看完服务端代码,接下我们来看下客户端的代码又是如何实现的?



客户端代码:


C# Code [http://www.oeedu.com]


1 using System;
  2 using System.Collections.Generic;
  3 using System.ComponentModel;
  4 using System.Data;
  5 using System.Drawing;
  6 using System.Text;
  7 using System.Windows.Forms;
  8
  9 using System.Net;
10 using System.Net.Sockets;
11
12 namespace Client
13 {
14     public partial class ClientMain : Form
15     {
16         public ClientMain()
17         {
18             InitializeComponent();
19         }
20
21         private IPEndPoint ServerInfo;
22         private Socket ClientSocket;
23         private Byte[] MsgBuffer;
24         private Byte[] MsgSend;
25
26         private void ClientMain_Load(object sender, EventArgs e)
27         {
28             this.CmdSend.Enabled = false;
29             this.CmdExit.Enabled = false;
30
31             ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
32             MsgBuffer = new Byte[65535];
33             MsgSend = new Byte[65535];
34             CheckForIllegalCrossThreadCalls = false;
35
36             Random TRand=new Random();
37             this.UserName.Text = "用户"   TRand.Next(10000).ToString();
38         }
39
40         private void CmdEnter_Click(object sender, EventArgs e)
41         {
42             ServerInfo = new IPEndPoint(IPAddress.Parse(this.ServerIP.Text), Convert.ToInt32(this.ServerPort.Text));
43
44             try
45             {
46                 ClientSocket.Connect(ServerInfo);
47
48                 ClientSocket.Send(Encoding.Unicode.GetBytes("用户: "   this.UserName.Text   " 进入系统!\n"));
49
50                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);
51
52                 this.SysMsg.Text  = "登录服务器成功!\n";
53                 this.CmdSend.Enabled = true;
54                 this.CmdEnter.Enabled = false;
55                 this.CmdExit.Enabled = true;
56             }
57             catch
58             {
59                 MessageBox.Show("登录服务器失败,请确认服务器是否正常工作!");
60             }
61         }
62
63         private void ReceiveCallBack(IAsyncResult AR)
64         {
65             try
66             {
67                 int REnd = ClientSocket.EndReceive(AR);
68                 this.RecieveMsg.AppendText(Encoding.Unicode.GetString(MsgBuffer, 0, REnd));
69                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);
70
71             }
72             catch
73             {
74                 MessageBox.Show("已经与服务器断开连接!");
75                 this.Close();
76             }
77
78         }
79
80         private void CmdSend_Click(object sender, EventArgs e)
81         {
82             MsgSend = Encoding.Unicode.GetBytes(this.UserName.Text   "说:\n"   this.SendMsg.Text   "\n");
83             if (ClientSocket.Connected)
84             {
85                 ClientSocket.Send(MsgSend);
86                 this.SendMsg.Text = "";
87             }
88             else
89             {
90                 MessageBox.Show("当前与服务器断开连接,无法发送信息!");
91             }
92         }
93
94         private void CmdExit_Click(object sender, EventArgs e)
95         {
96             if (ClientSocket.Connected)
97             {
98                 ClientSocket.Send(Encoding.Unicode.GetBytes(this.UserName.Text   "离开了房间!\n"));
99                 ClientSocket.Shutdown(SocketShutdown.Both);
100                 ClientSocket.Disconnect(false);
101             }
102             ClientSocket.Close();
103
104             this.CmdSend.Enabled = false;
105             this.CmdEnter.Enabled = true;
106             this.CmdExit.Enabled = false;
107         }
108
109         private void RecieveMsg_TextChanged(object sender, EventArgs e)
110         {
111             this.RecieveMsg.ScrollToCaret();
112         }
113
114         private void SendMsg_KeyDown(object sender, KeyEventArgs e)
115         {
116             if (e.Control && e.KeyValue == 13)
117             {
118                 e.Handled = true;
119                 this.CmdSend_Click(this, null);
120             }
121         }
122
123
124
125
126     }
127 }



我只对服务器端的代码做了注释,客户端就没有写注释了,因为代码是差不多的。区别在于客户端不需要监听,也不需要启用线程进行委托。
关于 ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
这句代码,我想给初学者解释一下,这里“AddressFamily.InterNetwork”表示的是使用IPV4地址,“SocketType.Stream”表示使用的是流格式(另外还有数据包格式和原始套接字格式),“ProtocolType.Tcp”表示使用TCP协议(另外还有很多其它协议,例如大家常看到的UDP协议)。
另外关于SOCKET类中的BeginReceive方法,请大家参考MSDN,里面有详细说明。

下面是Settings.xml内容


XML Code [http://www.oeedu.com]


<?xml version="1.0" encoding="utf-8" ?>
<Server>
  <ServerPort>6600</ServerPort>
</Server>



本文代码下载地址:
  • 大小: 38.9 KB
  • 大小: 60 KB
分享到:
评论

相关推荐

    C# TCP Socket编程示例

    这是一个不错的TCP Socket编程示例,里面包含了服务器和客户端的软件,欢迎下载。

    C#网络与通信程序设计案例精讲示例代码

    \chap06 提供了本书第6章基于Socket的聊天室源程序; \chap07 提供了本书第7章多线程下载源程序 \chap08 提供了本书第8章基于Web的电子书店源程序; \chap09 提供了本书第9章网络游戏源程序; \chap10 提供...

    C#.NET网络编程.part1

    gui程序的编写和编译运行 4.4 基于udp协议的网络会话实例 4.4.1 ...客户端编程 4.5.4 编译运行 4.6 基于udp的客户一服务器聊天应用的实现 4.6.1 qtcpserversession类 4.6.2 qtcpserver类 4.6.3 ...

    Fleck:C#Websocket实现

    Fleck是C#中的WebSocket服务器实现。 从项目分支出来的Fleck不需要继承,容器或其他引用。 Fleck不依赖于HttpListener或HTTP.sys ,这意味着它将在Windows 7和Server 2008主机上运行。 例子 以下是将回显到...

    c#(Socket)异步套接字代码示例

    异步客户端套接字示例 下面的示例程序创建一个连接到服务器的客户端。该客户端是用异步套接字生成的,因此在等待服务器返回响应时不挂起客户端应用程序的执行。该应用程序将字符串发送到服务器,然后在控制台显示该...

    Visual C#网络编程技术与实践源代码

     本书不仅适用于使用Visual C# 2005进行软件开发的广大软件开发人员,也适合高等院校师生学习和参考使用,特别对高校计算机专业的学生进行毕业设计具有非常好的指导价值,也可以作为广大计算机编程爱好者的自学参考...

    易语言-HP-Socket 5.5.1 rc2 源码+模块+例程(新增了可靠 UDP 组件!!!)

    Socket 是一套通用的高性能 TCP/UDP/HTTP 通信框架,包含服务端组件、客户端组件和Agent组件,广泛适用于各种不同应用场景的 TCP/UDP/HTTP 通信系统,提供 C/C++、C#、Delphi、E(易语言)、Java、Python 等编程语言...

    Socket通信.zip

    基于C#的socket通信代码,涵盖了TCP服务器和客户端的创建和详细解析,客户端发送“震动”效果的示例,字符串和字节之间的相互转换示例,适合新手对网络编程的学习使用。

    c#基础实例

    实例6 在SQL Server中存储显示图片 实例7 在ACESS 2000中存储显示图片 第六章 网络应用 实例1 Socket建立服务器程序 实例2 Socket建立客户端程序 实例3 P2P技术实现点对点聊天 实例4 C/S...

    实验三Socket通信实验报告.doc

    基于C的面向连接的socket编程模型 1. 点对点通信功能 实现网络点对点通讯程序的关键步骤就是实现信息在网络中的发送和接收。数据接收 使用的是Socket,数据发送使用的是NetworkStream。 1.1利用Socket来接收信息 ...

    C#开发典型模块大全

    1.3.4 利用MSDN帮助附带的示例学习编程 11 1.4 启动Visual Studio 2005开发环境 12 1.4.1 启动Visual Studio 2005 12 1.4.2 创建项目 12 1.5 熟悉Visual Studio 2005集成开发环境 13 1.5.1 新特性 14 ...

    C#开发典型模块大全(光盘)第二部分

    1.3.4 利用MSDN帮助附带的示例学习编程 1.4 启动VisualStudio2005开发环境 1.4.1 启动VisualStudio2005 1.4.2 创建项目 1.5 熟悉VisualStudio2005集成开发环境 1.5.1 新特性 1.5.2 主窗口 1.5.3 菜单栏 1.5.4 工具栏...

    C#开发典型模块大全(光盘)

    1.3.4 利用MSDN帮助附带的示例学习编程 1.4 启动VisualStudio2005开发环境 1.4.1 启动VisualStudio2005 1.4.2 创建项目 1.5 熟悉VisualStudio2005集成开发环境 1.5.1 新特性 1.5.2 主窗口 1.5.3 菜单栏 1.5.4 工具栏...

    C#开发典型模块大全(光盘)第一部分

    1.3.4 利用MSDN帮助附带的示例学习编程 1.4 启动VisualStudio2005开发环境 1.4.1 启动VisualStudio2005 1.4.2 创建项目 1.5 熟悉VisualStudio2005集成开发环境 1.5.1 新特性 1.5.2 主窗口 1.5.3 菜单栏 1.5.4 工具栏...

    vc++ 应用源码包_1

    内含各种例子(vc下各种控件的使用方法、标题栏与菜单栏、工具栏与状态栏、图标与光标、程序窗口、程序控制、进程与线程、字符串、文件读写操作、文件与文件夹属性操作、文件与文件夹系统操作、系统控制操作、程序...

    vc++ 应用源码包_5

    内含各种例子(vc下各种控件的使用方法、标题栏与菜单栏、工具栏与状态栏、图标与光标、程序窗口、程序控制、进程与线程、字符串、文件读写操作、文件与文件夹属性操作、文件与文件夹系统操作、系统控制操作、程序...

Global site tag (gtag.js) - Google Analytics