张士玉小黑屋

为什么我们需要ValueTuple？Tuple是引用类型，但ValueTuple是值类型。Tuple不提供命名约定，但ValueTuple提供了强大的命名约定。在Tuples中，您不能创建零分量的元组，但在ValueTuple中，您可以创建零元素的元组。ValueTuple的性能优于Tuple。因为ValueTuple提供了一种轻量级的机制，用于从现有方法返回多个值。并且ValueTuple的语法比Tuples更优化。ValueTuple通过使用解构和_关键字为访问值元组的元素提供了更大的灵活性。但是Tuple不能提供解构的概念和_关键字。在ValueTuple中，item1和item2等成员是字段。但在元组中，它们是属

书接上回，【Flink源码】再谈Flink程序提交流程（上）一文中我们已经将程序从客户端提交给了ResourceManager接下来我们就去ResourceManager中一探究竟创建Dispatcher、ResourceManagerYarnJobClusterEntrypoint类是Yarnper-job集群的入口，包含了我们想看的main方法YarnJobClusterEntrypoint.javapublicstaticvoidmain(String[]args){LOG.warn("JobClustersaredeprecatedsinceFlink1.15.PleaseuseanAp

TaskExecutor.hTask|TaskIn一个是函数对象，一个是可调用的类对象usingTaskIn=std::function<void()>;usingTask=TaskCancelableImp<void()>;TaskCancelableImp一个重载了operator()的类，返回值和参数是对应的模板参数，函数可取消取消通过一强一弱智能指针实现同时定义了取消后的默认返回值template<classR,class...ArgTypes>classTaskCancelableImp<R(ArgTypes...)>:publicTaskCancelable{public:

写在前面在【Flink源码】再谈Flink程序提交流程（中）一文中，笔者后来发现谬误颇多，且随着Flink版本的更迭，部分方法实现方式已发生较大改变。因此，思虑再三决定针对JobManager相关源码根据最新的Flink版本（1.17）单独成文。JobManager是什么？Flink的主节点JobManager是一个逻辑上的主节点，针对不同的部署模式，主节点的实现类也不一样JobManager有三大核心内容：ResourceManager、Dispatcher和WebMonitorEndpointResourceManager：Flink集群的资源管理器，只有一个，负责Slot的管理和申请等工作Dispatcher：负责接收用户提交Jo

集成HTTP库axios集成HTTP库axios我们定位到web的目录，使用命令安装axios:指定版本号：我们定位到Home.vue，我们要在这个页面通过axios用电子书列表功能。导入axios，在setuo中使用：启动后端和前端，发现报错：为了解决跨域问题，我们后端需要增加一个配置类：@ConfigurationpublicclassCorsConfigimplementsWebMvcConfigurer{@OverridepublicvoidaddCorsMappings(CorsRegistryregistry){registry.addMapping("/**").allowedO

文章目录如何保证消息不丢失Go实现安装操作库发送端的确认消费端的确认如何保证消息不丢失在使用RabbitMQ的时候，我们需要保证消息不能丢失，消息从生产者生产出来一直到消费者消费成功，这条链路是这样的：消息的可靠投递分为了两大内容：发送端的确认（p->broker和exchange->queue）和消费端的确认（queue->c）。发送端的确认Rabbit提供了两种方式来保证发送端的消息可靠性投递：confirm确认模式和return退回模式。confirm确认模式：消息从producer到达exchange则会给producer发送一个应答，我们需要开启confirm模式，才能接收到这条应答。开启方式是将Channel.Con

EventPoller.hWorkThreadPool.hEventPollerUML继承自TaskExecutor类，最重要的是实现async方法结构std::thread::id_loop_thread_id//执行事件循环的线程id//async相关//内部事件管道PipeWrap_pipe;//从其他线程切换过来的任务std::mutex_mtx_task;List<Task::Ptr>_list_task;//epoll相关int_epoll_fd=-1;unordered_map<int,std::shared_ptr<PollEventCB>>_eve

FRP介绍frp是一个高性能的反向代理应用，支持tcp,udp,http,https协议。https://github.com/fatedier/frp/releases可以根据不同的需要选择不同的版本，我用的是linux进行测试 流程介绍因为黑客机处于内网，受害机也处于内网，他们不能直接通信此时就需要一个公网的ip来扮演“中间人”的角色，让他们俩个能够成功的通信演示环境黑客机就用我虚拟机中的kaliVPS用的阿里云服务器，只要是公网的ip就可以受害机用的我朋友的电脑步骤服务端将frp通过xftp上传到VPS上 vim打开frps.ini进行编辑，此处的端口为frp服务的端口，token为密钥，设置完后就必须通过token来连接frp服

代理模式分为静态代理和动态代理静态代理介绍类似于生活中的中介代理房东租房、婚介代理要结婚的情侣布置婚礼现场等等。实现拿房东租房为例Rent接口packagecom.curtian.study.static_proxy.demo1;publicinterfaceRent{voidrent();}Rent接口的第一个实现类，房东packagecom.curtian.study.static_proxy.demo1;/***房东*/publicclassHostimplementsRent{@Overridepublicvoidrent(){System.out.println("房东租房子");}}

目录一、JavaScript运算符1.运算符2.算数运算符3.递增和递减运算符4.比较运算符5.逻辑运算符5.1逻辑与5.2逻辑或6.赋值运算符7.运算符优先级二、JavaScript流程控制三、JavaScript数组1.创建数组1.1利用new创建数组1.2利用数组字面量创建数组2.获取数组中的元素3.数组中新增元素四、JavaScript函数函数的返回值arguments的使用函数声明方式五、JavaScript作用域1.变量的作用域2.作用域链六、JavaScript预解析七、JavaScript对象创建对象的三种方式1.利用字面量创建对象2.利用newObject创建对象3.利用构造函数创建对象new关键字遍历对象属