Silverlight Socket异步通信范例 Demo

最近刚接触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" ShowGridLi<a href="https://www.jb51.cc/tag/nes/" target="_blank" class="keywords">nes</a>="True">
         <Grid.RowDe<a href="https://www.jb51.cc/tag/Finitio/" target="_blank" class="keywords">Finitio</a>ns >
             <RowDe<a href="https://www.jb51.cc/tag/Finitio/" target="_blank" class="keywords">Finitio</a>n />
             <RowDe<a href="https://www.jb51.cc/tag/Finitio/" target="_blank" class="keywords">Finitio</a>n />
         </Grid.RowDe<a href="https://www.jb51.cc/tag/Finitio/" target="_blank" class="keywords">Finitio</a>ns>
 
         <Text<a href="https://www.jb51.cc/tag/Box/" target="_blank" class="keywords">Box</a> x:Name="txtToSend" Grid.Row="0"/>
         <Button Grid.Row="1" Click="OnSend" Content="Send" Margin="20" />
     </Grid>

Client端CS代码：

   
   
    
    using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Linq;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Controls;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Documents;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Input;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Media;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Media.Animation;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Windows.Shapes;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Threading;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Text;

namespace SocketTest
{
    public partial class MainPage : UserControl
    {
        //SilverlightSocket通信是基于异步的Socket通信，为了保持有<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>Socket一直处于Receive状态，所以设置两个Socket进行通信
        private SynchronizationContext syn;//同步上下文
        private Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket sendSocket;//用于发送信息的Socket
        private <a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> sendSocketArgs;//发送信息的Socket参数
        private Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket receiveSocket;//用于接收信息的Socket
        private <a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> receiveSocketArgs;//用于接收信息的Socket参数
        private string remoteIPAddress;//远程连接的IP地址
        public MainPage()
        {
            //初始化
            InitializeComponent();
            syn = SynchronizationContext.Current;
            sendSocket=new Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
            receiveSocket=new Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket(AddressFamily.InterNetwork,ProtocolType.Tcp);
            sendSocketArgs = new <a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a>();
            receiveSocketArgs = new <a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a>();
            remoteIPAddress = "10.6.1.69";
            SocketPrepare(sendSocket,sendSocketArgs);
            SocketPrepare(receiveSocket,receiveSocketArgs);
        }
        protected void SocketPrepare(Socket _socket,<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> _socketArgs)
        {
            byte[] bytes = Encoding.UTF8.GetBytes("Prepare");
            _socketArgs.UserToken = bytes;
            //Silverlight通信端口有严格的规定，具体查看文档
            _socketArgs.RemoteEndPoint = new DnsEndPoint(remoteIPAddress,4502);
            _socketArgs.Completed += new EventHandler<<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a>>(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,<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> e)
        {
            Socket s = sender as Socket;
            switch (e.LastOperation)
            {
                case SocketAsyn<a href="https://www.jb51.cc/tag/cop/" target="_blank" class="keywords">cop</a>eration.Connect:
                    ProcessConnect_Send(s,e);
                    break;
                case SocketAsyn<a href="https://www.jb51.cc/tag/cop/" target="_blank" class="keywords">cop</a>eration.Receive:
                    ProcessReceive_Post(s,e);
                    break;
                case SocketAsyn<a href="https://www.jb51.cc/tag/cop/" target="_blank" class="keywords">cop</a>eration.Send:
                    ProcessSend_Receive(s,e);
                    break;
            }
        }
        void ProcessConnect_Send(Socket tmpSocket,<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> e)
        {
            //从UserToken获得要发送的<a href="https://www.jb51.cc/tag/neirong/" target="_blank" class="keywords">内容</a>
            byte[] bytes = (byte[])e.UserToken;
            e.SetBuffer(bytes,bytes.Length);
            tmpSocket.SendAsync(e);

        }
        void ProcessSend_Receive(Socket tmpSocket,<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> e)
        {
            byte[] bytes = new byte[30];
            e.SetBuffer(bytes,bytes.Length);
            tmpSocket.ReceiveAsync(e);
        }
        void ProcessReceive_Post(Socket tmpSocket,<a href="https://www.jb51.cc/tag/socketasynceventargs/" target="_blank" class="keywords">socketasynceventargs</a> e)
        {
            syn.Post(GetText,Encoding.UTF8.GetString(e.Buffer,e.Buffer.Length) + " and Received");
            //为了保证有<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>Socket一直处在Receive状态，所以在接收到第一<a href="https://www.jb51.cc/tag/cishu/" target="_blank" class="keywords">次数</a>据之后，继续进入Receive状态
            if (tmpSocket == receiveSocket) tmpSocket.ReceiveAsync(e);
        }
        void GetText(object str)
        {
            txtToSend.Text += "/r/n" + str.ToString();
        }
    }
}

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

代码如下：

ServerMonitor.cs

   
   
    
    using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Linq;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Text;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.IO;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Threading;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Collections;

namespace SocketTestServer
{
    public class ServerMonitor
    {
       public static  List<Socket> socketList = new List<Socket>();
        public ServerMonitor()
        {
            Console.WriteLine("=====Socket监听服务开启=====");
        }
        //监听策略请求和发送策略请求<a href="https://www.jb51.cc/tag/fangfa/" target="_blank" class="keywords">方法</a>
        public void PolicyThread()
        {
            //创建<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>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 = Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.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!");
                }
            }
        }
        //监听信息请求和发送信息<a href="https://www.jb51.cc/tag/fangfa/" target="_blank" class="keywords">方法</a>
        public void InfoThread()
        {
            //创建<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>Socket用于监听4502端口，<a href="https://www.jb51.cc/tag/huoqu/" target="_blank" class="keywords">获取</a>接收客户端发送过来的信息
            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();
            }
        }
        //发送策略<a href="https://www.jb51.cc/tag/wenjian/" target="_blank" class="keywords">文件</a>的<a href="https://www.jb51.cc/tag/fangfa/" target="_blank" class="keywords">方法</a>，参数是传递进来的Socket连接
        public void SendPolicy(Socket socket)
        {
            //创建<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a><a href="https://www.jb51.cc/tag/wenjian/" target="_blank" class="keywords">文件</a>流，该<a href="https://www.jb51.cc/tag/wenjian/" target="_blank" class="keywords">文件</a>留指定代开<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>策略<a href="https://www.jb51.cc/tag/wenjian/" target="_blank" class="keywords">文件</a>，至于策略<a href="https://www.jb51.cc/tag/wenjian/" target="_blank" class="keywords">文件</a>的格式，MS的Silverlight有详细说明和配置<a href="https://www.jb51.cc/tag/fangfa/" target="_blank" class="keywords">方法</a>
            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<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket = 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("当前的线程<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>为：" + Thread.CurrentThread.Name);
                        socket.Send(Encoding.UTF8.GetBytes(ipAddress));
                    }
                    catch (Exception ex)
                    {
                        if (socketList.Contains(this<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket))
                             socketList.Remove(this<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cket);
                        Console.WriteLine("有<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>远程连接 " + ipAddress + " <a href="https://www.jb51.cc/tag/guanbi/" target="_blank" class="keywords">关闭</a>");
                        break;
                    }
                }
            }
        }

    }
}

Program.cs

   
   
    
    using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Linq;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Text;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Threading;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>ckets;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.Net;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.IO;
using Sy<a href="https://www.jb51.cc/tag/stem/" target="_blank" class="keywords">stem</a>.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();
            //建立<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>线程，用于创建Socket来监听策略请求和发送。
            ThreadStart pcts = new ThreadStart(server.PolicyThread);
            Thread policythread = new Thread(pcts);
            policythread.Start();
            //建立<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>线程，用于创建Socket来监听信息请求和发送。
            ThreadStart infots = new ThreadStart(server.InfoThread);
            Thread infothread = new Thread(infots);
            infothread.Start();
            //建立<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>线程。用于测试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<a href="https://www.jb51.cc/tag/so/" target="_blank" class="keywords">.so</a>cketList;
                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("有<a href="https://www.jb51.cc/tag/yige/" target="_blank" class="keywords">一个</a>连接Client<a href="https://www.jb51.cc/tag/guanbi/" target="_blank" class="keywords">关闭</a>");
                    }
                }
                Console.WriteLine("<a href="https://www.jb51.cc/tag/Now/" target="_blank" class="keywords">Now</a> Connection Count is "+list.Count);
            }
        }
    }
}

Silverlight Socket异步通信 范例 Demo

相关文章

Silverlight Socket异步通信范例 Demo