Silverlight Socket异步通信 范例 Demo

概述  最近刚接触Silverlight，研究了一下Silverlight的Socket通信，把代码贴出来与大家分享下。 以下在Vs2010 、Silverlight4.0下测试通过。 首先要建立一个PolicyFile.xml文件，该文件留指定一个策略文件，至于策略文件的格式，MS的Silverlight有详细说明和配置方法   <?xml version="

 

最近刚接触Silverlight，研究了一下Silverlight的Socket通信，把代码贴出来与大家分享下。

以下在Vs2010 、Silverlight4.0下测试通过。

首先要建立一个Policyfile.xml文件，该文件留指定一个策略文件，至于策略文件的格式，MS的Silverlight有详细说明和配置方法

 

                <?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>  

 

 

接下来写ClIEnt端 xaml

 

                   <GrID x:name="LayoutRoot" Background="White" ShowGrIDlines="True">         <GrID.RowDeFinitions >             <RowDeFinition />             <RowDeFinition />         </GrID.RowDeFinitions>          <TextBox x:name="txtToSend" GrID.Row="0"/>         <button GrID.Row="1" Click="OnSend" Content="Send" margin="20" />     </GrID>

 

 

 

ClIEnt端CS代码：

 

              using System;using System.Collections.Generic;using System.linq;using System.Net;using System.windows;using System.windows.Controls;using System.windows.documents;using System.windows.input;using System.windows.Media;using System.windows.Media.Animation;using System.windows.Shapes;using System.Net.sockets;using System.Threading;using System.Text;namespace SocketTest{    public partial class MainPage : UserControl    {        //SilverlightSocket通信是基于异步的Socket通信，为了保持有一个Socket一直处于Receive状态，所以设置两个Socket进行通信        private SynchronizationContext syn;//同步上下文        private System.Net.sockets.socket sendSocket;//用于发送信息的Socket        private socketasynceventargs sendSocketArgs;//发送信息的Socket参数        private System.Net.sockets.socket receiveSocket;//用于接收信息的Socket        private socketasynceventargs receiveSocketArgs;//用于接收信息的Socket参数        private string remoteIPAddress;//远程连接的IP地址        public MainPage()        {            //初始化            InitializeComponent();            syn = SynchronizationContext.Current;            sendSocket=new System.Net.sockets.socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);            receiveSocket=new System.Net.sockets.socket(AddressFamily.InterNetwork,ProtocolType.Tcp);            sendSocketArgs = new socketasynceventargs();            receiveSocketArgs = new socketasynceventargs();            remoteIPAddress = "10.6.1.69";            SocketPrepare(sendSocket,sendSocketArgs);            SocketPrepare(receiveSocket,receiveSocketArgs);        }        protected voID SocketPrepare(Socket _socket,socketasynceventargs _socketArgs)        {            byte[] bytes = EnCoding.UTF8.GetBytes("Prepare");            _socketArgs.UserToken = bytes;            //Silverlight通信端口有严格的规定，具体查看文档            _socketArgs.RemoteEndPoint = new DnsEndPoint(remoteIPAddress,4502);            _socketArgs.Completed += new EventHandler<socketasynceventargs>(socketArgs_Completed);            _socket.ConnectAsync(_socketArgs);            //socket通信步骤：Contect->Send->Receive        }        voID OnSend(object sender,EventArgs args)        {                sendSocketArgs.UserToken = EnCoding.UTF8.GetBytes(txtToSend.Text);                ProcessConnect_Send(sendSocket,sendSocketArgs);        }        voID socketArgs_Completed(object sender,socketasynceventargs e)        {            Socket s = sender as Socket;            switch (e.Lastoperation)            {                case SocketAsyncoperation.Connect:                    ProcessConnect_Send(s,e);                    break;                case SocketAsyncoperation.Receive:                    ProcessReceive_Post(s,e);                    break;                case SocketAsyncoperation.Send:                    ProcessSend_Receive(s,e);                    break;            }        }        voID ProcessConnect_Send(Socket tmpSocket,socketasynceventargs e)        {            //从UserToken获得要发送的内容            byte[] bytes = (byte[])e.UserToken;            e.SetBuffer(bytes,bytes.Length);            tmpSocket.SendAsync(e);        }        voID ProcessSend_Receive(Socket tmpSocket,socketasynceventargs e)        {            byte[] bytes = new byte[30];            e.SetBuffer(bytes,bytes.Length);            tmpSocket.ReceiveAsync(e);        }        voID ProcessReceive_Post(Socket tmpSocket,socketasynceventargs e)        {            syn.Post(GetText,EnCoding.UTF8.GetString(e.Buffer,e.Buffer.Length) + " and Received");            //为了保证有一个Socket一直处在Receive状态，所以在接收到第一次数据之后，继续进入Receive状态            if (tmpSocket == receiveSocket) tmpSocket.ReceiveAsync(e);        }        voID GetText(object str)        {            txtToSend.Text += "/r/n" + str.ToString();        }    }}      

 

 

我们用一个控制台项目来作为Socket的Server端，用于接收Sliverlight程序发过来的信息以及向SilverlightClIEnt端发送信息。

代码如下：

ServerMonitor.cs

 

              using System;using System.Collections.Generic;using System.linq;using System.Text;using System.Net.sockets;using System.Net;using System.IO;using System.Threading;using System.Collections;namespace SocketTestServer{    public class ServerMonitor    {       public static  List<Socket> socketList = new List<Socket>();        public ServerMonitor()        {            Console.Writeline("=====Socket监听服务开启=====");        }        //监听策略请求和发送策略请求方法        public voID PolicyThread()        {            //创建一个Socket用来监听943（固定的）端口的策略请求                   Socket policy = new Socket(AddressFamily.InterNetwork,ProtocolType.Tcp);            policy.Bind(new IPEndPoint(IPAddress.Any,943));            policy.Listen(10);            while (true)            {                Socket _policy = policy.Accept();                string policyRequestString = "<policy-file-request/>";//固定                byte[] b = new byte[policyRequestString.Length];                _policy.Receive(b);                string requeststring = System.Text.EnCoding.UTF8.GetString(b,b.Length);                Console.Writeline(requeststring);                if (requeststring == policyRequestString)                {                    SendPolicy(_policy);                    Console.Writeline("Policy file have sended");                    _policy.Close();                }                else                {                    Console.Writeline("not a sure request string!");                }            }        }        //监听信息请求和发送信息方法        public voID InfoThread()        {            //创建一个Socket用于监听4502端口，获取接收客户端发送过来的信息            Socket socket = new Socket(AddressFamily.InterNetwork,ProtocolType.Tcp);            socket.Bind(new IPEndPoint(IPAddress.Any,4502));            socket.Listen(4);            while (true)            {                Socket _socket = socket.Accept();                IPEndPoint endPoint = _socket.RemoteEndPoint as IPEndPoint;                string ipAddress = endPoint.Address.ToString();                socketList.Add(_socket);                ThreadStart work = new ThreadStart(new ThreaDWork(_socket).DoWork);                Thread threaDWork = new Thread(work);                threaDWork.name = ipAddress;                threaDWork.Start();            }        }        //发送策略文件的方法，参数是传递进来的Socket连接        public voID SendPolicy(Socket socket)        {            //创建一个文件流，该文件留指定代开一个策略文件，至于策略文件的格式，MS的Silverlight有详细说明和配置方法            fileStream fs = new fileStream(@"D:/Policyfile.xml",fileMode.Open);             int length = (int)fs.Length;            byte[] bytes = new byte[length];            fs.Read(bytes,length);            fs.Close();            socket.Send(bytes,length,SocketFlags.None);        }        protected class ThreaDWork        {            private Socket socket;            public ThreaDWork(Socket socket)            {                this.socket = socket;            }            public voID DoWork()            {                IPEndPoint endPoint = socket.RemoteEndPoint as IPEndPoint;                string ipAddress = endPoint.Address.ToString();                while(true)                {                    try                    {                        byte[] b2 = new byte[1024];                        int count = socket.Receive(b2);                        Console.Writeline(EnCoding.UTF8.GetString(b2,count));                        Console.Writeline("当前的线程名称为：" + Thread.CurrentThread.name);                        socket.Send(EnCoding.UTF8.GetBytes(ipAddress));                    }                    catch (Exception ex)                    {                        if (socketList.Contains(this.socket))                             socketList.Remove(this.socket);                        Console.Writeline("有一个远程连接 " + ipAddress + " 关闭");                        break;                    }                }            }        }    }}      

 

Program.cs

 

              using System;using System.Collections.Generic;using System.linq;using System.Text;using System.Threading;using System.Net.sockets;using System.Net;using System.IO;using System.Collections;namespace SocketTestServer{    class Program    {        private static List<Socket> List;        private static ServerMonitor server;        static voID Main(string[] args)        {            //Console.Writeline("================Socket服务开启======================");            server = new ServerMonitor();            //建立一个线程，用于创建Socket来监听策略请求和发送。            ThreadStart pcts = new ThreadStart(server.PolicyThread);            Thread policythread = new Thread(pcts);            policythread.Start();            //建立一个线程，用于创建Socket来监听信息请求和发送。            ThreadStart infots = new ThreadStart(server.InfoThread);            Thread infothread = new Thread(infots);            infothread.Start();            //建立一个线程。用于测试Server端详ClIEnt端发送信息            ThreadStart SendMessage = new ThreadStart(SendMsg);            Thread thread = new Thread(SendMessage);            thread.Start();        }        static voID SendMsg()        {            while (true)            {                //每隔六秒，向所有连接到Server端的ClIEnt发送信息                Thread.Sleep(6000);                List = ServerMonitor.socketList;                foreach (Socket s in List)                {                    try                    {                        IPEndPoint endPoint = s.RemoteEndPoint as IPEndPoint;                        string msg = endPoint.Address.ToString();                        s.Send(EnCoding.UTF8.GetBytes(msg));                    }                    catch (Exception ex)                    {                        if (List.Contains(s))                             List.Remove(s);                        Console.Writeline("有一个连接ClIEnt关闭");                    }                }                Console.Writeline("Now Connection Count is "+List.Count);            }        }    }}      

总结

以上是内存溢出为你收集整理的Silverlight Socket异步通信 范例 Demo全部内容，希望文章能够帮你解决Silverlight Socket异步通信 范例 Demo所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。