上半年春招的时候，作为面试官，对于面试表现的不错的同学会要求其写一小段代码看看。题目很简单：
需求：需要利用同一logstash进程采集不同日志，输出到es的不同index，各输入输出隔离；
一、滚动窗口（Tumbling Windows） 滚动窗口有固定的大小，是一种对数据进行均匀切片的划分方式。窗口之间没有重叠，也不会有间隔，是“首尾相接”的状态。滚动窗口可以基于时间定义，也可以基于数据个数定义；需要的参数只有一个，就是窗口的大小（window size）。
前言 ????原题样例：提莫攻击 ????C#方法：一次遍历 ????Java 方法：一次遍历 ????总结 ????前言 ???? 算法题 ???? ???? 每天打卡一道算法题，既是一个
注意：cron表达式可分为6或7个占位符，但在spring自带的定时任务中，cron只支持6个参数，若使用7个参数就会报错
前天我们做了Java实现微信轰炸，一开始用的很趁手，但慢慢发现每次调试程序的太麻烦了，而且容易引发错误。所以这一次我们继续升级微信轰炸。
导读：虽然已经有很多分析工具 jvisualvm,jstat,jmap,jstack,Memory Analyzer等。但可能不是大杂烩,或者线上无法分析等。所以看看arthas的功能，好用就用它了
前段时间投实习，腾讯的暑期实习进了在线笔试。结果只做出了一道题（1/5），非常丢人。
3)在java程序里，目录中的间隔符可以是正斜线/。反斜线\表示转义字符，所以如果需要在Java【php也一样】程序里用到Windows平台上的反斜线\作为目录间隔符，必须是双反斜线\\。
将一个给定字符串 s 根据给定的行数 numRows ，以从上往下、从左到右进行 Z 字形排列。
给你两个整数 n 和 k ，请你构造一个答案列表 answer，该列表应当包含从 1 到 n 的 n 个不同正整数，并同时满足下述条件：
我们在编写Spring Boot应用中经常会遇到这样的场景，比如：我需要定时地发送一些短信、邮件之类的操作，也可能会定时地检查和监控一些标志、参数等。 创建定时任务 在Spring Boot中编写定时任务是非常简单的事，下面通过实例介绍如何在Spring Boot中创建定时任务，实现每过5秒输出一下当前时间。 在Spring Boot的主类中加入@EnableScheduling注解，启用定时任务的配置 @SpringBootApplication @EnableScheduling public clas
从getFirstDayOfWeek()开始，完整的7天，并且包含那一年至少getMinimalDaysInFirstWeek()天。 该计算方式和区域相关，对zh_CN区域，2020年第一周条件：从周日开始的完整7天，2020年包含1天即 可。显然，2019年12月27日周日到2020年1月2日周六是2020年第一周，得出的week year就是2021年。
学习ScheduledExecutorService类创建的newScheduledThreadPool相关用法
调度任务也是最近产品中需要用的，定时与后台进行数据同步，研究了几种方法后，觉得还是JobSchedule相对效果还好点，主要原因是WorkManager的定时任务最短也需要15分钟，虽然JobSchedule在Android7.0后也这样的，但是可以通过别的办法实现，所以两个都说一下，两个也都会用到。
用新浪微博API积累了微博广场的1.4万条数据，我选择了21个字段输出为TXT文件，想用Python稍微处理一下，统计一下这1.4万条微博里面表情使用情况，统计结构在最后。 无聊的时候用了下新浪JAVA版的API，对JAVA还不熟悉，但是稍微改一下还是没问题的，数据保存为TXT文件，再用Python处理，JAVA部分很简单，Python部分只涉及到表情的正则提取，都不好意思写出来了。 1、调用新浪JAVA API下载微博广场数据 步骤思路： 初始化API的Weibo类，设置Token后，设置下载间隔，然后重
问题导读 1.DStreams的含义是什么？ 2.DStreams提供哪两种类型的操作？ 3.Transformations操作分为哪两种类型？ 4.本文说了哪些输入源？ 5.什么是batch？ 本篇做了一些细节优化，防止初学者在看到的时候，造成误解.如有问题，欢迎交流 RDD与job之间的关系 Spark Streaming是构建在Spark上的实时流计算框架，扩展了Spark流式大数据处理能 力。Spark Streaming将数据流以时间片为单位分割形成RDD，使用RDD操作处理每一块数 据
编写一个程序，将 a.txt 文件中的单词与 b.txt 文件中的单词交替合并到 c.txt文件中，a.txt 文件中的单词用回车符分隔，b.txt 文件中用回车或空格进行分隔。
例如我们当前有一个需求为，我们需要对数据进行处理，但是数据处理时间为当前的时间减去 3 个月的这个时间间隔。
3、冯‘诺依曼体系：计算机硬件由运算器、控制器、存储器、输入设备和输出设备五大部分组成。
1，如果一端的Socket被关闭（或主动关闭，或因为异常退出而 引起的关闭），另一端仍发送数据，发送的第一个数据包引发该异常(Connect reset by peer)。
这些问题在日常开发中可能被很多人忽视（比如有的人遇到上面的问题只是重启服务器或者调大内存，而不会深究问题根源），但能够理解并解决这些问题是Java程序员进阶的必备要求。本文将对一些常用的JVM性能调优监控工具进行介绍，希望能起抛砖引玉之用。本文参考了网上很多资料，难以一一列举，在此对这些资料的作者表示感谢！关于JVM性能调优相关的资料，请参考文末。
1、如果一端的Socket被关闭（或主动关闭，或因为异常退出而引起的关闭），另一端仍发送数据，发送的第一个数据包引发该异常(Connect reset by peer)。
之前，我们经常会通过StringBuffer或者StingBuilder对字符串进行拼接，但是你知道Java8中推出的StringJoiner吗？它比前者更加优美、灵活，如果你现在还使用StringBuffer拼接，强烈推荐你试试StringJoiner。
给定一个单链表，把所有的奇数节点和偶数节点分别排在一起。请注意，这里的奇数节点和偶数节点指的是节点编号的奇偶性，而不是节点的值的奇偶性。
最近了不起在自己的服务器里基于Pandora搭建了ChatGPT页面，以后只需要accessToken或者key就可以使用，不再需要再去官网玩了，省下了不少时间。
最近我在自己的服务器里基于Pandora搭建了ChatGPT页面，以后只需要accessToken或者key就可以使用，不再需要再去官网玩了，省下了不少时间。
出于用户隐私信息保护的目的，系统上需将姓名、身份证、手机号等敏感信息进行加密存储，很自然选择了AES算法，外面又套了一层Base64，之前用的是sun.misc.BASE64Decoder/BASE64Encoder，网上的资料基本也都是这种写法，运行得很完美。但这种写法在idea或者maven编译时就会有一些黄色告警提示。到了Java 8后，Base64编码已经成为Java类库的标准，内置了 Base64 编码的编码器和解码器。于是乎，我手贱地修改了代码，改用了jdk8自带的Base64方法
数据流操作的另一个常见需求是对两条数据流中的事件进行联结（connect）或Join。Flink DataStream API中内置有两个可以根据时间条件对数据流进行Join的算子：基于间隔的Join和基于窗口的Join。本节我们会对它们进行介绍。
创建一个thread，然后让它在while循环里一直运行着，通过sleep方法来达到定时任务的效果，代码如下：
一般在各种业务场景中，为了保持系统稳定，我们都会有相应的重试机制，因为比如说，某个接口某个数据库链接由于网络抖动或者其他因素导致响应失败，这时候直接判定失败或者Mock数据未必是一种优雅的方式，因为这种情况下未必是接口挂掉了或者数据库连不上了，有可能是网络一时的抖动导致的，所以这时候一个优雅的重试机制或许能帮上我们。
在数学中，定积分是一个非常重要的概念，它表示函数在区间[a, b]上的积分值。在 Java 中，可以使用数学库 Math 中的方法来计算定积分或者其他数学表达式。本次需求是利用JAVA求定积分，也就是编译一个自动计算定积分的函数。
Given an input string, reverse the string word by word.
MediaCodec 有两种方式触发输出关键帧，一是由配置时设置的 KEY_FRAME_RATE 和KEY_I_FRAME_INTERVAL参数自动触发，二是运行过程中通过 setParameters 手动触发输出关键帧。
题外话：学编程越是学到后面，我就越发的感受到，刷题是提升编程技能最快的方式。学编程从入门到进阶，再到高阶，现在从16题开始就会有一些难度了，这里我会整理一些我刷过的一些题目。
Arthas的大名想必大家都听过，它是一款线上监控诊断产品，通过全局视角实时查看应用 load、内存、gc、线程的状态信息，并能在不修改应用代码的情况下，对业务问题进行诊断，包括查看方法调用的出入参、异常，监测方法执行耗时，类加载信息等。
foreachRDD函数属于将DStream中结果数据RDD输出的操作，类似transform函数，针对每批次RDD数据操作，但无返回值
Thread dumps（线程转储）能帮助我们判断 CPU 峰值、死锁、内存异常、应用反应迟钝、响应时间变长和其他系统问题。一些在线的分析工具比如 http://fastthread.io/ 也能帮助我们分析和定位问题，但是这些工具都要求有一个 dump 文件。因此在这篇文章当中，我总结了7中抓取 Java Thread Dumps 文件的方式。
Arthas 是基于 Greys 进行二次开发的全新在线诊断工具，利用Java6的Instrumentation特性，动态增强你所指定的类，获取你想要到的信息，采用命令行交互模式，同时提供丰富的 Tab 自动补全功能，让你在定位、分析诊断问题时看每一个操作都看起来是那么的 666。
在一个大型体育场内举办了一场大型活动，由于疫情防控的需要，要求每位观众的必须间隔至少一个空位才允许落座。现在给出一排观众座位分布图，座位中存在已落座的观众，请计算出，在不移动现有观众座位的情况下，最多还能坐下多少名观众。
在『任务调度线程池』功能加入之前，可以使用 java.util.Timer 来实现定时功能，Timer 的优点在于简单易用，但 由于所有任务都是由同一个线程来调度，因此所有任务都是串行执行的，同一时间只能有一个任务在执行，前一个 任务的延迟或异常都将会影响到之后的任务。
Java GC就是JVM记录仪，书画了JVM各个分区的表演。 什么是 Java GC Java GC（Garbage Collection，垃圾收集，垃圾回收）机制，是Java与C++/C的主要区别之一，作为Java开发者，一般不需要专门编写内存回收和垃圾清理代码，对内存泄露和溢出的问题，也不需要像C程序员那样战战兢兢。这是因为在Java虚拟机中，存在自动内存管理和垃圾清扫机制。概括地说，该机制对JVM（Java Virtual Machine）中的内存进行标记，并确定哪些内存需要回收，根据一定的回收策略，
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议
