结合 WebService 实现消息 主动推送到客户端

说明:不需要复杂的技术,不需要长轮循,还是老技术实现,上代码

1.消息实体

    public class NoticeModel {
        public string Sender { get; set; }
        public string Reciever { get; set; }
        public string Content { get; set; }
        public DateTime SendDateTime { get; set; }
    } 
 
2. 消息队列
 
    public class NoticeQueen {
        private ManualResetEvent resetEvent = new ManualResetEvent(false);
        private Queue<NoticeModel> queue = new Queue<NoticeModel>();
 
        public void EnQueen(NoticeModel noticeModel) {
            lock (queue) {
                queue.Enqueue(noticeModel);
                resetEvent.Set();
            }
        }
 
        public NoticeModel DeQueen() {
            resetEvent.WaitOne();
            lock (queue) {
                if (this.queue.Count == 1) {
                    this.resetEvent.Reset();
                }
                return queue.Dequeue();
            }
        }
    } 

3.消息适配
 
   public class NoticeAdapter {
 
        public Dictionary<string,NoticeQueen> noticeQueens = new Dictionary<string,NoticeQueen>();
 
        public static NoticeAdapter NoticeAdapterInstance = new NoticeAdapter();
 
        public string AddClient(string clientName) {
            try {
                if (!this.noticeQueens.ContainsKey(clientName)) {
                    this.noticeQueens[clientName] = new NoticeQueen();
                }
                return clientName;
            }
            catch (Exception) {
                return null;
            }
        }
        public void AddNotice(NoticeModel noticeModel) {
            if (noticeQueens.ContainsKey(noticeModel.Reciever)) {
                NoticeAdapterInstance.noticeQueens[noticeModel.Reciever].EnQueen(noticeModel);
            }
        }
 
        public NoticeModel GetNotice(NoticeModel noticeModel) {
            if (noticeQueens.ContainsKey(noticeModel.Reciever)) {
                return NoticeAdapterInstance.noticeQueens[noticeModel.Reciever].DeQueen();
            }
            return new NoticeModel();
        }
 
    }
 
4.消息接收页
 
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="NoticeReciever.aspx.cs" Inherits="WebApplication.SiteNotice.NoticeReciever" %>
 
<!DOCTYPE html>
 
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
    <title></title>
    <script src="../Scripts/jquery-1.10.2.min.js"></script>
    <script src="../Scripts/myJQAjax.js"></script>
    <script src="../Scripts/myJQDialog.js"></script>
    <script>
        var webServ;
        $(function () {
            webServ = WebApplication.SiteNotice.SiteNoticeServ;
            GetNotice();
        });
 
 
        function GetNotice() {
            webServ.WaiteNotice("<%=UserID%>",function (res) {
                if (res.Content != null) {
                    callBack(res);
                }
            });
        }
 
        function callBack(res) {
            myJQDialog.rightBottomAlert("webnotice",res.Content);
            GetNotice();
        }
    </script>
</head>
<body>
    <form id="form1" runat="server">
        <asp:ScriptManager runat="server">
            <Services>
                <asp:ServiceReference Path="SiteNoticeServ.asmx"/>
            </Services>
        </asp:ScriptManager>
    <div>
    
    </div>
    </form>
</body>
</html>
 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
 
namespace WebApplication.SiteNotice {
    public partial class NoticeReciever : System.Web.UI.Page {
        public string UserID { get; set; }
        protected void Page_Load(object sender,EventArgs e) {
            if (!IsPostBack) {
                UserID = Session.SessionID;
                NoticeAdapter.NoticeAdapterInstance.AddClient(Session.SessionID);
            }
        }
 
 
    }
}  
 
5.消息发送页
 
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="NoticeSender.aspx.cs" Inherits="WebApplication.SiteNotice.NoticeSender" %>
 
<!DOCTYPE html>
 
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
    <title></title>
</head>
<body>
    <form id="form1" runat="server">
    <div>
        <asp:TextBox runat="server" ID="txt_Content"></asp:TextBox>
        <asp:Button runat="server" ID="btn_sender" Text="发送" OnClick="btn_sender_Click"/>
    </div>
    </form>
</body>
</html>
 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
 
namespace WebApplication.SiteNotice {
    public partial class NoticeSender : System.Web.UI.Page {
        protected void Page_Load(object sender,EventArgs e) {
 
        }
 
        protected void btn_sender_Click(object sender,EventArgs e) {
            var clients = NoticeAdapter.NoticeAdapterInstance.noticeQueens;
            foreach (var noticeQueen in clients) {
                NoticeAdapter.NoticeAdapterInstance.AddNotice(new NoticeModel() {
                    Reciever = noticeQueen.Key,Content = txt_Content.Text
                });
 
            }
        }
    }
} 
 
6.webservice 调用
 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Services;
 
namespace WebApplication.SiteNotice {
    /// <summary>
    /// SiteNoticeServ 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务,请取消注释以下行。 
    [System.Web.Script.Services.ScriptService]
    public class SiteNoticeServ : System.Web.Services.WebService {
 
        [WebMethod]
        public string HelloWorld() {
            return "Hello World";
        }
        [WebMethod]
        public NoticeModel WaiteNotice(string reciever) {
            var model = NoticeAdapter.NoticeAdapterInstance.GetNotice(new NoticeModel() { Reciever = reciever });
            return model;
        }
 
 
    }
}
阅读原文

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


1.使用ajax调用varxhr;functioninvoke(){if(window.ActiveXObject){xhr=newActiveXObject("Microsoft.XMLHTTP");}else{xhr=newXMLHttpRequest();}//指定请求地址varurl="http://127.0.0.1:7777/hello?wsdl";//
               好不容易把WebService服务器端搭建起来,我们还需要客户端程序也同样跑起来才能够进行和服务器端程序的通信: 在这篇文章里面,我会先自己写代码去实现调用WebService服务器端程序,接下来,通过IDEA配置的方式来调用WebService服务端: 首先,我写了一个W
1新建一个工程项目用来做服务端增加一个MyService1类文件packagecom.zns.ws;importjavax.jws.WebMethod;importjavax.jws.WebService;importjavax.xml.ws.Endpoint;@WebServicepublicclassMyService1{publicstaticvoidmain(String[]args){
packagecom.transsion.util;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStreamReader;importjava.io.PrintWriter;importjava.net.URL;importjava.net.URLConnection;importcom.alibaba.druid.util.Base64;importcom.tra
再生产wsdl文件时重写描述文件1usingSystem;2usingSystem.Collections.Generic;3usingSystem.Linq;4usingSystem.Web;5usingSystem.Web.Services.Description;67namespaceStrongSoftManage.Web.App8{9publicclassSoapExtens:SoapExtensi
一般情况下,使用eclipse自带的jax-ws生成webservice会自动生成2个类:ContractConnector.java packagecom.wonders.webservice.contract;importjava.text.DecimalFormat;importjava.text.ParseException;importjava.text.SimpleDateFormat;importjava.util.Date;i
一、WebService概述1.1什么是WebService 基于Web的服务:服务器端整出一些资源让客户端应用访问(获取数据) 一个跨语言、跨平台的规范(抽象)所谓跨编程语言和跨操作平台,就是说服务端程序采用java编写,客户端程序则可以采用其他编程语言编写,反之亦然!跨操作系统平台则是指服务
一、什么是CXF?    ApacheCXF=Celtix+Xfire,开始叫ApacheCeltiXfire,后来更名为ApacheCXF了,以下简称为CXF。ApacheCXF是一个开源的webServices框架,CXF帮助您构建和开发webServices,它支持多种协议,比如:SOAP1.1,1,2 XML/HTTP、RESTful或者CORBA。  
工具IDEA一、构建项目1、选择SpringInitializr2、填写项目信息3、勾选webService4、勾选Thymeleaf5、项目建立完成,启动类自动生成二、写个Controller启动服务。浏览器访问/hello接口。 
1.环境win764位,vs20102.新建一个asp.netweb应用程序(同上一篇)3.添加一个web引用,引用上一篇创建的服务。注意不是服务引用。如下图 
WebService之WSDL文件讲解   恩,我想说的是,是不是经常有人在开发的时候,特别是和第三方有接口的时候,走的是SOAP协议,然后用户给你一个WSDL文件,说按照上面的进行适配,嘿嘿,这个时候,要是你以前没有开发过,肯定会傻眼,那如果你想学习的话,就认真的看下面的讲解咯:一、WSDL概述  
在websrvice发布文件的webconfig中加入<httpRuntimemaxRequestLength="102400"/> <webServices>     <protocols>       <addname="HttpPost"/>       <addname="HttpGet"/>     </protocols>   
 代码比较简单,按照如下来操作即可,只是jar包有很多问题,比如找不到classnotFondspring、以及找不到xfile.xml、以及xfile.xml中的一个参数问题,以及2.0 spring。jar和spring1.6.2冲突问题,总之这个小demo报了一堆错误,其实都是jar的问题,为了让大家减少这方面的错误,所以我提供
 一、soapUI简介SOAP:   WebService通过Http协议发送请求和接收结果时,发送的请求内容和结果内容都采用XML格式封装,并增加了一些特定的HTTP消息头,以说明HTTP消息头的内容格式,这些特定的HTTP消息头和XML内容格式就是SOAP协议。SOAP提供了标准的RPC方法来调用WebService。 
参考,感谢https://blog.csdn.net/hj7jay/article/details/727224381.环境:win764位,jdk1.8.0_201 EclipseJavaEEIDEforWebDevelopers.Version:Mars.1Release(4.5.1)2.创建一个普通的java项目,名字是TheService在src目录下创建一个com.hyan.service包,在此包下创建
CXF实现RestfulWebService基础示例一、写在前面IDE:IDEA14JDK:1.7CXF:2.6.2示例来源:%CXF_HOME%\samples\jax_rs\basic发布方式:JAXRSServerFactoryBean的create()方法调用方式:URL的openStream()方法、HttpClient的executeMethod()方法二、服务端(Java项目)1.准备Jar包
封装helper类:classWebServiceHelper{///<summary>///1.get请求http方法///</summary>///<paramname="url">基础url</param>///<paramname="method">请求方法</param>///<paramnam
.net客户端调用java或.netwebservice进行soapheader验证最近项目中有业务需要跨平台调用web服务,客户端和服务器之间采用非对称加密来保证数据的安全性,webservice的安全验证基于soapheader。借此机会,顺便整理一下调用.netwebservice和javawebservice的验证方式,记录下来。
Node.jshttps://www.cnblogs.com/goldlong/p/8027997.htmlQQ音乐apihttps://juejin.im/post/5a35228e51882506a463b172#heading-11?tdsourcetag=s_pcqq_aiomsgGit把本地仓库上传到GitHbubhttps://blog.csdn.net/zamamiro/article/details/70172900git删除本地仓库https://blog.cs
转载自:孤傲苍狼 WebService学习总结(三)——使用JDK开发WebService一、WebService的开发手段使用Java开发WebService时可以使用以下两种开发手段1、 使用JDK开发(1.6及以上版本)-->详见:本文2、使用CXF框架开发-->详见:其他文章二、使用JDK开发WebServi