Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work.
Claim your profile
Articles by import java.util.concurrent.Future
Kafka之【生产消息】-CSDN博客
消息（Record） 在kafka中传递的数据我们称之为消息（message）或记录(record)，所以Kafka发送数据前，需要将待发送的数据封装为指定的数据模型： 相关属性必须在构建数据模型时指定，其中主题和value的值是必须要传递的。如果配置中开启了自动创建主题，那么Topic主题可以不存在。value就是我们需要真正传递的数据了，而在未指定分区器或者未指定分区得情况下，Key可以用于数据的分区定位。 根据前面提供的配置信息创建生产者对象，通过这个生产者对象向Kafka服务器节点发送数据，而具体的发送是由生产者对象创建时，内部构建的多个组件实现的，多个组件的关系有点类似于生产者消费者模式。 生产者（Producer）是一个关键组件，负责将消息发送到Kafka集群。Kafka生产者主要由三个核心部分组成： KafkaProducer RecordAccumulator Sender 数据生产者（KafkaProducer）...
商城项目【尚品汇】08异步编排-CSDN博客
1.线程的创建方式 package com.atguigu.gmall.product.thread; import java.math.BigDecimal; public class ThreadTest { public static void main(String[] args) { System.out.println("主线程开始"); Thread thread = new Thread01(); thread.start(); System.out.println("主线程完毕"); } public static class Thread01 extends Thread{ @Override public void run() { System.out.println("通过继承Thread类，重写run()方法，创建线程"+Thread.currentThread().getId()); BigDecimal bigDecimal = new BigDecimal(10); BigDecimal bigDecimal1 = new...
JavaSE多线程-CSDN博客
一:程序、进程和线程 静态代码 例如 软件 动态过程 如 运行中的qq等软件 一个正在运行的程序 程序是静态的，进程是动态的； 简而言之:线程是进程的一个执行单元。比进程更小的独立运行的基本单位。 注：一个程序至少一个进程，一个进程至少一个线程。比如视频中同时有声音、图像、弹幕等; 简单 进程 线程；任务 二:线程的创建和启动（Java如何实现线程的） 概述 Java语言的JVM允许程序运行多个线程（Java允许同时执行多个代码的），它通过java.lang.Thread类来体现。 Thread类的特性: 每个线程都是通过某个特定Thread对象的run()方法来完成操作的，经常把run()方法的主体称为线程体。 通过该Thread对象的start()方法来启动这个线程，而非直接调用run()。 JDK1.5之前创建新执行线程有两种方法： 继承Thread类的方式； 实现Runnable接口的方式； 继承Thread类 定义子类继承Thread类。 子类中重写Thread类中的run方法，把新线程要做的事写在run方法中。 创建Thread子类对象，即创建线程对象。...
Kafka生产与消费详解-CSDN博客
Kafka生产与消费全流程 Kafka是一款消息中间件，消息中间件本质就是收消息与发消息，所以这节课我们会从一条消息开始生产出发，去了解生产端的运行流程，然后简单的了解一下broker的存储流程，最后这条消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、Kafka客户端是如何去设计一个非常优秀的生产级的保证高吞吐的一个缓冲机制 2、消费端的原理：每个消费组的群主如何选择，消费组的群组协调器如何选择，分区分配的方法，分布式消费的实现机制，拉取消息的原理，offset提交的原理。 Kafka一条消息发送和消费的流程(非集群) 我们这里使用Kafka内置的客户端API开发kafka应用程序。因为我们是Java程序员，所以这里我们使用Maven，使用较新的版本 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.3.1</version> </dependency> 生产者...
教你如何判断Java代码中异步操作是否完成 - 华为云开发者联盟 - 博客园
本文分享自华为云社区《java代码实现异步返回结果如何判断异步执行完成》，作者： 皮牙子抓饭。 在许多应用程序中，我们经常使用异步操作来提高性能和响应度。在Java中，我们可以使用多线程或者异步任务来执行耗时操作，并且在后台处理过程完成后获取结果。但是，在使用异步操作时，我们通常需要知道异步任务何时完成，以便进行下一步的操作。 本篇文章将介绍几种常见的方法来判断Java代码中异步操作是否完成。 1.
【中介者模式(Mediator)】使用Java实现中介者模式 - 四处观察 - 博客园
中介者，何为中介者，顾名思义就是我们的在处理A和B之间的关系的时候，引入一个中间人，来处理这两者之间的关系，例如生活中我们需要去租房，买房，都会有中介，来处理房东和租客之间的协调关系，这个就是中介者，落实到具体的代码中呢，就像我们的Controller可能会依赖很多的Service层面的东西，在这里的代码都会注入很多Service，导致依赖很严重，耦合较高，并且多的情况下会使得Controller的代码看起来并不是那么简洁，而中介者模式，恰恰可以解决这一痛楚，降低Controller和Service层面的依赖，通过一个接口，来实现Controller调用业务层面的操作，在中介者体系下，我们更多的是关注我们自身的业务，以及在业务之中，我们如何构建我们的业务模型，以及每个业务需要做的事件处理操作即可，换做以往的开发模式，我们需要依赖Bussiness A,B,C三个Service。在引入了Mediator中介者模式，我们的Controller只需要注入并引入IMediator的对象，即可实现调用对应的A,B,C的业务操作。接下来，我们一起看看，如何设计以及如何使用。...
Windows安装和使用kafka-CSDN博客
一、安装kafka 由于kafka依赖jdk和zookeeper，安装kafka之前需要先安装jdk和zookeeper，也可以使用kafka自带的zookeeper。安装jdk可以参考：Windows和Linux安装jdk，此处使用kafka自带的zookeeper，不单独安装。 下面在Windows系统中安装kafka时使用的ip地址是192.168.10.188，这是我自己电脑的ip。 修改zk和kafka的配置文件。 修改zk的配置文件： 配置上面创建的mydata目录，用于保存zookeeper的数据。 修改kafka的配置文件：...
关于Kafka事务处理的详细讲解-CSDN博客
Kafka事务 producer可能给多个topic，多个partition发送消息，这些消息组成一个事务，这些消息需要对consumer同时可见或者同时不可见。Kafka事务需要在producer端处理，consumer端不需要做特殊处理，跟普通消息消费一样 1.事务流程 整个流程步骤： 事务初始化: InitTransactions,事务初始化是一次性的而事务开启、提交/回滚则一致循环运行 开启事务: beginTransaction 发送消息，向n个topic发送多条:producer.send 提交事务: commitTransaction 回滚事务:abortTransaction 2、事务配置 Producer Consumer transactional.id 事务ID，类型为String字符串，默认为空，客户端自定义，例如"order_bus" isolation.level 事务隔离级别，默认为空，开启事务的话，需要将其设置为"read_committed" enable.idempotence...
Async File IO | Concurrency Deep Dives
In this article, learn about low-level Java/Scala async file IO: How AsynchronousFileChannel works. Where does the IO operation take place? The implications of OS write buffers. TLDR On Linux, the AsynchronousFileChannel merely shifts a blocking IO operation to an executor service. There is no native support. It is easier to exhaust available heap memory than with a synchronous FileChannel if you submit writes faster than the IO operations can complete. The Operating System (OS) lies.
The Long Road to Java Virtual Threads
It's taken nearly 30 years. Java 1.21's introduction of Virtual Threads will finally make multitasking in Java almost effortless. In order to fully appreciate their revolutionary nature, it is helpful to take a look at the various imperfect solutions offered by Java over the years to solve the "do useful work while we wait for something else" problem. Java 1 The Introduction of Java version 1 in 1995 was remarkable.
Java多线程与并发-阿里云开发者社区
序号 地址 1 计算机网络核心 2 数据库相关 3 Redis 4 Linux相关 5 JVM的内容 6 GC相关的 7 Java多线程与并发 8 Java多线程与并发-原理 9 Java常用类库与技巧 10 Java框架-Spring 1、JDK版本的选择 选择JDK8、JDK11进行讲解的原因：Oracle长期支持 2、进程和线程的区别 进程和线程的由来 3、进程与线程的区别 进程是资源分配的最小单位,线程是cpu调度的最小单位.
javaEE -3（12000字详解多线程）
一：单例模式 首先啥是设计模式? 设计模式好比象棋中的 “棋谱”. 红方当头炮, 黑方马来跳. 针对红方的一些走法, 黑方应招的时候有一些固定的套路. 按照套路来走局势就不会吃亏. 软件开发中也有很多常见的 “问题场景”. 针对这些问题场景, 大佬们总结出了一些固定的套路. 按照这个套路来实现代码, 也不会吃亏. 单例模式能保证某个类在程序中只存在唯一一份实例, 而不会创建出多个实例，这一点在很多场景上都需要. 比如 JDBC 中的 DataSource 实例就只需要一个。 而单例模式具体的实现方式, 分成 “饿汉” 和 “懒汉” 两种. 类加载的同时, 创建实例.
Springboot中使用线程池的三种方式 - 天下没有收费的bug - 博客园
前言 多线程是每个程序员的噩梦,用得好可以提升效率很爽，用得不好就是埋汰的火葬场。 这里不深入介绍，主要是讲解一些标准用法，熟读唐诗三百首，不会作诗也会吟。 这里就介绍一下springboot中的多线程的使用，使用线程连接池去异步执行业务方法。 由于代码中包含详细注释,也为了保持文章的整洁性，我就不过多的做文字描述了。 VisiableThreadPoolTaskExecutor 编写 new VisiableThreadPoolTaskExecutor() 方式创建线程池, 返回值是 Executor 点击查看代码 import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.util.concurrent.ListenableFuture; import java.util.concurrent.Callable; import...
Kafka生产与消费示例_奔跑的码农小哥的博客-CSDN博客
Kafka是一款消息中间件，消息中间件本质就是收消息与发消息，所以这节课我们会从一条消息开始生产出发，去了解生产端的运行流程，然后简单的了解一下broker的存储流程，最后这条消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、Kafka客户端是如何去设计一个非常优秀的生产级的保证高吞吐的一个缓冲机制 2、消费端的原理：每个消费组的群主如何选择，消费组的群组协调器如何选择，分区分配的方法，分布式消费的实现机制，拉取消息的原理，offset提交的原理。 简单入门 我们这里使用Kafka内置的客户端API开发kafka应用程序。因为我们是Java程序员，所以这里我们使用Maven，使用较新的版本 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.3.1</version> </dependency> 先创建一个主题，推荐在消息发送时创建对应的主题。当然就算没有创建主题，Kafka也能自动创建。...
白嫖一个属于你的私有大模型 - yejg1212 - 博客园
最近国内的大模型可谓是遍地开花，你瞧瞧： 这么火，我也想搞一个试试，于是就有了这篇文章！对，你没看错，就是白嫖。 毕竟人家清华都开源了，哈哈哈hoho~~ 先把开源地址贴一下，老铁们可以自行去瞧一瞧： https://github.com/THUDM/ChatGLM-6B https://huggingface.co/THUDM/chatglm-6b ChatGLM-6B 是一个开源的、支持中英双语问答的对话语言模型，基于 General Language Model (GLM) 架构，具有 62 亿参数。 结合模型量化技术，用户可以在消费级的显卡上进行本地部署（INT4 量化级别下最低只需 6GB 显存）。 ChatGLM-6B 使用了和 ChatGLM 相同的技术，针对中文问答和对话进行了优化。 经过约 1T 标识符的中英双语训练，辅以监督微调、反馈自助、人类反馈强化学习等技术的加持，62 亿参数的 ChatGLM-6B 已经能生成相当符合人类偏好的回答。 最重要的一点，人家遵循Apache-2.0协议。 下面开干吧！ 准备机器...
实现多线程的4种方式_242030的博客-CSDN博客
实现多线程的4种方式 使用实现多线程有四种方式： 继承 Thread 类； 实现 Runnable 接口； 使用 Callable 和 FutureTask 实现有返回值的多线程； 使用 ExecutorService 和 Executors 工具类实现线程池(如果需要线程的返回值，需要在线程中实现 Callable 和 Future 接口) Thread 类本质上是实现了 Runnable 接口的一个实例，代表一个线程的实例。启动线程的唯一方法就是通过 Thread 类的 start() 实例方法，start() 方法是一个 native 方法，它将启动一个新线程，并执行 run() 方法。 继承 Thread 类的优点：简单，且只需要实现父类的 run 方法即可( start 方法中含有 run 方法，会创建一个新的 线程，而 run 是执行当前线程)。 继承 Thread 类的缺点：Java 的单继承，如果对象已经继承了其他的类则不能使用该方法，且不能获取线程的返回 值。 package com.multithreading; public class ThreadDemo...
Kafka-工作流程、如何保证消息可靠性_吃豆子的恐龙的博客-CSDN博客
分布式事件流平台。希望不仅仅是存储数据，还能够数据存储、数据分析、数据集成等功能。消息队列（把数据从一方发给另一方），消息生产好了但是消费方不一定准备好了（读写不一致），就需要一个中间商来存储信息，kafka就是中间商 架构图如下： 名称 解释 Broker 消息中间件处理节点，一个Kafka节点就是一个broker，一个或者多个Broker可以组成一个Kafka集群 Topic Kafka根据topic对消息进行归类，发布到Kafka集群的每条消息都需要指定一个topic Producer 消息生产者，向Broker发送消息的客户端 Consumer 消息消费者，从Broker读取消息的客户端 ConsumerGroup 每个Consumer属于一个特定的Consumer Group，一条消息可以被多个不同的Consumer Group消费，但是一个Consumer Group中只能有一个Consumer能够消费该消息 Partition 物理上的概念，一个topic可以分为多个partition，每个partition内部消息是有序的 offset...
多线程进阶_小白不想秃头的博客-CSDN博客
本章博客主要是围绕一些多线程相关的面试题，讨论的内容都是往年同学遇到的原题，以后面试也大概率会遇到的！！！ 常见的锁策略 锁策略指的不是某个具体的锁，是一个抽象的概念，描述的是锁的特性，描述的是一类锁 乐观锁：预测该场景中，不太会出现锁冲突的情况（后续做的工作更少） 悲观锁：预测该场景中，非常容易出现锁冲突（后续做的工作更多） 锁冲突：两个线程尝试获取一把锁，一个能获取成功，另一个线程阻塞等待 锁冲突的概率大/小，对后续的工作，是有一定影响的 重量级锁：加锁开销是比较大的（花的时间多，占用系统资源多） 轻量级锁：加锁的开销比较小（花的时间少，占用系统资源少） 一个悲观锁，很可能是重量级锁（不绝对） 一个乐观锁，很可能是轻量级锁（不绝对） 悲观乐观，是在加锁之前，对锁冲突概率的预测，决定工作的多少 重量轻量，是在加锁之后，考量实际锁的开销 正是因为这样的概念重合，针对一个具体的锁，可能把它叫做乐观锁，也可能叫做轻量级锁 自旋锁是轻量级锁的一种典型实现，在用户态下，通过自旋的方式（比如while循环），实现类似于加锁的效果...
Kafka_JokeOrSerious的博客-CSDN博客
Kafka的Pruducer采取异步发送，两个线程：main线程和sender线程，一个线程共享变量-RecordAccumulator main给RecordAccumulator，Sender线程从RecordAccumulator中拉取消息发送到Kafka broker。 发送流程 main线程(Producer->Itercepters->Serializer->Partitioner)->RecordAccumulator->Sender Itercepters拦截器：传入String Serializer序列化器：传入String,返回Byte Partitioner分区器：传入Byte <!--导入依赖--> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.2.0</version> </dependency> package com.atguigu.producer; import...
KAFKA第二课之生产者(面试重点)_叫我莫言鸭的博客-CSDN博客
生产者学习 在消息发送的过程中，涉及到了两个线程——main线程和Sender线程。在main线程中创建了一个双端队列RecordAccumulator。main线程将消息发送给RecordAccumulator，Sender线程不断从RecordAccumulator中拉取消息发送到Kafka Broker。 生产者如何发送的？ 现在Main线程中将数据进行处理，处理成IO型数据，然后调用sender进行发送 Main: 1.读取生产者配置 2.产生数据 3.过滤数据（校验什么的） 4.序列化 5.放入缓冲区 RecordAccumulator 6.发送Sender 细节： 考虑的问题 1.生产者配置的读取和修改 2.数据的过滤与分区， 3.缓冲区是如何设置的，大小 4.发送（发送失败怎么样，请求区的大小） 这里注意一下，可以在缓冲区对数据进行压缩，这样就提高缓冲区的容量和发送的数据量，提高吞吐量 1.什么是同步和异步 同步就是，串行，一条龙 异步 一起运行 举例： 餐馆点餐 同步： 需要等服务员过来，让服务员记录， 异步： 点餐APP直接点餐，交给队列，让他自己运行...
Java 中创建线程的几种方式_java创建线程_程序媛-徐师姐的博客-CSDN博客
Java 是一种面向对象的编程语言，它支持多线程编程。多线程编程是指在一个程序中同时运行多个线程，这些线程可以并行执行，以提高程序的效率和性能。Java 提供了多种创建线程的方法，本文将介绍这些方法以及它们的优缺点。 继承 Thread 类 Java 中的 Thread 类是一个抽象类，我们可以通过继承 Thread 类来创建一个新的线程。具体实现方法是创建一个类并继承 Thread 类，然后重写 run() 方法。run() 方法是线程的主体，它包含线程要执行的代码。创建线程后，通过调用 start() 方法来启动线程。 下面是一个使用继承 Thread 类创建线程的示例代码： public class MyThread extends Thread { public void run() { System.out.println("MyThread is running."); } public static void main(String[] args) { MyThread myThread = new MyThread(); myThread.start(); } }...
二、Kafka生产与消费全流程_kafka 生产_JavaHxg的博客-CSDN博客
Kafka是一款消息中间件，消息中间件本质就是收消息与发消息，所以这节课我们会从一条消息开始生产出发，去了解生产端的运行流程，然后简单的了解一下broker的存储流程，最后这条消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、Kafka客户端是如何去设计一个非常优秀的生产级的保证高吞吐的一个缓冲机制 2、消费端的原理：每个消费组的群主如何选择，消费组的群组协调器如何选择，分区分配的方法，分布式消费的实现机制，拉取消息的原理，offset提交的原理。 简单入门 我们这里使用Kafka内置的客户端API开发kafka应用程序。因为我们是Java程序员，所以这里我们使用Maven，使用较新的版本 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.3.1</version> </dependency> 生产者 先创建一个主题，推荐在消息发送时创建对应的主题。当然就算没有创建主题，Kafka也能自动创建。...
2、java调用kafka api
1、kafka（2.12-3.0.0）介绍、部署及验证、基准测试 2、java调用kafka api 3、kafka重要概念介紹及示例 4、kafka分区、副本介绍及示例 5、kafka监控工具Kafka-Eagle介绍及使用 本分介绍java调用kafka api。 本文前置条件是kafka环境搭建好。 本分五部分，即简单的写数据到kafka、从topic中消费数据、异步回调、读写kafka中复杂数据类型和读取历史数据。 将1-100的数字消息写入到Kafka中。 导入Maven Kafka POM依赖 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.4.1</version> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-io</artifactId> <version>1.3.2</version>...
JAVA连接Kafka及SSL认证_java kafka ssl_小小白帝的博客-CSDN博客
JAVA连接Kafka 1、Maven驱动(注意一定要对应自己的Kafka版本) <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.12</artifactId> <version>2.5.0</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.5.0</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>2.5.0</version> </dependency> 2、生产者生产数据 2.1 普通方式创建Producer package com.tyhh.test; import...
Kafka配置动态SASL_SCRAM认证_kafka scram_冰之杍的博客-CSDN博客
Kafka中需要加上认证，并动态新增用户，SASL/SCRAM验证可以支持 本文章是对https://blog.csdn.net/qq_38616503/article/details/117529690中的内容整理与重新记录 第一步，在没有设置任何权限的配置下启动Kafka和Zookeeper，如需要从头安装Kafka，可参见Kafka的安装单机安装以及集群安装 (1)创建broker通信用户：admin(在使用sasl之前必须先创建,否则启动报错) bin/kafka-configs.sh --zookeeper 192.168.56.101:2181,192.168.56.102:2181,192.168.56.103:2181 --alter --add-config 'SCRAM-SHA-256=[password=admin-sec],SCRAM-SHA-512=[password=admin-sec]' --entity-type users --entity-name admin (2)创建生产用户producer bin/kafka-configs.sh...
大数据-玩转数据-Flink Python作业开发
一、PyFlink 的核心目标 将 Flink 能力输出到 Python 用户，进而可以让 Python 用户使用所有的 Flink 能力。 将 Python 生态现有的分析计算功能运行到 Flink 上，进而增强 Python 生态对大数据问题的解决能力。 二、PyFlink技术架构 三、PyFlink实用场景 在具体的案例之前我们先简单分享一些 PyFlink 所能适用的业务场景。首先 PyFlink 既然是 Python+Flink，那其适用场景也可以从 java 和 Python 两方面去分析，第一个 Java 所适用的场景 PyFlink 都适用。 第一个，事件驱动型，比如：刷单，监控等； 第二个，数据分析型的，比如：库存，双11大屏等； 第三个适用的场景是数据管道，也就是ETL场景，比如一些日志的解析等； 第四个场景，机器学习，比如个性推荐等。 这些都可以尝试使用 PyFlink 。除此之外还有 Python 生态特有的场景，比如科学计算等。那么这么多的应用场景，PyFlink 到底有哪些可用的 API 呢？ 四、PyFlink 的安装 使用具体的 API...
Kafka示例（Java版）_java kafka_我是真的想笑的博客-CSDN博客
安装1.8或以上版本JDK。具体操作。请参见安装JDK。 安装2.5或以上版本Maven。具体操作，请参见安装Maven。 在pom.xml中添加以下依赖 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.4.0</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.6</version> </dependency> 说明：建议您保持服务端和客户端版本一致，即保持客户端库版本和消息队列Kafka版实例的大版本一致。您可以在消息队列Kafka版控制台的实例详情页面获取消息队列Kafka版实例的大版本。 1）可选：下载SSL根证书。如果是SSL接入点，需下载该证书。...
Java: The Missing Features
In this article, we look at some of the "missing features" of Java. Before we get fully underway, however, we should point out that there are some features that we deliberately don’t consider. This is usually because the feature has either been extensively discussed elsewhere, or would require too much work at VM level. For example: No reified generics. This has been discussed at great length elsewhere and much of the commentary frequently misunderstands type erasure.
Show More
loading
Actions
Is this you?
As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work.Get in touch with import
Contact import, search articles and posts on X, monitor coverage, and track replies from one place.
Learn more about Muck Rack