• 关于

    生产者消费者问题

    的搜索结果

回答

怀疑是不是生产者问题了&xff0c;没有生产数据。和生产者那边联系了一下&xff0c;那边回复说一直有生产数据的&xff0c;排除 2&xff0c;怀疑是不是什么配置有问题&xff0c;导致不能消费。仔细检查了下&xff0c;消费者组、topic...
游客2q7uranxketok 2021-02-24 17:04:40 0 浏览量 回答数 0

回答

Java 实例-生产者/消费者问题 以下实例演示了如何通过线程解决生产者/消费者问题&xff1a;author by runoob.com ProducerConsumerTest.java */ public class ProducerConsumerTest { public static void main(String[]...
问问小秘 2020-02-13 17:57:01 0 浏览量 回答数 0

回答

介绍一下生产者消费者模式&xff0c;从GO语言的这个并发模型来看&xff0c;也就是说假如说咱们站在一个比较高的一个高度来看&xff0c;其实利用channel的确能达到共享内存的目的。这个channel的性质与在读写状态且保证顺序的...
剑曼红尘 2020-04-13 11:04:04 0 浏览量 回答数 0

回答

在学习Java队列的过程中了解到了阻塞/非阻塞队列网上看到阻塞队列很适合生产者/消费者模型,比如消费者在向生产者索要产品时产品空了,那么这时候会发生阻塞,等生产者产出了产品,消费者就能立即拿到了。我的问题是...
蛮大人123 2019-12-01 20:15:21 1131 浏览量 回答数 1

回答

Java 实例-生产者/消费者问题
问问小秘 2020-02-13 17:56:47 0 浏览量 回答数 1

回答

java rocketmq 生产者如何取得消费者的消费结果&xff1f;本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。点击链接欢迎加入感兴趣的技术领域群。
游客pklijor6gytpx 2019-12-01 21:54:19 273 浏览量 回答数 4

回答

但是生产者生产的后续数据会去消费&xff09;但是这个组是新的。然后我换了一个最开始使用这个主题的组来消费&xff0c;消费者一启动的时候就会马上从之前offset的位置开始消费。就很奇怪&xff0c;难道不是test2组才是正常...
1552433895772021 2020-02-22 12:01:37 0 浏览量 回答数 0

回答

dubbo消费者先启动&xff0c;生产者没有启动&xff0c;如果这时候在启动生产者&xff0c;调用消费中&xff0c;请求生产者的接口时&xff0c;为Null&xff0c;我查了dubbo的文档&xff0c;里面也有人提这个问题&xff0c;现在还没有找到解决...
Atom 2020-04-25 14:40:04 0 浏览量 回答数 1

回答

生产者消费者模型 在连接池中,连接在使用时从池中取出,用完后放入池中。对于 goroutine 而言,goroutine 通过语言关键字启动,无法像连接一样操作。那么如何让 goroutine 可以执行任务,且执行后可以重新用来执行其它...
有只黑白猫 2020-01-09 13:30:22 12 浏览量 回答数 2

回答

一个节点既是消费者又是生产者&xff0c;是不是不能在一台机器启动多个实例&xff1f;本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。点击链接欢迎加入感兴趣的技术领域群。
游客pklijor6gytpx 2019-12-01 21:51:10 10 浏览量 回答数 0

回答

自己构建一个blockingqueue,注入到m个生产者线程及n个消费者线程中;生产者线程不停的生产,往queue里put(),如果队列队列满了,线程wait挂起;消费者线程不停的消费,从queue里take(),如过队列空了,线程自动挂起...
蛮大人123 2019-12-02 02:15:13 0 浏览量 回答数 0

回答

阿里的RocketMQ&xff08;...问题&xff1a;先生产A tag 100条数据&xff0c;起一个消费者用个新的分组ID去消费A tag的数据&xff0c;...然后还要我消费者生产者之前起动空转5秒以上&xff0c;不知道还有谁家消息队列是这样的逻辑的。
1643696192679193 2021-05-26 11:13:55 10 浏览量 回答数 0

回答

按照文档编写生产者消费者 https://help.aliyun.com/document_detail/29549.html?spm=a2c4g.11186623.2.18.105f78b4oCZBUs#title-oxd-0bg-6nv 消息延时不管设置为一分钟还是一天&xff0c;消费者都是立刻就收到了...
jay121169 2020-06-05 17:32:08 0 浏览量 回答数 0

回答

RabbitMQ常用的工作队列的方式如下:但是这样有一个问题,就是如果我的生产者很多,而队列的数量又很少,只有一个,那等待的时间就有些长了,而我想实现这样的一个效果:也就是说多个消费者以工作队列的方式同时消费...
八月log 2019-12-01 20:23:49 4398 浏览量 回答数 2

回答

这其实是一个生产/消费模型中的一个问题:顺序消费问题.(假定生产者已将数据按照顺序放入队列)最开始能想到的方法:单线程消费,这样就严格保证了顺序.但带来的问题消费速度慢,特别是这种插入关系型数据库(耗IO)的...
蛮大人123 2019-12-02 01:55:28 0 浏览量 回答数 0

回答

测试和生产公用一套zookeeper&xff0c;怎么保证消费不冲突&xff1f;本问题来自阿里云开发社区的【11大垂直技术领域开发社群】。点击链接欢迎加入感兴趣的技术领域群。
游客pklijor6gytpx 2019-12-01 21:53:59 26 浏览量 回答数 1

回答

64;小帅帅丶 你好&xff0c;想跟你请教个问题&xff1a;我的消费者是0个&xff0c;...最后消费者也调取到生产者了&xff0c;那为什么这个网站上我的提供者是1个&xff0c;消费者是0个呢&xff1f;而且我的应用下面也是只有一个provider
爱吃鱼的程序员 2020-06-05 15:48:29 0 浏览量 回答数 1

回答

问题来自阿里云开发社区的【11大垂直技术领域开发社群】。https://developer.aliyun.com/article/706511 点击链接欢迎加入感兴趣的技术领域群。
游客mxpnxp6g3cq7o 2019-12-01 19:45:30 21 浏览量 回答数 1

回答

作为消费者的我调用服务端的接口&xff0c;一直报错 dubbo 消费方,如何将接口dubbo,注入到service或者dao层 dubbo启动服务端报这个错&xff1f;Dubbo 消费者如果数据校验了&xff0c;那么服务提供者还需要数据校验吗&xff1f;...
游客pklijor6gytpx 2019-12-01 21:54:03 31 浏览量 回答数 1

回答

如果你的数据来源已经确定,不需要额外的编码,那你可以使用 Flume 提供的 sources 和 sinks,反之,如果你需要准备自己的生产者消费者,那你需要使用 Kafka。Flume 可以在拦截器里面实时处理数据。这个特性对于...
hiekay 2019-12-02 01:42:10 0 浏览量 回答数 0

回答

生产者消费者API的系统环境属于不同集群环境&xff0c;在同一个jar程序中会造成系统配置加载冲突。请问&xff0c;有没有好的解决方式&xff1f;已解决方案&xff1a;将consumer和producer分离:消费者程序先获取源topic数据...
1263847017820869 2020-09-02 18:31:03 319 浏览量 回答数 0

回答

3、模拟多线程订单生产者消费者:static class OrdersProducerThread extends Thread { public void run(){ while(true){ 每隔 1000 毫秒生产一个商品 Thread.sleep(100);synchronized(list){ 当前商品满了,生产...
徐雷frank 2019-12-02 01:48:25 0 浏览量 回答数 0

回答

生产者消费者API的系统环境属于不同集群环境&xff0c;在同一个jar程序中会造成系统配置加载冲突。请问&xff0c;有没有好的解决方式&xff1f;已解决方案&xff1a;将consumer和producer分离:消费者程序先获取源topic数据...
1263847017820869 2020-09-02 18:29:02 0 浏览量 回答数 0

回答

生产者 public void start(){ producer&61;new DefaultMQProducer(groupName);producer.setNamesrvAddr(namesrvAddr);try { producer.start();} catch(MQClientException e){ log.error(e);} } public void send...
DM。 2020-06-01 14:49:32 0 浏览量 回答数 1

回答

Re服务可以正常调用&xff0c;但是服务列表不显示。...生产者的可以看到。消费者的hsf日志有 configRawInfo:null 的提示&xff0c;下载的实例demo没改过&xff0c;是我配置的问题&xff0c;还是代码需要修改呢。
lucky_blue 2019-12-02 00:20:08 0 浏览量 回答数 0

回答

Re服务可以正常调用&xff0c;但是服务列表不显示。...生产者的可以看到。消费者的hsf日志有 configRawInfo:null 的提示&xff0c;下载的实例demo没改过&xff0c;是我配置的问题&xff0c;还是代码需要修改呢。
lucky_blue 2019-12-02 00:20:08 0 浏览量 回答数 0

回答

数据的丢失问题&xff0c;可能出现在生产者、MQ、消费者
游客pklijor6gytpx 2019-12-02 03:10:11 0 浏览量 回答数 0

回答

问题来自Java技术沙龙的李博Java线下沙龙报名链接:https://yq.aliyun.com/activity/796
李博 bluemind 2019-12-01 19:26:10 515 浏览量 回答数 1

回答

2019-12-01 18:42:23 722 浏览量 回答数 1

回答

可能出现在生产者、MQ、消费者中&xff0c;咱们从 RabbitMQ 和 Kafka 分别来分析一下吧。生产者弄丢了数据 生产者将数据发送到 RabbitMQ 的时候&xff0c;可能数据就在半路给搞丢了&xff0c;因为网络问题啥的&xff0c;都有可能...
剑曼红尘 2020-04-21 10:04:26 105 浏览量 回答数 2

云产品推荐

视频直播 大数据计算服务 MaxCompute 国内短信套餐包 ECS云服务器安全配置相关的云产品 开发者问答 阿里云建站 新零售智能客服 万网 小程序开发制作 视频内容分析 视频集锦 代理记账服务 阿里云AIoT 阿里云科技驱动中小企业数字化