网站首页 站内搜索

搜索结果

查询Tags标签: consumer,共有 108条记录
  • C# 流水线 生产者/消费者链 Producer/Consumer

    <body>manager.csusing System; using System.Collections.Concurrent; using System.Threading; using bntu.pcm.plworker; using bntu.pcm.works;/** bntu 是我的网名,在cnblogs上可以搜到我的博客:https://www.cnblogs.com/SimbaWang/* pcm 是producer/consum…

    2022/9/11 1:23:19 人评论 次浏览
  • 如何解决消息队列的延时以及过期失效问题?

    如何解决消息队列的延时以及过期失效问题?消息队列满了以后该怎么处理?有几百万消息持续积压几小时,说说怎么解决?面试官心理分析 你看这问法,其实本质针对的场景,都是说,可能你的消费端出了问题,不消费了;或者消费的速度极其慢。接着就坑爹了,可能你的消息队列…

    2022/8/29 6:25:11 人评论 次浏览
  • 如何保证消息的顺序性?

    如何保证消息的顺序性?面试官心理分析 其实这个也是用 MQ 的时候必问的话题,第一看看你了不了解顺序这个事儿?第二看看你有没有办法保证消息是有顺序的?这是生产系统中常见的问题。 面试题剖析 我举个例子,我们以前做过一个 mysql binlog 同步的系统,压力还是非常大…

    2022/8/29 6:24:01 人评论 次浏览
  • RocketMQ

    消息中间件常用消息中间件对比RocketMQ相比其他两种有一个不可替代的优势:支持事务消息作用异步解耦(提高效率)削峰填谷(缓解压力)分布式缓存同步 消息分发写磁盘方式RocketMQ的消息是存储到磁盘上的,这样既能保证断电后恢复,又可以让存储的消息量超出内存的限制。…

    2022/8/4 6:25:36 人评论 次浏览
  • Java高级特性——平台模块系统

    Java高级特性——平台模块系统 java9 引入了 JAVA 平台模块系统 一、模块的概念 假设一个场景,我们想要修改或剔除一个很少使用的特性,如果它对外是公有的,那么就没办法推断这个变化产生的影响。模块为我们提供了比较好的解决方案。 一个 JAVA 平台模块包含:一个包集合…

    2022/8/1 1:24:10 人评论 次浏览
  • 自动化测试学习过程中遇到的JAVA知识

    1、PrimitiveIterator.OfInt iterator1 = IntStream.iterate(2,n -> n+1).limit(3).iterator(); 1)iterator() Java Iterator(迭代器)不是一个集合,它是一种用于访问集合的方法,可用于迭代 ArrayList 和 HashSet 等集合。 Iterator 是 Java 迭代器最简单的实现,L…

    2022/7/12 1:30:00 人评论 次浏览
  • java8之Consumer接口具有什么功能呢?

    转自: http://www.java265.com/JavaCourse/202206/3731.html 下文笔者讲述Consumer接口的功能简介说明,如下所示 Consumer接口 Consumer接口位于:java.util.function包下面 Consumer接口中包含一个抽象方法void accept(T t)其功能:消费一个泛型数据对象t如何消费泛型数据,…

    2022/6/24 1:18:09 人评论 次浏览
  • RocketMQ——总结(一)

    官网:https://rocketmq.apache.org/ 源码地址:https://github.com/apache/rocketmq一、RocketMQ的优点 1、天然支持集群模式、负载均衡、水平扩展能力 2、上亿级别的消息堆积能力 3、采用零拷贝的原理、顺序写盘、随机读(借鉴kafka) 4、丰富的API使用,支持顺序消息,…

    2022/5/4 23:15:42 人评论 次浏览
  • Kafka多线程开发消费者实例

    Kafka consumer是单线程的设计,这个其实不准确,从 Kafka 0.10.1.0 版本开始,KafkaConsumer 就变为了双线程的设计,即用户主线程和心跳线程。 所谓用户主线程,就是你启动 Consumer 应用程序 main 方法的那个线程,而新引入的心跳线程(Heartbeat Thread)只负责定期给…

    2022/4/16 23:17:31 人评论 次浏览
  • Kafka消费进度监控

    Kakfa消费滞后程度有个专门的名称:消费者 Lag 或 Consumer Lag。所谓滞后程度,就是指消费者当前落后于生产者的程度。 比方说,Kafka 生产者向某主题成功生产了 100 万条消息,你的消费者当前消费了 80 万条消息,那么我们就说你的消费者滞后了 20 万条消息,即 Lag 等于…

    2022/4/16 23:17:08 人评论 次浏览
  • 如何让Kafak尽可能不丢失消息

    Kafka 只对“已提交”的消息(committed message)做有限度的持久化保证 已提交,commit,若干个(可用配置设置) Broker 成功地接收到一条消息并写入到日志文件后,它们会告诉生产者程序这条消息已成功提交。 有限度,假如你的消息保存在 N 个 Kafka Broker 上,那么这个…

    2022/4/10 6:15:31 人评论 次浏览
  • python之Kafka

    1.安装kafka环境# 看这个地址 https://blog.csdn.net/github_38482082/article/details/82112641 # 你还需要装Java环境 # 测试启动如果启动成功,那么证明kafka启动成功 .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties #启动kafka .\bin\wind…

    2022/3/31 20:49:29 人评论 次浏览
  • Java多线程运行探幽

    事关Training2中Task4,想看看经典的两个进程并行会是什么样子题目概述 实现简单的生产者-消费者模型:Tray托盘容量为1;托盘满时不能放入,空时不能取货 Producer生产者共需生产10个货物;每生产一个货物后会立刻尝试放入,放入成功前不会继续生产,货物按照从1-10编号;…

    2022/3/30 22:19:33 人评论 次浏览
  • Dubbo

    Dubbo 目录Dubbo一、Dubbo概述1. 架构分类2. Dubbo简介3. RPC概述二、Dubbo使用方式1. Provider和Consumer执行流程三、Dubbo服务管理中心1. 服务管理中心概述2. 服务管理中心使用方式四、Dubbo统计中心1. 统计中心概述2. 统计中心使用方式五、Dubbo配置1. 启动检查机制2.…

    2022/3/19 6:29:44 人评论 次浏览
  • 基于Java Springboot+Vue+MyBatis音乐播放系统设计实现

    ?? 作者主页:Java李杨勇? ?? 简介:Java领域优质创作者??、Java李杨勇公号作者 简历模板、学习资料、面试题库、技术互助【关注我,都给你】 ?? 欢迎点赞 ?? 收藏 留言 ??视频演示:文末获取源码联系方式 springboot+vue音乐网站摘要:网络技术以及计算机的…

    2022/3/2 14:16:24 人评论 次浏览
共108记录«上一页1234...8下一页»
扫一扫关注最新编程教程