温馨提示:本文基于Kafka2.2.1版本。本文主要是以源码的手段一步一步探究消息发送流程,如果对源码不感兴趣,可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构图。从上文初识KafkaProducer生产者,可以通过KafkaProducer的send方法发送消息,send方法的声明如下:Future<RecordMetadata>send(ProducerRecord&l
分类:
其他好文 时间:
2020-12-08 11:59:45
阅读次数:
3
解决使用 Composer 的时候提示输入 TokenXXXXXXXXXfor future use by Composer. Token (hidden): 解决方法:进入 https://github.com/settings/tokens 点击 「Generate new token」 新建一 ...
分类:
其他好文 时间:
2020-12-01 12:06:30
阅读次数:
7
作者丨浮生忆梦 blog.csdn.net/m0_38110132/article/details/81481454 很长时间以来都没有怎么好好搞清楚RPC(即Remote Procedure Call,远程过程调用)和HTTP调用的区别,不都是写一个服务然后在客户端调用么?这里请允许我迷之一笑~N ...
分类:
Web程序 时间:
2020-11-18 13:23:32
阅读次数:
30
多线程在面试中基本上已经是必问项了,面试官通常会从简单的问题开始发问,然后再一步一步的挖掘你的知识面。
比如,从线程是什么开始,线程和进程的区别,创建线程有几种方式,线程有几种状态,等等。
接下来自然就会引出线程池,Lock,Synchronized,JUC的各种并发包。然后就会引出 AQS、CAS、JMM、JVM等偏底层原理,一环扣一环。
这一节我们不聊其他的,只说创建线程有几种方式。
是不是感觉非常简单,不就是那个啥啥那几种么。
其实不然,只有我们给面试官解释清楚了,并加上我们自己的理解,才能在面试中加分。
分类:
编程语言 时间:
2020-10-31 01:27:12
阅读次数:
74
面试的时候,经常被面试官问到AOP在你的项目中用到了那些场景,我一般的回答是日志,权限,事务处理,方法的统计,性能的监控。其实权限和事务都是跟业务相关的,咱们一起来想想针对其他几个如何来设计。重点是设计的思路。源码:https://github.com/limingios/netFuture/tree/master/tuling-enhance-plugin-masterAOP能干什么?日志新增的
分类:
编程语言 时间:
2020-10-19 22:52:55
阅读次数:
27
序言本节将学习一下如何实现异步查询转同步的方式,共计介绍了7种常见的实现方式。思维导图如下:异步转同步业务需求有些接口查询反馈结果是异步返回的,无法立刻获取查询结果。比如业务开发中我们调用其他系统,但是结果的返回确实通知的。或者rpc实现中,client调用server端,结果也是异步返回的,那么如何同步获取调用结果呢?正常处理逻辑触发异步操作,然后传递一个唯一标识。等到异步结果返回,根据传入的唯
分类:
编程语言 时间:
2020-10-10 17:23:37
阅读次数:
25
多线程 一个进程是程序运行的实例 线程是一个进程中的执行场景/执行单元 一个进程可以启动多个线程 每个java程序都至少启动了两个线程:main主线程和垃圾回收线程 在不同线程间 堆和方法区共享,但是一个线程一个栈 在多线程的环境中,当main 方法结束只是意味着主栈空了,但是其他的分支线程拥有的支 ...
分类:
编程语言 时间:
2020-10-06 19:52:24
阅读次数:
87
Ubuntu18.04 安装配置 Cadence Virtuoso617 之前的Centos7为了使用spectre提供的matlab toolbox,结果不小心删除了/usr/lib64中的某些动态库(XXXX.so文件),导致重启之后内核崩溃。 这里送上忠告:尽量不要使用rm命令,使用mv命令改 ...
分类:
系统相关 时间:
2020-09-17 19:36:16
阅读次数:
119
原文链接:Await and Async Explained with Diagrams and Examples 文章目录 简介 Promise 问题:组合 Promise Async 函数 Await 错误处理 讨论 简介 JavaScript ES7中的 async/await 使得协调异步 ...
分类:
其他好文 时间:
2020-09-17 18:17:19
阅读次数:
33
1:入参不同 excute() 传入的是 Runable, submit 传入的是 Callable 或 Runable 1):execute 方法源码 public void execute(Runnable command) { ... } 2):submit方法源码 public Future ...
分类:
其他好文 时间:
2020-09-16 12:14:48
阅读次数:
35