声明一个CPU密集型线程池，保证所有任务都能被执行完
怎么声明一个线程池，使它能够执行大量CPU密集型操作，又不会无限创建新线程，又能保证所有的任务都能被执行完成呢？ 先看下jdk中，声明线程池的API： ` public ThreadPoolExecutor(int corePoolSize,
java · 第 2 页
ElasticSearch的基本配置
本文简单介绍下ElasticSearch的常用基本配置。 从官网下载的es，我这里的版本是7.15.2，目录如下： [ ]() bin目录中是执行脚本，config是配置文件目录，data是es的数据存储目录，jdk是es自带的jdk目录。 ElasticSearch启动时默认使用环境变量ES_JA
kafka的数据文件解析（二）
首先很有必要的介绍下kafka的几个必要概念。 Broker Broker代表一个kafka服务，这其实是相对于集群环境来说的。在集群中，可以启动多个kafka，每个kafka都是一个broker。而每个kafka都有自己的唯一标识，这在server.properties配置文件中是可以看到的： `
kafka的数据文件解析（一）
学会看kakfa内部存储目录及文件，是学习kafka的很关键的一步。知道数据是怎么存储的，一些关键的kafka机制也就有了大概的推测。 数据目录下有哪些文件 我在kafka的配置文件上设置了数据存储目录：log.dirs=./kafka-data。 那么进入这个目录，看下里面都有哪些文件。 初始情况
代码实现最简单的kafka生产者和消费者
1、开启zookeeper和kafka服务，并创建topic：topic-1。 2、建立一个maven项目。 3、引入maven依赖： ` <dependency<groupId>org.apache.kafka</groupId<artifactId>kafka-clients</
kafka基本配置
kafka的软件包目录如下： 配置文件在config目录下，其中server.properties是kafka的配置文件，zookeeper.properties是zookeeper的配置文件。 ` #######zookeeper.properties ####################zo
一个独立部署的websocket服务
将websocket作为一个独立的服务部署起来，并且提供调用发送消息的api组件，由开发项目直接引入这个组件，就能便捷调用websocket的api，实现发送消息的功能。并且在微服务架构中，多个服务都可以调用这个websocket服务。 源码的地址： [https://gitee.com/freeb
kafka和zookeeper快捷启动
本文介绍下我自己稍微整合过的kafka和zookeeper软件，在windows下，可以一键式便捷启动kafka、zookeeper、生产者与消费服务，方便学习研究使用。 软件下载地址： ` 链接：https://pan.baidu.com/s/15YfcMsVGW2U8m44c11ZJfg 提取
kafka基本指令
1、启动zookeeper ，进入zookeeper的安装目录bin文件夹 ，直接双击运行zkServer.cmd（win系统）。 ` （Linux系统） bin/zookeeper-server-start.sh config/zookeeper.properties ` 2、进入kafka安装
@Transactional与synchronized同时使用的问题
在一段同步方法中同时使用@Transactional注解的时候，比如： ` @Transactional public synchronized void test() { System.out.println("数据库操作1"); System.ou
docker打包项目镜像，并批处理上传
需要在开发的项目根目录下，放一个Dockerfile文件，内容如下： ` FROM adoptopenjdk:8u275-b01-jdk-openj9-0.23.0-focal COPY ./ssmp-starter.jar ./app.jar RUN ln -snf /usr/share/zone
Springboot整合mybatis
项目结构 Dao层UserMapper ` //@Repository @Mapper public interface UserMapper { // @Select("SELECT FROM user") List<UserfindAll(); User getUser