稳扎稳打Silverlight(24) - 2.0通信之Socket, 开发一个多人聊天室

稳扎稳打Silverlight(24) - 2.0通信之Socket,开发一个多人聊天室

作者：webabcd

介绍
Silverlight 2.0 Socket通信。开发一个多人聊天室
服务端：实例化Socket,绑定,监听,连接,接收数据,发送数据
客户端：实例化Socket,指定服务端地址,发送数据

在线DEMO
http://www.voidcn.com/article/p-ounmxjds-tq.html

示例
1、Policy服务（向客户端发送策略文件的服务）
clientaccesspolicy.xml

<? xml version ="1.0" encoding ="utf-8" ?>
< access-policy >
         < cross-domain-access >
                 < policy >
                         < allow-from >
                                 < domain uri ="*" />
                         </ allow-from >
                         < grant-to >
                                 < socket-resource port ="4502-4534" protocol ="tcp" />
                         </ grant-to >
                 </ policy >
         </ cross-domain-access >
</ access-policy >

Main.cs

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Net.sockets;

using System.IO;

using System.Net;

namespace PolicyServer

{

public partial class Main : Form

{

// 客户端 socket 发送到服务端的对策略文件的请求信息

private readonly string _policyRequestString = "<policy-file-request/>";

private Socket _listener; // 服务端监听的 socket

private byte[] _policyBuffer; // 服务端策略文件的 buffer

private byte[] _requestBuffer; // 客户端 socket 发送的请求信息的 buffer

private int _received; // 接收到的信息字节数

private bool _flag = false; // 标志位。服务端是否要处理传入的连接

System.Threading.SynchronizationContext _syncContext;

public Main()

{

InitializeComponent();

_flag = true;

lblStatus.Text = "PolicyServer状态：启动";

lblStatus.ForeColor = Color.Green;

// 启动 PolicyServer

StartupPolicyServer();

// UI 线程

_syncContext = System.Threading.SynchronizationContext.Current;

}

private void btnStartup_Click( object sender,EventArgs e)

{

_flag = true;

lblStatus.Text = "PolicyServer状态：启动";

lblStatus.ForeColor = Color.Green;

}

private void btnPause_Click( object sender,EventArgs e)

{

_flag = false;

lblStatus.Text = "PolicyServer状态：暂停";

lblStatus.ForeColor = Color.Red;

}

/// <summary>

/// 启动 PolicyServer

/// </summary>

private void StartupPolicyServer()

{

string policyFile = Path.Combine(Application.StartupPath,"clientaccesspolicy.xml");

using (FileStream fs = new FileStream(policyFile,FileMode.Open,FileAccess.Read))

{

// 将策略文件的内容写入 buffer

_policyBuffer = new byte[fs.Length];

fs.Read(_policyBuffer,_policyBuffer.Length);

}

// 初始化 socket ，然后与端口绑定，然后对端口进行监听

_listener = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

_listener.Bind( new IPEndPoint(IPAddress.Any,943)); // socket 请求策略文件使用 943 端口

_listener.Listen(100);

// 开始接受客户端传入的连接

_listener.BeginAccept( new AsyncCallback(OnClientConnect),null);

}

private void OnClientConnect(IAsyncResult result)

{

if (!_flag)

{

// PolicyServer 停用的话，则不再处理传入的连接

_listener.BeginAccept( new AsyncCallback(OnClientConnect),null);

return;

}

Socket client; // 客户端发过来的 socket

try

{

// 完成接受客户端传入的连接的这个异步操作，并返回客户端连入的 socket

client = _listener.EndAccept(result);

}

catch (SocketException)

{

return;

}

_requestBuffer = new byte[_policyRequestString.Length];

_received = 0;

try

{

// 开始接收客户端传入的数据

client.BeginReceive(_requestBuffer,_policyRequestString.Length,SocketFlags.None,new AsyncCallback(OnReceive),client);

}

catch (SocketException)

{

// socket 出错则关闭客户端 socket

client.Close();

}

// 继续开始接受客户端传入的连接

_listener.BeginAccept( new AsyncCallback(OnClientConnect),null);

}

private void OnReceive(IAsyncResult result)

{

Socket client = result.AsyncState as Socket;

try

{

// 完成接收数据的这个异步操作，并计算累计接收的数据的字节数

_received += client.EndReceive(result);

if (_received < _policyRequestString.Length)

{

// 没有接收到完整的数据，则继续开始接收

client.BeginReceive(_requestBuffer,_received,_policyRequestString.Length - _received,client);

return;

}

// 把接收到的数据转换为字符串

string request = System.Text.Encoding.UTF8.GetString(_requestBuffer,_received);

if (StringComparer.InvariantCultureIgnoreCase.Compare(request,_policyRequestString) != 0)

{

// 如果接收到的数据不是“<policy-file-request/>”，则关闭客户端 socket

client.Close();

return;

}

// 开始向客户端发送策略文件的内容

client.BeginSend(_policyBuffer,_policyBuffer.Length,new AsyncCallback(OnSend),client);

}

catch (SocketException)

{

// socket 出错则关闭客户端 socket

client.Close();

}

private void OnSend(IAsyncResult result)

{

Socket client = result.AsyncState as Socket;

try

{

// 完成将信息发送到客户端的这个异步操作

client.EndSend(result);

// 获取客户端的ip地址及端口号，并显示

_syncContext.Post(ResultCallback,client.LocalEndPoint.ToString());

}

finally

{

// 关闭客户端 socket

client.Close();

}

void ResultCallback( object result)

{

// 输出客户端的ip地址及端口号

txtMsg.Text += result.ToString() + "\r\n";

}

2、Socket服务端（聊天室的服务端）
ClientSocketPacket.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace SocketServer

{

/// <summary>

/// 对客户端 Socket 及其他相关信息做一个封装

/// </summary>

public class ClientSocketPacket

{

/// <summary>

/// 客户端 Socket

/// </summary>

public System.Net.sockets.socket Socket { get; set; }

private byte[] _buffer;

/// <summary>

/// 为该客户端 Socket 开辟的缓冲区

/// </summary>

public byte[] Buffer

{

get

{

if (_buffer == null)

_buffer = new byte[32];

return _buffer;

}

private List< byte> _receivedByte;

/// <summary>

/// 客户端 Socket 发过来的信息的字节集合

/// </summary>

public List< byte> ReceivedByte

{

get

{

if (_receivedByte == null)

_receivedByte = new List< byte>();

return _receivedByte;

}

未完待续>>

OK
[源码下载]

稳扎稳打Silverlight(24) - 2.0通信之Socket, 开发一个多人聊天室

相关推荐