你是否遇到过两个(多个)系统间需要通过定时任务来同步某些数据?你是否在为异构系统的不同进程间相互调用、通讯的问题而苦恼、挣扎?如果是,那么恭喜你,消息服务让你可以很轻松地解决这些问题。 消息服务擅长于解决多系统、异构系统间的数据交换(消息通知/通讯)问题,你也可以把它用于系统间服务的相互调用(RPC)。RabbitMQ就是当前最主流的消息中间件之一。
2021-02-07 13:00:09 121.22MB 中间件
1
RabbitMQ消费者的C#控制台源码,可以接收生产者发送的消息。另外还有生产者源码,在另外一个包里。
2021-02-05 17:56:49 261KB RabbitMQ C#
1
rabbitMq中的driect模式,在服务端生产者可以直接使用此模式,对应消费端模式获取对接的模型消息,同时在生成的接口中可以直接使用此工具,方便适用!
2021-02-05 16:02:53 2KB rabbitmq
1
封装了RabbitMQ的订阅者线程和发布者线程(还有个初始化工厂的连接工具类),另外附加一个安卓的使用demo
2021-02-04 17:25:26 139KB RabbitMQ 封装 MQ
1
C#调用RabbitMQ消息队列的实现例子,包括的内容: 1、C#调用RabbitMQ--控制台程序模式--发送端 2、C#调用RabbitMQ--控制台程序模式--接收端 3、C# Winform 调用RabbitMQ--接收端
2021-02-04 15:54:13 1.38MB C#RabbitMQ rabbitMQ 消息队列
1
ch.ExchangeDeclare(exchange, exchangeType);//direct必须要routingKey //声明一个队列 ch.QueueDeclare("q", true, false, false, null); //将一个队列和一个路由绑定起来。并制定路由关键字 // ch.QueueBind("q", exchange, routingKey); ch.ExchangeDeclare("fanoutE", "fanout"); //声明一个队列 ch.QueueDeclare("fanoutQ", true, false, false, null); //将一个队列和一个路由绑定起来。并制定路由关键字 //ch.QueueBind("q", "fanoutE", routingKey); ch.QueueBind("fanoutQ", "fanoutE", "fanoutk");//fanout模式publish的时候不需要routingKey,只要绑定了的Q都能接收
2021-02-04 15:46:34 408KB RabbitMQ 消息 C#
1
mqtt:Tarantool MQTT客户端
2021-02-03 23:48:14 28KB c lua mqtt-client rabbitmq-client
1
docker,rabbitmq,安装配置与启动,默认用户与密码
2021-02-03 23:31:55 53KB docker rabbitmq Linux
1
带有Web UI的分布式多用户Scrapy系统 这是一个Django项目,允许用户通过Web界面创建,配置,部署和运行Scrapy Spiders。 该项目的目标是构建一个应用程序,该应用程序将允许多个用户编写自己的抓取脚本,并将其部署到一组工人中,以分布式方式进行抓取。 该应用程序允许用户通过Web界面执行以下操作: 创建一个Scrapy项目 添加/编辑/删除草率项目 添加/编辑/删除Scrapy项目管道 编辑链接生成器功能(有关更多信息,请参见下文) 编辑刮板功能(有关此内容,请参见下文) 将项目部署到工作机 在工作机上启动/停止项目 显示工作机,数据库和链接队列的联机状态 显示项目的部署状态 显示报废的数量 显示刮时项目中发生的错误数 显示项目的开始/停止日期和时间 建筑 该应用程序捆绑了用于MongoDB的Scrapy管道(用于保存被抓取的项目)和用于RabbitMQ的Scrapy调度程序(用于在工作人员之间分配链接)。 这些代码是从和获取并改编的。 这是运行应用程序所需的内容: MongoDB服务器(可以是独立群集或分片群集,副本集未经测试) RabbitMQ服务器
2021-02-03 09:37:34 5.95MB python django mongodb rabbitmq
1
安装RabbitMQ的必备工具
2021-02-02 00:32:55 104.27MB erlang RabbitMQ otp_win64 otp
1