SignalR从。。。到。。。

---

Signal搭建一个聊天室。

Signal框架学习

1.引入NuGut包
ASPNET.net.Signal.Hubs

新建一个owin startup类
代码：

 public void Configuration(IAppBuilder app)
        {
            // 有关如何配置应用程序的详细信息，请访问 http://go.microsoft.com/fwlink/?LinkID=316888
           // ConfigureAuth(app);
            var hubConfiguration = new HubConfiguration();

            hubConfiguration.EnableDetailedErrors = true;
            GlobalHost.Configuration.DisconnectTimeout = TimeSpan.FromSeconds(8);
            app.MapSignalR(hubConfiguration);
        }

2.新建一个集线器signalR类

思路：
服务端写法 :

   public void Send(@1) (string Message)
   {
       //发送给所有客户端
       Client.All.broadcastMessage(@2)(message);
   }

客户端调用方法：

 new 一个 IHubProxy  hub;

 ///创建一个连接
 var connection = new HubConnection("Hub服务地址（调试的时候一般为 localhost:端口）”);

 ///调用服务端方法的接口
 hub = connection.Create("Hub类名");  


 客户端调用方式：
 ///这部分相当于注册事件
 hub.On("@2",(返回数据)=>{ 返回数据的处理 });

 hub.Invoke("@1",参数);//这步相当于触发事件。

服务端代码

  public class ChatHub : Hub
    {


        public static List<string> Onlineusers = new List<string>();

        public static List<string> messageCache = new List<string>();
        /// <summary>
        /// 广播消息
        /// </summary>
        /// <param name="username"></param>
        /// <param name="message"></param>     
        
        public void Send(string SendID,string message)
        {
            Clients.All.broadcastMessage(Context.ConnectionId, message);
            messageCache.Add(Context.ConnectionId + message);
            //Clients.All.refresh()
           // Clients.All.addMessage(username + message);
            
        }


        public void p2p(string ReciveID,string SendID,string SendMessage)
        {

            
            Clients.Client(ReciveID).sendP2pMessage(ReciveID, SendMessage);
            messageCache.Add(SendID + "发送了" + SendMessage + "给" + ReciveID);
            
        }


        /// <summary>
        /// 获取信息列表。详细看客户端。
        /// </summary>
        /// <param name="clinetID"></param>
        public void GetMesList(string clinetID)
        {
            StringBuilder sb = new StringBuilder();
            foreach (var item in messageCache)
            {
                sb.AppendLine(item);

            }
            Clients.Client(clinetID).SendList(sb.ToString());

        }
        /// <summary>
        /// 获取用户列表
        /// </summary>
        /// <returns></returns>

        public void GetOnline(string ClientID)
        {
            StringBuilder sb = new StringBuilder();
            foreach (var item in Onlineusers)
            {
                sb.Append("*"+item);
            }
            Clients.Client(ClientID).SendUserList(sb.ToString());
        }
        public override Task OnConnected()
        {
            Onlineusers.Add(Context.ConnectionId);
            Clients.All.broadcastMessage(Context.ConnectionId, "加入了服务器");

            StringBuilder sb = new StringBuilder();
            foreach (var item in Onlineusers)
            {
                sb.Append("*" + item);
            }
            Clients.All.SendUserList(sb.ToString());
            Clients.All.broadcastMessage("当前在线人数", Onlineusers.Count + "人");
            return base.OnConnected();
        }

        public override Task OnDisconnected(bool stopCalled)
        {
            Onlineusers.Remove(Context.ConnectionId);
            Clients.All.broadcastMessage(Context.ConnectionId, "离开了服务器");
            StringBuilder sb = new StringBuilder();
            foreach (var item in Onlineusers)
            {
                sb.Append("*" + item);
            }
            Clients.All.SendUserList(sb.ToString());
            Clients.All.broadcastMessage("当前在线人数", Onlineusers.Count + "人");
            return base.OnConnected();
        }



    }

客户端代码：

 public partial class Form1 : Form
    {


        /// <summary>
        /// hub句柄
        /// </summary>
        IHubProxy hub;
        string name = "";

        public Form1()
        {
            InitializeComponent();
            

        }
    

        private void button1_Click(object sender, EventArgs e)
        {
            var connection = new HubConnection(textBox1.Text);
            hub = connection.CreateHubProxy(textBox2.Text);

            connection.Error += error => MessageBox.Show(error.ToString());
            try
            {
                connection.Start().Wait();
                name = connection.ConnectionId;
                hub.On<string, string>("broadcastMessage", (m, s) =>
                {
                  
                        textBoxRecive.Invoke(new MethodInvoker(() => { this.textBoxRecive.AppendText(m +"说："+s + "\r\n"); }));
                });

                hub.On<string, string>("sendP2pMessage", (c, m) =>
                {
                    textBoxRecive.Invoke(new MethodInvoker(() => { this.textBoxRecive.AppendText(c+"说："+m + "\r\n"); }));
                });



                hub.On<string>("SendUserList", (listvalue) =>
                {
                    textBoxRecive.Invoke(new MethodInvoker(() =>
                    {
                      
                        string[] str = listvalue.Trim().Split('*');
                        List<string> values = new List<string>();
                        textBoxDic.AppendText("当前在线用户 ：" + "\r\n");
                        foreach (var item in str)
                        {
                            if(item!="")
                            {
                                values.Add(item);
                                textBoxDic.AppendText(item + "\r\n");
                            }

                        }
                        
                        comboBox1.DataSource = values;
                        comboBox1.SelectedIndex = 0;
                        
                    }));

                });

                ///这里是触发该次回调的调用过程。
                hub.Invoke("GetOnline", name);

                // hub.Invoke("Send", "", name);

                MessageBox.Show("连接成功!");
                label4.Text = name;
            }
            catch(Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }

        }



        /// <summary>
        /// 表示调用信息列表。
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button4_Click(object sender, EventArgs e)
        {
            

            ///这里可以理解为注册回调。 listValue为回调的接收data.
            hub.On<string>("SendList", (listvalue) =>
             {
                 textBoxRecive.Invoke(new MethodInvoker(() =>
                 {
                     textBoxDic.AppendText("缓存数据" + "\r\n" + listvalue+"\r\n");
                 }));

             });

            ///这里是触发该次回调的调用过程。
           hub.Invoke("getMesList",name);


        }

        private void button2_Click(object sender, EventArgs e)
        {
            if (radioButton2.Checked)
            {
                ///发送点对点消息 第一个参数 接收者ID 第二个参数 发送ID 第三个参数 发送内容。
                hub.Invoke("p2p", comboBox1.Text, name, textBoxSend.Text);

            }
            else
            {
                hub.Invoke("Send", name, this.textBoxSend.Text);
            }
           
        }

        private void button3_Click(object sender, EventArgs e)
        {
            hub.Invoke("Send", "测试数据");
        }


       
    }

Web页面客户端简单实现：

<!DOCTYPE html>
<html>
<head>
    <title>SignalR Simple Chat</title>
    <style type="text/css">
        .container {
            background-color: #99CCFF;
            border: thick solid #808080;
            padding: 20px;
            margin: 20px;
        }
    </style>
</head>
<body>
    <div class="container">
        <input type="text" id="message" />
        <input type="button" id="sendmessage" value="Send" />
        <input type="hidden" id="displayname" />
        <div id="mineID"></div>
        <ul id="discussion"></ul>
    </div>
    <script src="Scripts/jquery-1.6.4.js"></script>
    <script src="Scripts/jquery.signalR-2.2.1.js"></script>
    <!--Reference the autogenerated SignalR hub script. -->
    <script src="signalr/hubs"></script>    
    <!--Add script to update the page and send messages.-->
    <script type="text/javascript">
        $(function () {
            // Declare a proxy to reference the hub.
            var chat = $.connection.chatHub;
            // Create a function that the hub can call to broadcast messages.

            //var name = chat.client.connection.oncl
            //$('#mineID').append("<p>" + name + "</p>");

            var name;
            chat.client.broadcastMessage = function (username, message) {
                // Html encode display name and message.
                var encodedName = $('<div />').text(username).html();
                var encodedMsg = $('<div />').text(message).html();
                // Add the message to the page.
                $('#discussion').append('<li><strong>' + encodedName
                    + '</strong>:  ' + encodedMsg + '</li>');
            };

          

             
           
            // Get the user name and store it to prepend to messages.
            //$('#displayname').val(prompt('Enter your name:', ''));
            // Set initial focus to message input box.
            //$('#message').focus();
            // Start the connection.
            $.connection.hub.start().done(function () {
                $('#sendmessage').click(function () {
                    // Call the Send method on the hub.
                    chat.server.send($('#displayname').val(), $('#message').val());
                    // Clear text box and reset focus for next comment.
                    $('#message').val('').focus();
                });
            });
        });
    </script>
</body>
</html>

————————————————————————————————我是有底线的———————————————————————————————————————