远程消息队列 异步回调

问题描述

我现在要实现的一个功能就是远程服务器里面有个计算函数这个函数里面有个for循环计算,要把每次的计算结果都实时的传递给客户端,现在要满足同时几百个人来同时调用这个函数,我用消息队列来实现,我的思路是这样的,不同的客户调用和服务器连接起来后,在客户端通过指定服务器路径来生成(接受)消息队列对象,在服务器端我直接通过客户的ip传递给服务器端,然后服务器端创建一个和客户端一样的名称的消息队列,从而满足客户端和服务器端同时功用一个消息队列,应该就不会出现上面的问题吧.问题一在服务器端为什么不能够根据传过来的ip生成响应的队列呀,msdn也说了,要在公共队列下面创建,我怎么都没有看都有公共队列,而只有专用队列,传出队列.系统队列,难道是我xp不支持,另外,我几台连都是在一个域起来,?问题二我如果用多线程来做,系统开销那不是很大,我想他应该和网站访问的功能和类似.请问网站是通过什么方式来实现异步回调?请大家指点,小弟先谢了.

时间: 2016-05-12

远程消息队列 异步回调的相关文章

MQget 节点 无法访问 output绑定的远程消息队列

问题描述 MQget节点无法访问output绑定的远程消息队列我定义了一个远程消息队列,通过MB获取消息,然后转发到这个远程消息队列中,可是确报告创建队列并重试操作.[测试客户机错误]MQ输出监视器尝试获取此消息时遇到错误:[测试客户机错误]com.ibm.etools.mft.unittest.core.transport.mq.MQWrapperException:无法访问队列QM_OA.OA_IN.R.当队列不存在时,通常会发生这种情况.这个异常,QM_OA.OA_IN.R这个消息队列存在

RabbitMQ消息队列(七):适用于云计算集群的远程调用(RPC)

        在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成.那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例. 1. 客户端接口 Client interface         为了展示一个RPC服务是如何使用的,我们将创建一段很简单的客户端class. 它将会向外提供名字为call的函数,这个call会发送RPC请求并且阻塞知道收到RPC运算的结果.代码

.NET C# 异步读取Windows消息队列无法实现

问题描述 场景:由于项目需求,在WCF与WindowsService之间需要用到Windows消息队列这个东西WindowsService可以正常写入队列消息,但是,在WCF服务中要去异步读取消息队列中的数据,却不能正常访问得到数据并处理.WindowsService在创建队列实例时已将将权限给到了最高级别Everyone了错误提示:消息队列系统的访问被拒绝.求各位大神,帮帮忙吧,很着急-- 解决方案 解决方案二:遇到同样的问题.求大神解答..

C#实现异步消息队列

原文:C#实现异步消息队列 拿到新书<.net框架设计>,到手之后迅速读了好多,虽然这本书不像很多教程一样从头到尾系统的讲明一些知识,但是从项目实战角度告诉我们如何使用我们的知识,从这本书中提炼了一篇,正好符合我前几篇的"数据驱动框架"设计的问题: 消息队列 消息队列(英语:Message queue)是一种进程间通信或同一进程的不同线程间的通信方式,软件的贮列用来处理一系列的输入,通常是来自使用者.消息队列提供了异步的通信协议,每一个贮列中的纪录包含详细说明的资料,包含发

用消息队列怎么实现多客户端连接

问题描述 用消息队列怎么实现多客户端连接,我现在两台机子连起来可以,要是多台生成的数据进入一个队列就会混乱,请问如何解决 解决方案 解决方案二:没明白你什么意思解决方案三:多线程阿,在新开线程里面进行交互而不是在侦听线程.解决方案四:对放入消息队列的数据Message,制定灵活的格式,比如采用XML,然后在message包含比较的信息反应数据的源头.解决方案五:我现在要实现的一个功能就是远程服务器里面有个计算函数这个函数里面有个for循环计算,要把每次的计算结果都实时的传递给客户端,现在要满足同

流行消息队列服务

一.简单消息队列服务 HTTPSQS HTTPSQS(HTTP Simple Queue Service)是一款基于 HTTP GET/POST 协议的轻量级开源简单消息队列服务,使用 Tokyo Cabinet 的 B+Tree Key/Value 数据库来做数据的持久化存储. 队列(Queue)又称先进先出表(First In First Out),即先进入队列的元素,先从队列中取出.加入元素的一头叫"队头",取出元素的一头叫"队尾".利用消息队列可以很好地异步

艾伟_转载:消息队列(Message Queue)简介及其使用

消息队列(Message Queue)简介及其使用 利用 MSMQ(Microsoft Message Queue),应用程序开发人员可以通过发送和接收消息方便地与应用程序进行快速可靠的通信.消息处理为您提供了有保障的消息传递和执行许多业务处理的可靠的防故障方法. MSMQ与XML Web Services和.Net Remoting一样,是一种分布式开发技术.但是在使用XML Web Services或.Net Remoting组件时,Client端需要和Server端实时交换信息,Serve

消息队列入门(二)消息队列的规范和开源实现

1.AMQP规范 AMQP 是 Advanced Message Queuing Protocol,即高级消息队列协议.AMQP不是一个具体的消息队列实现,而 是一个标准化的消息中间件协议.目标是让不同语言,不同系统的应用互相通信,并提供一个简单统一的模型和编程接口. 目前主流的ActiveMQ和RabbitMQ都支持AMQP协议. AMQP相关的角色和职责 Producer 消息生产者 一个给exchange发送消息的程序,发送方式大致是:它首先创建一个空消息,然后填上内容.路由KEY,最后发

消息队列和管道的区别(转载)

转载自:http://bbs.chinaunix.net/viewthread.php?tid=265266 作者:beginner-bj 请问管道和消息队列有什么不同  管道通信(PIPE) 管道通信方式的中间介质是文件,通常称这种文件为管道文件.两个进程利用管道文件进行通信时,一个 进程为写进程,另一个进程为读进程.写进程通过写端(发送端)往管道文件中写入信息:读进程通过读 端(接收端)从管道文件中读取信息.两个进程协调不断地进行写.读,便会构成双方通过管道传递信息 的流水线. 利用系统调用