金沙国际官网_金沙国际平台登录

因为这个金沙国际官网_金沙国际平台登录网站与很多的大型澳门赌场都有合作,金沙国际官网_金沙国际平台登录尽职尽责,高效执行,保持好奇心,不断学习,追求卓越,点击进入金沙国际官网_金沙国际平台登录马上体验吧,所以现在也正式地开始了营业。

您的位置:金沙国际官网 > 编程 > mvc中路由的投射和实现IHttpHandler挂载,WebSocket和

mvc中路由的投射和实现IHttpHandler挂载,WebSocket和

发布时间:2019-11-02 02:11编辑:编程浏览(185)

    .net 信息采集ajax数据

    介绍:

    前面写过一篇简单的websocke实现服务端。这一篇就不在说什么基础的东西主要是来用实例说话,主要是讲一下实现单聊和群组聊天和所有群发的思路设计。

    直接不懂的可以看一下上一篇简单版本再来看也行:实现服务端WebSocket传送门

    首先我们了解一下一般的方法

        我们只需要在web.config配置文件中做映射处理即可。

    关于.net信息采集的资料很多,但是如果采集的网站是ajax异步加载数据的模式,又如何采集呢?今天就把自己做信息采集时,所遇到的一些问题和心得跟大家分享一下。

    实现效果:

    本示例主要实现了个什么东西哪,我们都使用qq或者其他的聊天工具,所有下面我说的大家也都懂。就不啰嗦废话了。

    首先说实现6个主要的功能:

    • 单聊:可以指定人进行聊天。
    • 群发:这个的意思就是当前服务器内的所有人包含自己,这个就跟一个推送效果一样。
    • 开启连接(客户端):通知除自己以外的所有用户
    • 金沙国际官网,关闭连接(客户端):通知除自己以外的所有用户
    • 群组A:实现一个群组名字为A
    • 群组B:实现一个群组名字为B

    好了基本就是这个大致功能。下面看下最终效果吧:

    金沙国际官网 1金沙国际官网 2金沙国际官网 3

    以上是第一个图先进入了A群组,后面两个在B群组。然后A有进入了B群组,所有第一张图可以收到所有聊天,但是后面两张只能收到B群组的聊天。

    第一种形式:

     <system.web>
        <urlMappings enabled="true">
    
          <add url="~/d" mappedUrl="SmackBio.WebSocketSDK.GenericHandler"/>
    
        </urlMappings>
    

    注释:这里的url就是我们需要在请求的具体写法,然后mappedUrl则是我们实际项目中的处理位置。

    第二种形式:

     <system.webServer>
        <validation validateIntegratedModeConfiguration="false" />
        <handlers>    
          <add path="/socket" verb="*" name="GenericHandler" type="SmackBio.WebSocketSDK.GenericHandler"/>
        </handlers>
      </system.webServer>
    

    注释:这里的path就是我们请求的入口地址,type则是我们的实际项目中的方法类位置。

    采集网站的几种方式与利弊:

     开始撸代码(socket版)

    因为是在上面说道的文章改造的,所有基本的三连击(开启服务,开启监听,接受事件)我就不介绍了。

    mvc路由配置方法

    这是我们不同使用的映射形式。但是在mvc路由中我们挂起一般处理程序却发现行不通了,下面我们就要配置路由方法进行映射。

    在mvc中我们分为三步:

        1.实现处理代码程序(实现一般处理程序继承类IHttpHandler)

    金沙国际官网 4金沙国际官网 5

     1   public class GenericHandler : IHttpHandler
     2     {
     3         public void ProcessRequest(HttpContext context)
     4         {
     5             if (context.IsWebSocketRequest || context.IsWebSocketRequestUpgrading)
     6             {
     7                 context.AcceptWebSocketRequest(new SBWebSocketHandler());
     8             }
     9             else
    10             {
    11                 context.Response.ContentType = "text/plain";
    12                 context.Response.Write("Service running");
    13             }
    14         }
    15 
    16         public bool IsReusable
    17         {
    18             get
    19             {
    20                 return false;
    21             }
    22         }
    23     }
    

    View Code

        2.定义一个类路由规则(实现路由IRouteHandler接口然后指向处理代码程序类)

    金沙国际官网 6金沙国际官网 7

     public class PlainRouteHandler : IRouteHandler
        {
    
            public IHttpHandler GetHttpHandler(RequestContext requestContext)
            {
                return new GenericHandler();
            }
        }
    
     public static void RegisterHandler(RouteCollection routes)
            {
    
                RouteTable.Routes.Add("socket",
                     new Route("socket", new MvcZodiac.Controllers.PlainRouteHandler()));
            }
    

    View Code

     

        3.注册到程序中(在Global.asax中的Application_Start方法注册)

     RegisterHandler(RouteTable.Routes);
    

     这里补充一下,这句话一定要写在路由注册之前,不然不会起作用。例如:

    金沙国际官网 8

     

    1. HttpWebRequest

    思路分析

    我们既然实现的是聊天,那么跟谁聊天当然是其他人,所以我们应该有其他人,可是问题又来了我们登录了如何确认记录状态哪,我登录之后我可以跟服务器通讯,怎么找到其他人进行通讯哪?我就是想到的是使用字典Dictionary来进行存储,为什么用字典而不用list是因为,字典中是键值储存,我们把键当作人,然后值存储这个人的通讯连接,这样我只要知道这个人就在里面找到这个人,然后就取到这个人的连接就可以通讯了。

            //建立登录用户记录信息
            public static Dictionary<string, Socket> ListUser = new Dictionary<string, Socket>();
    

    注:写完这个之后我们老大看了下我的代码说你这个存在一个问题:线程安全,确实的Dictionary不是线程安全,当时写的时候没多想,他说完我就想起来了,以前用Paralle时候用到的线程安全类ConcurrentBag和ConcurrentDictionary,在这了当然可以改成:

           //建立登录用户记录信息
            public static ConcurrentDictionary<string, Socket> ListUser = new ConcurrentDictionary<string, Socket>();
    

    好了我们可以进行通讯了,可以找到指定的人进行通讯了,那当然所有人的通讯也可以解决了。所有我就直接说下开启连接和关闭连接的通知。我在消息接受和消息发送的时候定义了自己的规则:

    开启连接:我在发送的时候最前面带:login字符串告诉消息接受我现在是登录,你告诉别人吧。

    关闭连接:退出的时候没有发送字符串所以为空

     ws.send("login,我已经连接上了!!!");
    

      ws.close();
      alert("关闭了通讯")

    然后我在消息处理增加了判断处理:

                       if (string.IsNullOrEmpty(resultList[0]))
                        {
                            //退出                       
                            SignOut(myClientSocket.RemoteEndPoint.ToString());
                            ListUser.Remove(myClientSocket.RemoteEndPoint.ToString());
                            myClientSocket.Shutdown(SocketShutdown.Both);
                            myClientSocket.Close();
                            Debug.WriteLine("当前退出用户:" + myClientSocket.RemoteEndPoint.ToString());
                        }
                        else if (resultList[0] == "login")
                        {
                            //登录
                            Login(myClientSocket.RemoteEndPoint.ToString());
                            ListUser.Add(myClientSocket.RemoteEndPoint.ToString(), myClientSocket);
                            Debug.WriteLine("当前登录用户:" + myClientSocket.RemoteEndPoint.ToString());
                        }
    

    大致其他的思路也是这个样子:单聊,群发,群组都是定义相应的规则来进行判断然后进行单独的业务。

    利用系统自带HttpWebRequest对象,采集网站内容,优点是采集效率快,但是如果网站是ajax异步加载数据的方式,是采集不到网页内容的,并且网站没有采用ajax的方式,在网页中用到了javascript,比如说:网页内容用document.write的方式输出到网页中的,这种情况也是获取不到内容的。其次还需要知道对方网站的编码格式(就是网页头部中<meta charset="utf-8"/>),如果采集时网站编码格式错误的话,会导致采集的内容是乱码。但这个是小问题,我自己当时查阅资料时找到了别人封装好的方法,但是很惭愧因为不知道作者是谁了,我会把相应的代码下载链接提供给大家。以上的问题是因为js和ajax是需要浏览器去解析的,所以导致了获取不到网页内容。

    全部判断逻辑代码

    这里是写在了服务端的消息接受ReceiveMessage方法内,这个方法是一个统一的发送接受方法。想看原方法的请看上一篇:实现服务端WebSocket传送门

    我这里只是写了我要做的效果,当然可以自己随便修改的。

    金沙国际官网 9金沙国际官网 10

     var resultStr = AnalyzeClientData(result, receiveNumber);
                        string[] resultList = resultStr.Split(',');
                        //string sendMsg = $"你({myClientSocket.RemoteEndPoint.ToString()}):" + resultList[1] + "【服务端回复】";
                        //myClientSocket.Send(SendMsg(sendMsg));//取消对自己提示发送给别人
                        if (string.IsNullOrEmpty(resultList[0]))
                        {
                            //退出                       
                            SignOut(myClientSocket.RemoteEndPoint.ToString());
                            ListUser.Remove(myClientSocket.RemoteEndPoint.ToString());
                            myClientSocket.Shutdown(SocketShutdown.Both);
                            myClientSocket.Close();
                            Debug.WriteLine("当前退出用户:" + myClientSocket.RemoteEndPoint.ToString());
                        }
                        else if (resultList[0] == "login")
                        {
                            //登录
                            Login(myClientSocket.RemoteEndPoint.ToString());
                            ListUser.Add(myClientSocket.RemoteEndPoint.ToString(), myClientSocket);
                            Debug.WriteLine("当前登录用户:" + myClientSocket.RemoteEndPoint.ToString());
                        }
                        else if (resultList[0] == "all")
                        {
                            //群发所有用户
                            GroupChat(myClientSocket.RemoteEndPoint.ToString(), resultList[1]);
                        }
                        else if (resultList[0] == "groupA")
                        {
                            //群组发送
                            GroupChatA("groupA", myClientSocket.RemoteEndPoint.ToString(), resultList[1]);
                        }
                        else if (resultList[0] == "groupB")
                        {
                            //群组发送
                            GroupChatA("groupB", myClientSocket.RemoteEndPoint.ToString(), resultList[1]);
                        }
                        else
                        {
                            //单聊
                            SingleChat(myClientSocket.RemoteEndPoint.ToString(), resultList[0], resultList[1]);
                        }
    

    View Code

    逻辑判断完成就进入相应的业务方法了,下面我把每一个业务方法放上来。

    Help.HttpHelp.HttpRequest("采集的网址");
    

    开启连接

    金沙国际官网 11金沙国际官网 12

    #region  登录提示别人
            public void Login(string userId)
            {
                if (ListUser.Count() > 0)
                {
                    foreach (var item in ListUser)
                    {
                        if (item.Key != userId)
                        {
                            Socket socket = item.Value;
                            try
                            {
                                socket.Send(SendMsg($"用户({userId})登录了"));
                            }
                            catch (Exception e)
                            {
                                Debug.WriteLine("该用户已掉线:" + item.Key);
                                //用户已掉线就删除掉
                                ListUser.Remove(item.Key);
                            }
                        }
                    }
    
                }
    
            }
            #endregion
    

    View Code

    源码下载地址

    关闭连接

    金沙国际官网 13金沙国际官网 14

    #region  退出提示别人
            public void SignOut(string userId)
            {
                if (ListUser.Count() > 0)
                {
                    foreach (var item in ListUser)
                    {
                        if (item.Key != userId)
                        {
                            Socket socket = item.Value;
                            try
                            {
                                socket.Send(SendMsg($"用户({userId})退出了"));
                            }
                            catch (Exception e)
                            {
                                Debug.WriteLine("该用户已掉线:" + item.Key);
                                //用户已掉线就删除掉
                                ListUser.Remove(item.Key);
                            }
                        }
                    }
    
                }
    
            }
            #endregion
    

    View Code

              2.浏览器控件

    单聊

    金沙国际官网 15金沙国际官网 16

    #region 单聊
            public void SingleChat(string userIdA, string userIdB, string msg)
            {
                Socket socket = ListUser[userIdB];
                if (socket != null)
                {
                    try
                    {
                        socket.Send(SendMsg($"用户({userIdA}=>{userIdB}):{msg}"));
                    }
                    catch (Exception e)
                    {
                        Debug.WriteLine("该用户已掉线:" + userIdB);
                        //用户已掉线就删除掉
                        ListUser.Remove(userIdB);
                    }
                }
    
            }
            #endregion
    

    View Code

    因为当时我开发的时候,用的是cs模式,相信大家同样也会用cs的模式去开发这个功能。既然是cs模式(不考虑美观)的情况下肯定是WinForm,WinForm中有自带的浏览器控件,这个是不好用的,我当时用的是Geckofx,基于火狐内核的一款浏览器控件,但是这方面的资料很少,当时遇到了一些问题都找不到解决方法,但后来还是都解决了。用了该控件就可以获取到ajax异步加载的数据,在网页加载完成之后,延迟几秒钟获取网页内容,就可以很方便的获取到网页内容,缺点是相对第一种方案来说的话会慢一些,因为它是一个浏览器控件,需要渲染html和解析js等操作。

    群发所有人

    金沙国际官网 17金沙国际官网 18

    #region 群发
            public void GroupChat(string userId, string msg)
            {
                if (ListUser.Count() > 0)
                {
                    foreach (var item in ListUser)
                    {
                        if (item.Key != userId)
                        {
                            Socket socket = item.Value;
                            try
                            {
                                socket.Send(SendMsg($"用户({userId}=>{item.Key}):{msg}"));
                            }
                            catch (Exception e)
                            {
                                Debug.WriteLine("该用户已掉线:" + item.Key);
                                //用户已掉线就删除掉
                                ListUser.Remove(item.Key);
                            }
                        }
                    }
    
                }
    
            }
            #endregion
    

    View Code

    Geckofx下载

    群组实现

    金沙国际官网 19金沙国际官网 20

    #region 实现群组
    
            //群组记录分类
            List<GroupHelp> groupList = new List<GroupHelp>();
            public void GroupChatA(string groupName, string userId, string msg)
            {
                if (string.IsNullOrEmpty(groupName))
                {
                    return;
                }
                //判断自己是否在群组
                GroupHelp isEisx = groupList.Where(b => b.userId == userId && b.Name == groupName).FirstOrDefault();
                if (isEisx == null)
                {
                    groupList.Add(new GroupHelp()
                    {
                        Name = groupName,
                        userId = userId
                    });
                }
                //根据群组名称判断是否存在群组
                var nowGroupList = groupList.Where(b => b.Name == groupName).ToList();
                foreach (var itemG in nowGroupList)
                {
                    Socket socket = ListUser[itemG.userId];
                    try
                    {
                        socket.Send(SendMsg($"用户({userId}=>{itemG.userId}):{msg}"));
                    }
                    catch (Exception e)
                    {
                        Debug.WriteLine("该用户已掉线:" + itemG.userId);
                        //用户已掉线就删除掉
                        ListUser.Remove(itemG.userId);
                    }
                }
            }
            #endregion
    

    View Code

    本文由金沙国际官网发布于编程,转载请注明出处:mvc中路由的投射和实现IHttpHandler挂载,WebSocket和

    关键词:

上一篇:没有了

下一篇:没有了