1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. M>
  5. MQ消息订阅

当前主题:MQ消息订阅

Java工程师学习指南(完结篇)

Java工程师学习指南 完结篇 先声明一点,文章里面不会详细到每一步怎么操作,只会提供大致的思路和方向,给大家以启发,如果真的要一步一步指导操作的话,那至少需要一本书的厚度啦。 因为笔者还只是一名在校生,所以写的内容主要还是针对Java初学者或者接触Java

阅读全文

业务系统从阿里云物联网平台获取设备数据的3种方案

在企业IoT业务场景中,往往需要将设备上报到IoT物联网平台的数据进行加工处理,存储到数据库中,以便供业务系统使用。物联网平台提供了3种获取数据的方式: -通过阿里云POP API获取设备数据 -通过HTTP/2服务端订阅取设备数据 -通过规则引擎配置流转数

阅读全文

为什么要使用MQ消息中间件?这3个点让你彻底明白!

前言 一个用消息队列的人,不知道为啥用,有点尴尬。没有复习这点,很容易被问蒙,然后就开始胡扯了。 回答:这个问题,咱只答三个最主要的应用场景,不可否认还有其他的,但是只答三个主要的,即以下六个字:解耦、异步、削峰 1、解耦 传统模式: 传统模式的缺点: 系统

阅读全文

应用上云新模式,Aliware 全家桶亮相杭州云栖大会

全面上云带来的变化,不仅是上云企业数量上的攀升,也是企业对云的使用方式的转变,越来越多的企业用户不仅将云作为一种弹性资源,更是开始在云上部署架构和应用,借助 Serverless 等技术,开发人员只需聚焦于业务代码,省去了对底层资源的维护,同时底层资源用起来

阅读全文

RocketMQ一个新的消费组初次启动时从何处开始消费呢?

1、抛出问题 一个新的消费组订阅一个已存在的Topic主题时,消费组是从该Topic的哪条消息开始消费呢? 首先翻阅DefaultMQPushConsumer的API时,setConsumeFromWhere(ConsumeFromWhere consume

阅读全文

SpringBoot2.0 整合 RocketMQ ,实现请求异步处理

本文源码:GitHub·点这里 || GitEE·点这里 一、RocketMQ简介 1、架构图片 2、角色分类 (1)、Broker RocketMQ 的核心,接收 Producer 发过来的消息、处理 Consumer 的消费消息请求、消息的持 久化存储、

阅读全文

到底什么时候该使用MQ?

一、缘起 一切脱离业务的架构设计与新技术引入都是耍流氓。 引入一个技术之前,首先应该解答的问题是,这个技术解决什么问题。 就像微服务分层架构之前,应该首先回答,为什么要引入微服务,微服务究竟解决什么问题(详见《互联网架构为什么要做微服务?》)。 最近分享了几

阅读全文

MQ,互联网架构解耦神器

一个架构常识:当调用方需要关心执行结果,通常使用RPC调用。 ret = PassportService::userAuth(name, pass); switch(ret){ case(YES) : return YesHTML(); case(NO) :

阅读全文

MQ消息订阅相关问答

查看更多 提问题

消息队列MQ 无法订阅消息,用的C#示例代码

//创建consumer ONSFactory onsfactory = new ONSFactory(); PushConsumer pConsumer = onsfactory.getInstance(

阅读全文

MQ 订阅消息示例程序出错

![1](https://yqfile.alicdn.com/665b6b1fcb2a52f274a9d0e6eddc0eadd3061845.png) 错误提示 1.The type new MessageListener(){} must im

阅读全文

消息队列订阅功能能否主动推给订阅者

阿里云消息队列能否主动将消息推给订阅者,如果不能那么移动端能否直接访问MQ,还是需要访问服务器端,再有服务器端像MQ中要数据在返给移动端

阅读全文

redis的消息队列和发布订阅系统的区别?怎么选择?

使用jedis的BRPOP和BLPOP实现的阻塞时消息队列 与 使用jedis的subscribe和publish实现的发布订阅系统 的区别在哪里,怎么选择?

阅读全文

消息队列,取到重复的数据

同一consumerId同一消息只能获取一次才对吧,为啥老是取到重复的数据。 测试的时候两个consumerId都把队列消息取完后再push新的,再取数据会出现已取过的数据 ps:用的htttp接入 补充1:consumerId 乱输(不在订阅管理中

阅读全文

MQ里面的MQTT客户端是否能做负载均衡?

两台机子,分别部署同样的项目,在两台机子上跑两个线程同时订阅相同的Topic. 两台机子,利用阿里云的负载均衡做高并发. MQTT怎样才能做负载均衡,例如,我一条消息发布过来,只被一台机子消费?

阅读全文

mqtt消息队列,Android接收消息

//点击按钮调用resavebutton() 方法,通过控制台发送消息,不能收到,程序也不报错,请大神指导,谢谢 private void resavebutton() { // /** * 设置当

阅读全文

activemq发送topic消息,接收了两次

使用spring + activemq 框架,发送topic消息,在接收端接收了两次消息,但使用queue却不会出现这种情况。 xml配置如下 ``` <!-- 配置connectionFactory --> <bean id="jmsFa

阅读全文