1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. S>
  5. 生产者消费者

当前主题:生产者消费者

生产者消费者 相关的博客

查看更多 写博客

Kafka 原理和实战

本文首发于 vivo互联网技术 微信公众号 https://mp.weixin.qq.com/s/bV8AhqAjQp4a_iXRfobkCQ作者简介:郑志彬,毕业于华南理工大学计算机科学与技术(双语班)。先后从事过电子商务、开放平台、移动浏览器、推荐广告和

阅读全文

一道真实的面试题 | 如何保证消息队列的高可用

5万人关注的大数据成神之路,不来了解一下吗?5万人关注的大数据成神之路,真的不来了解一下吗?5万人关注的大数据成神之路,确定真的不来了解一下吗? 欢迎您关注《大数据成神之路》 面试题:如何保证消息队列的高可用? 面试官心理分析 如果你的简历里写了MQ,如果有

阅读全文

为什么大多数的企业名称和商标不同?

想让商标和企业名称一致一直是很多企业的诉求,但实践中却很难实现,Why? 今天,小编就为你揭晓答案。 原因一:公司名称核准和商标注册是两套系统 企业名称由省级工商管理局进行核准,一般以“行政区划+企业字号+企业类型”形式组成。由于企业名称一般由各省工商管理局

阅读全文

一分钟实现分布式锁

一、缘起 分布式环境下,多台机器上多个进程对一个数据进行操作,如果不做互斥,就有可能出现“余额扣成负数”,或者“商品超卖”的情况,如何实现简易分布式锁,对分布式环境下的临界资源做互斥,是今天将要讨论的话题。 二、互斥原理 原理:多个访问方对同一个资源进行操作

阅读全文

想要金九银十面试通关,不懂 Java多线程肯定是不行的!

作者 | 纳达丶无忌 如果对什么是线程、什么是进程仍存有疑惑,请先 Google 之,因为这两个概念不在本文的范围之内。 用多线程只有一个目的,那就是更好的利用 CPU 的资源,因为所有的多线程代码都可以用单线程来实现。说这个话其实只有一半对,因为反应“多角

阅读全文

SpringBoot 整合 JMS(ActiveMQ)

SpringBoot整合JMS(ActiveMQ) 消息队列(Message Queue)是一种进程间或线程间的异步通信方式,使用消息队列消息生产者在消息产生后,会将消息保存在消息队列中直到消费者来取走它,即消息的发送者和接收者不需要与消息队列交互。使用消息

阅读全文

科技赋能零售,最终还是要消失于无形中

导读: 8月23日,“新零售论坛:零售业的再革命” 由数澜科技与华院数据在上海百联创业空间成功举办。**数澜科技参谋长武凯(行竹)就“零售数据中台实践”进行了分享,并在“新零售创业的机遇与挑战”圆桌论坛中发表了独特的见解。** 过去的一年里,零售行业正在发生

阅读全文

选型宝访谈:如何打造云时代的一体化供应链平台?

写在前面 供应链是现代企业竞争的焦点,线上拼用户和流量,线下拼供应链,已成为许多企业的共识。近年来,在“中国制造”和“电子商务”大发展的带动下,SCM已成为许多企业继ERP之后的新标配。 今天,移动互联网蓬勃发展,云计算、大数据、AI等技术日臻成熟,企业信息

阅读全文

生产者消费者 相关问答

查看更多 提问题

到底rocketmq-broker的brokerIP1指的是什么地址?

nameserver和broker及生产者在阿里的专有网络中,前端作为消费者收不到消息,而专有网络中的消费者可以收到消息。请问我该怎么做?

阅读全文

[@徐雷frank][¥20]用 wait-notify 写一段代码来解决生产者-消费者问题?

问题来自Java技术沙龙的李博 Java线下沙龙报名链接:https://yq.aliyun.com/activity/796

阅读全文

Pyspark - 打印来自Kafka的消息

我建立了一个带有生产者和消费者的kafka系统,作为消息流式传输json文件的行。 使用pyspark,我需要分析不同流媒体窗口的数据。为此,我需要查看pyspark流式传输的数据......我该怎么做? 要运行代码,我使用了Yannael的Doc

阅读全文

生成“假”流数据。

我尝试生成流数据,以模拟我收到两个值的情况,Integer类型,在不同的时间范围内,带有时间戳,Kafka作为连接器。 我使用Flink环境作为消费者,但我不知道哪个是生产者的最佳解决方案。(如果可能,Java语法优于Scala) 我应该直接从Ka

阅读全文

使用RabbitMQ作为消息队列,多个生产者往同一个队列里面塞数据,然后用工作队列的方式来消费队列,能不能创建多个队列来同时这么干

RabbitMQ常用的工作队列的方式如下: ![image](https://yqfile.alicdn.com/9ad668c48ba3f6c601f221b7a5d6d7599534076a.png) 但是这样有一个问题,就是如果我的生产者很多,而队列

阅读全文

PHP 可以用 linux 下的FIFO文件实现简单的生产者/消费者模式吗?

我想用两个PHP 进程。 一个写FIFO 文件,一个读FIFO文件,然后通过读到的内容拼接shell ,PHP 去执行这个shell. 大家觉得可行吗?可取吗?负载高的时候呢?

阅读全文

消费者不能消费消息

生产者可以发送消息,在控制台也可以查看到,状态为已订阅未消费。但是消费者不能消费消息,在控制台手动给消费者下发消息,消费者可以收到。

阅读全文

linux环境高级编程,谢谢各位大神!

以生产者消费者模型,编写一个多线程程序。生产者只有一个,生产一个产品并打印当前库存数和生产总数,并睡眠10毫秒。消费者有3个,查看库存,如库存大于0则拿走一个产品,打印线程号及其当前拥有的产品数量,然后睡眠1毫秒。

阅读全文