Kafka对主题的管理通过Kafka-topics.sh来执行，内容如下： exec $(dirname $0)/kafka-run-class.sh kafka.admin.TopicCommand "$@" 内部调用了kafka.admin.TopicCommand类 1.创建主题 如果配置了参 ...
分类：
其他好文 时间：
2020-07-29 10:13:06
阅读次数：
65
public class DeleteStr { static StringBuffer end; // static String startStr = "<123>1<456>8<9</456></123>"; // static String startStr = "<2abc>7<df</2 ...
分类：
其他好文 时间：
2020-07-29 09:56:21
阅读次数：
67
简介 String对象有个特殊的StringTable字符串常量池，为了减少Heap中生成的字符串的数量，推荐尽量直接使用String Table中的字符串常量池中的元素。 那么String.intern的性能怎么样呢？我们一起来看一下。 String.intern和G1字符串去重的区别 之前我们提 ...
分类：
其他好文 时间：
2020-07-28 10:15:18
阅读次数：
77
大顶堆和小顶堆 相关介绍可参看：北京大学空地学院数据结构与算法 第六章 6.8.2.2 小节 代码实现如下 class Heap: """二叉堆的实现 小顶堆""" def __init__(self): self.heapList = [0] # 默认一个 0 做占位，使得根节点的索引在 1 上 ...
分类：
编程语言 时间：
2020-07-27 23:32:44
阅读次数：
75
apple 官方文档 https://developer.apple.com/library/archive/documentation/Cocoa/Conceptual/Multithreading/RunLoopManagement/RunLoopManagement.html#//apple_ ...
分类：
移动开发 时间：
2020-07-27 09:52:52
阅读次数：
89
网络设备接收数据的主要方法是由中断引发设备的中断处理函数，中断处理函数判断中断类型，如果为接收中断，则读取接收到的数据，分配 sk_buffer 数据结构和数据缓冲区，将接收到的数据复制到数据缓冲区，并调用 netif_rx() 函数将 sk_buffer 传递给上层协议。下面是完成这个过程的函数模 ...
分类：
系统相关 时间：
2020-07-27 09:34:12
阅读次数：
87
1）案例需求 使用 Flume 采集服务器本地日志，需要按照日志类型的不同，将不同种类的日志发往不同的分析系统。 2）需求分析 在实际的开发中，一台服务器产生的日志类型可能有很多种，不同类型的日志可能需要发送到不同的分析系统。此时会用到 Flume 拓扑结构中的 Multiplexing 结构，Mu ...
分类：
Web程序 时间：
2020-07-26 23:24:13
阅读次数：
106
从jdk1.4开始，java中引入了nio包，提供了非阻塞式的网络编程模型，提供网络性能。nio中核心组件有三个：channel、buffer、selector。这里主要探讨buffer的概念和使用。buffer本质上是数据容器，可以存储java中的各种原始数据类型，并提供了读、写等各种操作。 1. ...
分类：
编程语言 时间：
2020-07-26 15:39:15
阅读次数：
64
// item 为 chooseImage 返回的图片 path let buffer = wx.getFileSystemManager().readFileSync(item) wx.cloud.callFunction({ name:'printedTextOCR', data: { buff ...
分类：
微信 时间：
2020-07-26 00:56:32
阅读次数：
103
二、重点非阻塞模型：NIO模型1. Channel：和流等级一样，双向的，可读可写 2. Buffer：存数据的地方，可以用来读写 3. Selector：NIO的核心类，可以监听多个channel的时间（连接打开，数据到达）-->使得单线程可以管理多个channel，只有在读写事件发生时才找线程过 ...
分类：
编程语言 时间：
2020-07-26 00:44:25
阅读次数：
69
