Android Framework底层原理之WMS的启动流程

news2024/9/29 9:34:11

一 概述

今天,我们介绍 WindowManagerService(后续简称 WMS)的启动流程,WMS 是 Android 系统中,负责窗口显示的的服务。在 Android 中它也起着承上启下的作用。

如下图,就是《深入理解 Android》书籍中的一张图。

图中展示了,WMS 在 Android 系统的地位,它作为中间层,连接了上层的 View 框架和下层的 SurfaceFingler。了解了 WMS 的工作机制,我们就彻底打通了上层 VIew 到底层 Surface,甚至到显示器如何显示的逻辑。

接下来,我们依旧从 WMS 的启动开始,来看 WMS 是如何启动的。

二 从 SystemServer 开始

2.1 startOtherServices

[frameworks/base/services/java/com/android/server/SystemServer.java]
private void startOtherServices(@NonNull TimingsTraceAndSlog t) {

	WindowManagerService wm = null;
	
	// 这里传入的 PhoneWindowManager 就是 WMS 中的 WindowManagerPolicy
	wm = WindowManagerService.main(context, inputManager, !mFirstBoot, mOnlyCore,
			new PhoneWindowManager(), mActivityManagerService.mActivityTaskManager);
			
	ServiceManager.addService(Context.WINDOW_SERVICE, wm, /* allowIsolated= */ false,
			DUMP_FLAG_PRIORITY_CRITICAL | DUMP_FLAG_PROTO);
	
	// 将 WMS 设置到 AMS 中
	mActivityManagerService.setWindowManager(wm);
	
	wm.onInitReady();

	...

	try {
		wm.displayReady();
	} catch (Throwable e) {
		reportWtf("making display ready", e);
	}

	...

	try {
		wm.systemReady();
	} catch (Throwable e) {
		reportWtf("making Window Manager Service ready", e);
	}

	...

	// 更新上下文中,关于显示窗口相关的属性
	final Configuration config = wm.computeNewConfiguration(DEFAULT_DISPLAY);
	DisplayMetrics metrics = new DisplayMetrics();
	context.getDisplay().getMetrics(metrics);
	context.getResources().updateConfiguration(config, metrics);

}

和 AMS 不同的是,WMS 的启动是在 SystemServer 的 startOtherServices 中,启动过程依旧是我们之前提过的构造、注册,只是少了 onStart 这个步骤。

并且,在 WMS 启动之后,还会陆续调用一些其他的函数

  • onInitReady
  • displayReady
  • systemReady
  • updateConfiguration

接下来,我们会根据 WMS 启动过程中调用的函数,以此查看它们具体的实现原理。

从 AMS 和 WMS 的启动,我们可以看出来,它们都是隶属于 SystemServer 进程的,根据之前我们对应用和 AMS 的了解,也经常看到它们交互的流程中,有 WMS 的身影,所以虽然说是应用和 AMS,WMS 的通信,实际上就是应用和 SystemServer 进程的通信。

2.2 main

[frameworks/base/services/core/java/com/android/server/wm/WindowManagerService.java]
public static WindowManagerService main(final Context context, final InputManagerService im,
		final boolean showBootMsgs, final boolean onlyCore, WindowManagerPolicy policy,
		ActivityTaskManagerService atm) {
	return main(context, im, showBootMsgs, onlyCore, policy, atm,
			new DisplayWindowSettingsProvider(), SurfaceControl.Transaction::new, Surface::new,
			SurfaceControl.Builder::new);
}

public static WindowManagerService main(final Context context, final InputManagerService im,
		final boolean showBootMsgs, final boolean onlyCore, WindowManagerPolicy policy,
		ActivityTaskManagerService atm, DisplayWindowSettingsProvider
		displayWindowSettingsProvider, Supplier<SurfaceControl.Transaction> transactionFactory,
		Supplier<Surface> surfaceFactory,
		Function<SurfaceSession, SurfaceControl.Builder> surfaceControlFactory) {
	DisplayThread.getHandler().runWithScissors(() ->
			sInstance = new WindowManagerService(context, im, showBootMsgs, onlyCore, policy,
					atm, displayWindowSettingsProvider, transactionFactory, surfaceFactory,
					surfaceControlFactory), 0);
	return sInstance;
}

在 WMS 的 main 函数中主要做了两件事

  1. 创建了一个 WMS 对象
  2. 将这个 WMS 对象传递给了 DisplayThread

我们首先看这个 WMS 对象的构造函数

三 WindowManagerService

3.1 WMS 的构造函数

private WindowManagerService(Context context, InputManagerService inputManager,
		boolean showBootMsgs, boolean onlyCore, WindowManagerPolicy policy,
		ActivityTaskManagerService atm, DisplayWindowSettingsProvider
		displayWindowSettingsProvider, Supplier<SurfaceControl.Transaction> transactionFactory,
		Supplier<Surface> surfaceFactory,
		Function<SurfaceSession, SurfaceControl.Builder> surfaceControlFactory) {
	installLock(this, INDEX_WINDOW);

	// ActivityTaskManagerService
	mGlobalLock = atm.getGlobalLock();
	mAtmService = atm;
	mContext = context;
	mIsPc = mContext.getPackageManager().hasSystemFeature(FEATURE_PC);
	mAllowBootMessages = showBootMsgs;
	...

	// 输入法管理
	mInputManager = inputManager; // Must be before createDisplayContentLocked.
	// 显示管理
	mDisplayManagerInternal = LocalServices.getService(DisplayManagerInternal.class);

	// Surface 图像相关
	mSurfaceControlFactory = surfaceControlFactory;
	mTransactionFactory = transactionFactory;
	mSurfaceFactory = surfaceFactory;
	mTransaction = mTransactionFactory.get();

	mPolicy = policy;
	// 窗口动画
	mAnimator = new WindowAnimator(this);
	// 根窗口容器
	mRoot = new RootWindowContainer(this);

	final ContentResolver resolver = context.getContentResolver();
	mUseBLAST = Settings.Global.getInt(resolver,
		Settings.Global.DEVELOPMENT_USE_BLAST_ADAPTER_VR, 1) == 1;

	mSyncEngine = new BLASTSyncEngine(this);

	mWindowPlacerLocked = new WindowSurfacePlacer(this);
	mTaskSnapshotController = new TaskSnapshotController(this);

	mWindowTracing = WindowTracing.createDefaultAndStartLooper(this,
			Choreographer.getInstance());

	LocalServices.addService(WindowManagerPolicy.class, mPolicy);

	mDisplayManager = (DisplayManager)context.getSystemService(Context.DISPLAY_SERVICE);

	mKeyguardDisableHandler = KeyguardDisableHandler.create(mContext, mPolicy, mH);

	mPowerManager = (PowerManager)context.getSystemService(Context.POWER_SERVICE);
	mPowerManagerInternal = LocalServices.getService(PowerManagerInternal.class);

	if (mPowerManagerInternal != null) {
		mPowerManagerInternal.registerLowPowerModeObserver(
				new PowerManagerInternal.LowPowerModeListener() {
			@Override
			public int getServiceType() {
				return ServiceType.ANIMATION;
			}

			@Override
			public void onLowPowerModeChanged(PowerSaveState result) {
				synchronized (mGlobalLock) {
					final boolean enabled = result.batterySaverEnabled;
					if (mAnimationsDisabled != enabled && !mAllowAnimationsInLowPowerMode) {
						mAnimationsDisabled = enabled;
						dispatchNewAnimatorScaleLocked(null);
					}
				}
			}
		});
		mAnimationsDisabled = mPowerManagerInternal
				.getLowPowerState(ServiceType.ANIMATION).batterySaverEnabled;
	}
	mScreenFrozenLock = mPowerManager.newWakeLock(
			PowerManager.PARTIAL_WAKE_LOCK, "SCREEN_FROZEN");
	mScreenFrozenLock.setReferenceCounted(false);

	mDisplayNotificationController = new DisplayWindowListenerController(this);

	// AMS 相关
	mActivityManager = ActivityManager.getService();
	mActivityTaskManager = ActivityTaskManager.getService();
	mAmInternal = LocalServices.getService(ActivityManagerInternal.class);
	mAtmInternal = LocalServices.getService(ActivityTaskManagerInternal.class);
	... 
}

WMS 的构造函数的代码非常长,其中有包含各种服务,我们这里只关注和我们应用 Activity 相关的,还有和显示相关的窗口容器 RootWindowContainer,还有和刷新相关的 Surface

3.2 runWithScissors

另外,在 main 函数中,还调用了一个 runWithScissors,这个函数是 Handler 中定义的函数,这里我们简单看一下。

public final boolean runWithScissors(@NonNull Runnable r, long timeout) {
	if (r == null) {
		throw new IllegalArgumentException("runnable must not be null");
	}
	if (timeout < 0) {
		throw new IllegalArgumentException("timeout must be non-negative");
	}

	if (Looper.myLooper() == mLooper) {
		r.run();
		return true;
	}

	BlockingRunnable br = new BlockingRunnable(r);
	return br.postAndWait(this, timeout);
}

runWithScissors 是 Handler 中的函数,用一句话概括就是,如果发送消息的线程与 Handler 处理的线程相同,就直接调用。如果不同,就阻塞调用

3.3 onInitReady

public void onInitReady() {
	initPolicy();

	// Add ourself to the Watchdog monitors.
	Watchdog.getInstance().addMonitor(this);
	createWatermark();
	showEmulatorDisplayOverlayIfNeeded();
}

3.4 initPolicy

private void initPolicy() {
	UiThread.getHandler().runWithScissors(new Runnable() {
		@Override
		public void run() {
			WindowManagerPolicyThread.set(Thread.currentThread(), Looper.myLooper());
			// mPolicy 其实就是 PhoneWindowManager【5.1】
			mPolicy.init(mContext, WindowManagerService.this, WindowManagerService.this);
		}
	}, 0);
}

mPolicy 其实是 PhoneWindowManager,runWithScissors 前面介绍过了,如果是当前线程,就直接运行,如果不是当前线程,就阻塞运行。

所以这里是在 android.ui 线程中,运行 mPolicy 的初始化逻辑

3.5 createWatermark

void createWatermark() {
	if (mWatermark != null) {
		return;
	}

	File file = new File("/system/etc/setup.conf");
	FileInputStream in = null;
	DataInputStream ind = null;
	try {
		in = new FileInputStream(file);
		ind = new DataInputStream(in);
		String line = ind.readLine();
		if (line != null) {
			String[] toks = line.split("%");
			if (toks != null && toks.length > 0) {
				// TODO(multi-display): Show watermarks on secondary displays.
				final DisplayContent displayContent = getDefaultDisplayContentLocked();
				mWatermark = new Watermark(displayContent, displayContent.mRealDisplayMetrics,
						toks, mTransaction);
				mTransaction.apply();
			}
		}
	} ...
}

createWatermark 创建系统水印(只能显示文字)。

3.6 displayReady

[frameworks/base/services/core/java/com/android/server/wm/WindowManagerService.java]
public void displayReady() {
	synchronized (mGlobalLock) {
		if (mMaxUiWidth > 0) {
			mRoot.forAllDisplays(displayContent -> displayContent.setMaxUiWidth(mMaxUiWidth));
		}
		applyForcedPropertiesForDefaultDisplay();
		mAnimator.ready();
		mDisplayReady = true;
		// createWatermark重新配置所有显示器大小
		mRoot.forAllDisplays(DisplayContent::reconfigureDisplayLocked);
		// 是否触屏
		mIsTouchDevice = mContext.getPackageManager().hasSystemFeature(
				PackageManager.FEATURE_TOUCHSCREEN);
		mIsFakeTouchDevice = mContext.getPackageManager().hasSystemFeature(
				PackageManager.FEATURE_FAKETOUCH);
	}

	try {
		// ATMS
		mActivityTaskManager.updateConfiguration(null);
	} catch (RemoteException e) {
	}
}

displayReady 就是初始化显示器大小。

3.7 systemReady

[frameworks/base/services/core/java/com/android/server/wm/WindowManagerService.java]
public void systemReady() {
	mSystemReady = true;
	
	// 调用 PhoneWindowManager 的 systemReady
	mPolicy.systemReady();
	// 调用 DisplayPolicy 的 systemReady
	mRoot.forAllDisplayPolicies(DisplayPolicy::systemReady);
	// 调用 TaskSnapshotController 的 systemReady
	mTaskSnapshotController.systemReady();
	mHasWideColorGamutSupport = queryWideColorGamutSupport();
	mHasHdrSupport = queryHdrSupport();
	// 加载系统设置
	UiThread.getHandler().post(mSettingsObserver::loadSettings);
	// VR
	IVrManager vrManager = IVrManager.Stub.asInterface(
			ServiceManager.getService(Context.VR_SERVICE));
	if (vrManager != null) {
		try {
			final boolean vrModeEnabled = vrManager.getVrModeState();
			synchronized (mGlobalLock) {
				vrManager.registerListener(mVrStateCallbacks);
				if (vrModeEnabled) {
					mVrModeEnabled = vrModeEnabled;
					mVrStateCallbacks.onVrStateChanged(vrModeEnabled);
				}
			}
		} catch (RemoteException e) {
			// Ignore, we cannot do anything if we failed to register VR mode listener
		}
	}
}

3.8 computeNewConfiguration

public Configuration computeNewConfiguration(int displayId) {
	synchronized (mGlobalLock) {
		return computeNewConfigurationLocked(displayId);
	}
}

3.9 computeNewConfigurationLocked

private Configuration computeNewConfigurationLocked(int displayId) {
	if (!mDisplayReady) {
		return null;
	}
	final Configuration config = new Configuration();
	final DisplayContent displayContent = mRoot.getDisplayContent(displayId);
	displayContent.computeScreenConfiguration(config);
	return config;
}

displayId 表示的是显示设备的 id,这两段代码,就是通过 mRoot(RootWindowContainer)获取显示指定设备的 DisplayContent。说人话就是,通过显示器的 id,获取显示器对应的实例类 DisplayContent

四 DisplayThread

[frameworks/base/services/core/java/com/android/server/DisplayThread.java]
public final class DisplayThread extends ServiceThread {
    private static DisplayThread sInstance;
    private static Handler sHandler;

	private DisplayThread() {
		// DisplayThread 运行重要的东西,但 AnimationThread 更重要。因此,优先级设置为 THREAD_PRIORITY_DISPLAY + 1
		// THREAD_PRIORITY_DISPLAY 的值为 -4,
		super("android.display", Process.THREAD_PRIORITY_DISPLAY + 1, false /*allowIo*/);
	}

DisplayThread 就是 Android 中的 android.display 线程,它的优先级为 THREAD_PRIORITY_DISPLAY + 1,THREAD_PRIORITY_DISPLAY 值为 -4,所以 android.display 线程的优先级是 -3。

再回到 【2.2】中,WMS 的 main 函数是通过 android.display 线程完成的,并且在 android.display 线程中,对 android.ui 线程进行了初始化。

五 UIThread

public final class UiThread extends ServiceThread {
    private static final long SLOW_DISPATCH_THRESHOLD_MS = 100;
    private static final long SLOW_DELIVERY_THRESHOLD_MS = 200;
    private static UiThread sInstance;
    private static Handler sHandler;

    private UiThread() {
        super("android.ui", Process.THREAD_PRIORITY_FOREGROUND, false /*allowIo*/);
    }

    @Override
    public void run() {
        // Make sure UiThread is in the fg stune boost group
        Process.setThreadGroup(Process.myTid(), Process.THREAD_GROUP_TOP_APP);
        super.run();
    }

UiThread 和 DisplayThread 一样,也是继承自 ServiceThread,它的线程名是 android.ui,优先级是 THREAD_PRIORITY_FOREGROUND,值为-2,所以 android.ui 线程的优先级是 -2。

六 PhoneWindowManager

PhoneWindowManager 是 WindowManagerPolicy 的实现类,它定义了手机窗口、处理输入事件以及与系统 UI 交互的策略和行为。

PhoneWindowManager 中的函数有很多,这里我们列举一个,其中的按键分发的函数 interceptKeyBeforeQueueing。

6.1 interceptKeyBeforeQueueing

[frameworks\base\services\core\java\com\android\server\policy\PhoneWindowManager.java]
public int interceptKeyBeforeQueueing(KeyEvent event, int policyFlags) {
	final int keyCode = event.getKeyCode();
	final boolean down = event.getAction() == KeyEvent.ACTION_DOWN;
	boolean isWakeKey = (policyFlags & WindowManagerPolicy.FLAG_WAKE) != 0
			|| event.isWakeKey();

	if (!mSystemBooted) {
		// 系统启动前,只监听电源按键
		if (down && (keyCode == KeyEvent.KEYCODE_POWER
				|| keyCode == KeyEvent.KEYCODE_TV_POWER)) {
			wakeUpFromPowerKey(event.getDownTime());
		} else if (down && (isWakeKey || keyCode == KeyEvent.KEYCODE_WAKEUP)
				&& isWakeKeyWhenScreenOff(keyCode)) {
			wakeUpFromWakeKey(event);
		}
		// 拦截掉电源键
		return 0;
	}


	// interceptKeyBeforeQueueing 主要就是对手机按键的事件拦截,这里我们简单列举几个
	// 返回键,音量键等等。
	switch (keyCode) {
		case KeyEvent.KEYCODE_BACK: {
			if (down) {
				mBackKeyHandled = false;
			} else {
				if (!hasLongPressOnBackBehavior()) {
					mBackKeyHandled |= backKeyPress();
				}
				// Don't pass back press to app if we've already handled it via long press
				if (mBackKeyHandled) {
					result &= ~ACTION_PASS_TO_USER;
				}
			}
			break;
		}

		case KeyEvent.KEYCODE_VOLUME_DOWN:
		case KeyEvent.KEYCODE_VOLUME_UP:

返回值是一个整型,如果是 0 就表示被拦截,一开始的电源按键我们就看到了,在系统没有启动前,电源按键只能用于系统启动,但是系统启动后,电源按键就可以用于其他的作用了,例如语音助手。

PhoneWindowManager 这个类主要的作用有:

  1. 按键的分发
  2. 窗口的管理

这里我们就不扩展了,后面遇到实际的场景再来说明。

七 总结

WMS 的启动流程比较简单,主要就是启动了两个线程 "android.display""android.ui"

如果你还没有掌握Framework,现在想要在最短的时间里吃透它,可以参考一下《Android Framework核心知识点》,里面内容包含了:Init、Zygote、SystemServer、Binder、Handler、AMS、PMS、Launcher……等知识点记录。

《Framework 核心知识点汇总手册》:https://qr18.cn/AQpN4J

Handler 机制实现原理部分:
1.宏观理论分析与Message源码分析
2.MessageQueue的源码分析
3.Looper的源码分析
4.handler的源码分析
5.总结

Binder 原理:
1.学习Binder前必须要了解的知识点
2.ServiceManager中的Binder机制
3.系统服务的注册过程
4.ServiceManager的启动过程
5.系统服务的获取过程
6.Java Binder的初始化
7.Java Binder中系统服务的注册过程

Zygote :

  1. Android系统的启动过程及Zygote的启动过程
  2. 应用进程的启动过程

AMS源码分析 :

  1. Activity生命周期管理
  2. onActivityResult执行过程
  3. AMS中Activity栈管理详解

深入PMS源码:

1.PMS的启动过程和执行流程
2.APK的安装和卸载源码分析
3.PMS中intent-filter的匹配架构

WMS:
1.WMS的诞生
2.WMS的重要成员和Window的添加过程
3.Window的删除过程

《Android Framework学习手册》:https://qr18.cn/AQpN4J

  1. 开机Init 进程
  2. 开机启动 Zygote 进程
  3. 开机启动 SystemServer 进程
  4. Binder 驱动
  5. AMS 的启动过程
  6. PMS 的启动过程
  7. Launcher 的启动过程
  8. Android 四大组件
  9. Android 系统服务 - Input 事件的分发过程
  10. Android 底层渲染 - 屏幕刷新机制源码分析
  11. Android 源码分析实战

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/853026.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

模拟实现消息队列项目(完结) -- 基于MQ的生产者消费者模型

目录 前言 1. 生产者 2. 消费者 3. 启动消息队列服务器 4. 运行效果 结语 前言 在上一章节,我们完成了消息队列的客户端部分,至此我们整个消息队列项目就构建完成了,那我们做的这个消息队列到底有什么效果,以及如何去使用我们自己的消息队列呢?那么本文,就将我们的MQ进行实战操…

GSEA富集分析结果详解

1. GSEA富集分析原理图 2. GSEA富集分析过程 1. 计算富集分数&#xff08;ES&#xff09; 富集分数&#xff1a;S 反应基因集&#xff08;比如某个通路内的基因集&#xff09;成员 s 在排序基因集 L&#xff08;比如根据 logFC 排序的差异基因集&#xff0c;默认降序&#xf…

“为爱起航,一村一书院”在阳朔落地

2023年8月1-5 日&#xff0c;“关爱祖国下一代&#xff0c;助力乡村振兴” 之为爱起航项目在阳朔举行。 本次活动由千里思乡村振兴促进会联合中国文化交流大使组委会携同大湾区19位师生加入到首批“为爱起航&#xff0c;一村一书院”项目中&#xff0c;同时&#xff0c;本项目得…

分页查询从接口到实现,统一对日期类型进行格式化处理

编写Service实现类编写Mapper的sql&#xff0c;但复杂的sql语句需要写到mapper对应的xml文件中日期类型格式化处理 /*** 扩展springmvc框架的消息转换器* param converters*/Overrideprotected void extendMessageConverters(List<HttpMessageConverter<?>> conve…

初识Container

1. 什么是Container&#xff08;容器&#xff09; 要有Container首先要有Image&#xff0c;也就是说Container是通过image创建的。 Container是在原先的Image之上新加的一层&#xff0c;称作Container layer&#xff0c;这一层是可读可写的&#xff08;Image是只读的&#xff0…

天津农商银行智能加密锁管理工具常见问题

天津农商银行智能加密锁管理工具&#xff0c;在使用过程中&#xff0c;可能出现一些莫名的错误&#xff0c;针对亲身遇到的坑&#xff0c;分享给大家&#xff0c;以备不时之需。 一、转账业务导入文件中文汉字出现乱码&#xff0c;如下图。 原因是文件编码不正确&#xff0c;…

MySQL:表的约束和基本查询

表的约束 表的约束——为了让插入的数据符合预期。 表的约束很多&#xff0c;这里主要介绍如下几个&#xff1a; null/not null,default, comment, zerofill&#xff0c;primary key&#xff0c;auto_increment&#xff0c;unique key 。 空属性 两个值&#xff1a;null&am…

【设计模式——学习笔记】23种设计模式——备忘录模式Memento(原理讲解+应用场景介绍+案例介绍+Java代码实现)

案例引入 游戏角色有攻击力和防御力&#xff0c;在大战Boss前保存自身的状态(攻击力和防御力)&#xff0c;当大战Boss后攻击力和防御力下降&#xff0c;可以从备忘录对象恢复到大战前的状态 传统设计方案 针对每一种角色&#xff0c;设计一个类来存储该角色的状态 【分析】…

cpu util margin,cpu freq margin

【cpufreq governor】cpu util 和 cpu margin怎么计算的_悟空明镜的博客-CSDN博客 cpu util margin&#xff0c;cpu freq margin 根据policy_util schedtune_margin 作为算力选对应的cpu cluster或调频

EXCEL表格操作

1.带格式合并&#xff1a;D6&"欢迎光临"&E6 2.带格式复制粘贴&#xff1a;ctrlc 复制&#xff0c;选择对于单元格点击选择性粘贴&#xff1a;粘贴值和数字格式

docker-compose 安装kafka集群

点击关注《golang技术实验室》公众号****&#xff0c;将****获取更多干货 介绍 Kafka是一种高性能的分布式流处理平台&#xff0c;它的集群工作原理如下&#xff1a; 假设你是一个快递员&#xff0c;Kafka集群就是一个快递中转站。在这个中转站中&#xff0c;有很多个小窗口…

基于TF-IDF+TensorFlow+词云+LDA 新闻自动文摘推荐系统—深度学习算法应用(含ipynb源码)+训练数据集

目录 前言总体设计系统整体结构图系统流程图 运行环境Python 环境TensorFlow环境方法一方法二 模块实现1. 数据预处理1&#xff09;导入数据2&#xff09;数据清洗3&#xff09;统计词频 2. 词云构建3. 关键词提取4. 语音播报5. LDA主题模型6. 模型构建 系统测试工程源代码下载…

分布式 - 消息队列Kafka:Kafka生产者发送消息流程和3种方式

文章目录 1. Kafka 生产者2. kafaka 命令行操作3. Kafka 生产者发送消息流程4. Kafka 生产者发送消息的3种方式1. 发送即忘记2. 同步发送3. 异步发送 5. Kafka 消息对象 ProducerRecord 1. Kafka 生产者 Kafka 生产者是指使用 Apache Kafka 消息系统的应用程序&#xff0c;它们…

wsl(在windows中使用呢linux系统)适用于windows的linux子系统

步骤可参考微软官方文档https://learn.microsoft.com/zh-cn/windows/wsl/install-manual#step-4—download-the-linux-kernel-update-package 在这里主要列举一些需要注意的点 wsl2的要求 一定要检查下windows版本&#xff0c;版本不对的先升级版本不然无法使用wsl2 wsl支持…

P4381 [IOI2008] Island (求基环树直径)

也许更好的阅读体验 D e s c r i p t i o n \mathcal{Description} Description 给一个基环树森林&#xff0c;求每棵树的直径的和&#xff0c;基环树的直径定义为&#xff0c;从一个点出发只能走到没走过的点&#xff08;即一个环不能把所有边都选&#xff09;&#xff0c;所经…

史上最细,自动化测试-logging日志采集详细实战(二)

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 1、测试场景 给登…

固态硬盘数据恢复方法有哪些?三种恢复方法助您解忧

近年来固态硬盘比较流行&#xff0c;因为工作的需要我也在使用固态硬盘&#xff0c;它真的给我带来了很多的方便。但是最近&#xff0c;我固态硬盘里的文件有些不知道怎么就丢失了&#xff0c;这给我带来了很大的困扰。有什么方法可以找回来吗&#xff1f; 固态硬盘&#xff08…

Netty客户端同步获取结果

上次服务间通信是异步的&#xff0c;现在想实现客户端同步拿到服务端响应结果。实现如下&#xff1a; 在NettyClientHandler类中增加一个结果缓存器 Map<Long,Protocol<ResponseMsg>> resultMap new ConcurrentHashMap<>();修改方法 Override protected vo…

【文献阅读笔记】深度异常检测模型

文章目录 导读相关关键词及其英文描述记录深度异常检测模型Supervised deep anomaly detection 有监督深度异常检测Semi-Supervised deep anomaly detection 半监督深度异常检测Hybrid deep anomaly detection 混合深度异常检测One-class neural network for anomaly detection…

VR全景的盈利模式你知道吗?VR全景能用在哪些领域?

引言&#xff1a; 随着科技的迅猛发展&#xff0c;虚拟现实技术已经逐渐走进我们的生活。这项令人惊叹的技术让我们能够穿越时间与空间的限制&#xff0c;重新定义人们与世界互动的方式。 一&#xff0e;什么是VR全景&#xff1f; VR全景&#xff0c;是一种通过虚拟现实技术&…