10 大树168

尚未进行身份认证

现在才明白,要赚到足够令自己安心的钱,才能过上简单、安逸、自由的生活,才能让自己活得更有底气。所以,多花时间努力,少点功夫矫情 github地址 https://github.com/lmchuyang/huyang

等级
TA的排名 3w+

mybatis批量插入和批量修改删除

第一, 是组装自己的的LIST 传入参数,再循环得到对象先贴 xml代码 update 的时候, mysql数据库, 一定要加上双线单引号,否则会报错,找不到数据库属性<!-- 增加SNMP --><insert id="insertAllSnmp" parameterType="java.util.List"> insert into tb_d...

2019-12-13 16:18:23

List使用Stream 分组求和groupingBy, collect、reduce方法流数据处理

jdk8 流式数据处理太灵活,一下了还不太好掌握 ,下面记录一些操作,方便使用的时候参考 public void testCodeSum() { Foo foo1 = new Foo(1, 2, 5); Foo foo2 = new Foo(2, 23, 6); Foo foo3 = new Foo(2, 6, 7); ...

2019-12-06 22:13:00

kafka不同组消费同一主题topic

因数涉及到数据的原子性,必须多个分组消费同一消费主题,写入数据库后, 可以自行回回滚数据,重新消费,不影响其它数据消费的目的,实现分批次拉取数据等,也是走了很多坑第一, 是环境兼容性问题,高版本可能更容易实现多分组消费同一主题topic依赖环境 springboot15.0+spring-kafka-1.1.1.RELEASE<parent> <group...

2019-12-06 11:30:46

kafka定时任务拉取数据

1 定时任务两种, 2 消费分组消费从哪里开始,不消费历史数据第一种监听的方式定时springboot1.5.6 + kafka2.1.7 依赖包 包冲突后, 又改回springboot-kafka1.1.1 定时任务不理想,恢复和暂停有问题 <dependency> <groupId>org.springfram...

2019-12-04 20:42:56

docker下读取txt文件找不到路径,必须copy到容器或者映射文件

今天遇到问题, 项目上传了一个GEO文件,但是在容器里运行的时候,找不到路径,因为容器里没有项目文件路径,只有一个JAR包, 这样的话,就要在容器里创建一个工作目录,然后打包容器的时候,把文件copy或者 add进容器里,代码如下1 第一步,docker 文件createDockerFile.sh 在服务端直接用命令 。 shcreateDockerFile.sh ,拉代码和打...

2019-11-28 13:13:31

kafka批量消费手动提交ACK

一次性拉取多条数据,消费后再手动提交ACK,因为要保存到数据库去, 这过程如果失败的话, 需要重新消费这些数据所以 配置的时候,KAFKA不能自动提交 ,批量消费数据设置ENABLE_AUTO_COMMIT_CONFIG=false,禁止自动提交 设置AckMode=MANUAL_IMMEDIATE 监听方法加入Acknowledgment ack 参数package c...

2019-11-27 21:08:52

kafka-stream流式处理示例

一 首生是kafka -stream 版本号问题,然后是springboot1.5.6兼容问题,发现springboot2.0不支持kafka -stream1.0.2包第一个是窗口聚合的初始值,第二个是进行聚合的聚合器,第三个就是窗口时间,第四个是类似于序列化的东西KTable aggregate = groupedStream.aggregate(initializer, ag...

2019-11-15 15:28:03

Logback异步日志输出的使用

<?xml version="1.0" encoding="UTF-8"?><configuration scan="true" scanPeriod="60 seconds" debug="false"> <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径 --> <property name="LOG_HOME" ...

2019-11-11 12:45:22

两种轮询平均分配的算法

1 第二种简单轮询算法1 定义一个变量保存索引值,然后每赋值一次, 就加1 用索引取值, 这样的话必须 是list才能取到里面的第几个 int f = 0; for (int j = 0; j < ziNode.size(); j++) { if (f >= maps.size()) { ...

2019-11-03 12:10:51

JAVA + GeoLite2+ip定位,查询国家地理位置信息

最新要用到地理位置做区域划分,需要知道哪个ip属于哪个区,五大洲的区域划分,有两千个IP需要知道,并且查询频率比较高,每十分钟去查询一次, 最开始是用的第三方API去调用,比如淘宝,百度等,但是就怕请求太频繁了,哪天给我黑名单了, 那我线上程序就挂了,还有一个,在国内用的话,是比较方便的,IP纯真数据库,但是我的IP大部分都是国外,定位在国内是没有什么问题,国外就...

2019-10-31 13:30:16

list内部元素排序

自定义排序,降序排: Collections.sort(list, new Comparator<Record>() { @Override public int compare(Record o1, Record o2) { return o2.getInt("id").compareTo(...

2019-10-25 15:10:01

软著源代码快速提取java代码读写-mac

import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.File;import java.io.FileReader;import java.io.FileWriter;import java.io.Writer;//软著源代码快速提取——java代码读写public class Re...

2019-10-22 18:51:43

SourceTree 3.1.3安装过程,不需要注册

一、sourcetree的免注册安装过程首先,下载windows版本的sourceTree。直接进入官网https://www.sourcetreeapp.com/下载1.首先下载并安装好git程序。2.接着下载并执行SourceTreeSetup-3.1.3.exe,会进入登录或注册bitbucket的界面,我只是想用软件,并不想去注册账号。怎么办?请往下看。3.打...

2019-09-13 23:26:04

springboot+异步线程池使用

今天在调试流量采集信息的时候,发现异步线程池不管用,无论怎么修改都无法启自定义的线程池,后来发现,springboot注解的方法,必须还是需要注入对象的方式调用,标准方式如下@AutowiredSNMPItemsnmpitem;第一步,配置线程池@Configuration@EnableAsyncclassTaskPoolConfig{...

2019-06-26 22:16:41

MAC安装MYSQL

安装 Homebrew安装工具官网https://brew.sh/index_zh-cn输入下面命令去终端,然后按任意键继续/usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"开始用命令安装MYSQL 示例如下安装mysql...

2019-06-19 18:23:38

springboot启动后执行某个方法的三种实现方式,且不影响提供服务

第一种方式,应该也是最简单的方式直接在方式上面注入,但是会影响服务提供,比如这个方法要执行五分钟这五分钟之内是无法提供服务的,这个方法是在服务初始化后之前运行,所以此方法运行不结束,服务就无法初始化,在这过程路也无法提供服务@PostConstructpublicvoidpingStart(){System.out.println("...

2019-06-18 17:57:04

springboot+redis+kafka集群配置 分布式

redis 配置 需要注意的地方是多服务器的时候,格式不一样@Configuration@ConditionalOnClass({JedisCluster.class})public class RedisConfig { @Value("${spring.redis.cluster.nodes}") private String clusterNod...

2019-06-13 11:21:42

kafka生产环境集群搭建

三台服务器准备工作 安装java环境 搭建zookeeper集群 搭建kafka集群服务器配置主机名 IP地址 硬件配置 kafka-1 192.168.1.162 24CPU、46G内存、600G存储 kafka-2 192.168.1.166 24CPU、64G内存、600G存储 kafka-3 192.168....

2019-05-29 09:58:09

git简单操作

1 先在界面 创建项目名个人设置里添加公钥等进入工程目录 cd $project_root(你的项目路径)初始化git仓库 git init添加文件到仓库 git add .提交代码到仓库 git commit -m 'init commit'链接到 git remote add o...

2019-05-16 17:32:04

VMware下的Linux扩展磁盘空间(CentOS7)

主要的命令集放在一起,#fdisk-l#fdisk/dev/sda1后面是具体的操作步骤[root@itcast01/]#fdisk-l磁盘/dev/sda:53.7GB,53687091200字节,104857600个扇区Units=扇区of1*512=512bytes扇区大小(逻辑/物理):512字节/512字节...

2019-05-11 14:14:39

查看更多

勋章 我的勋章
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 勤写标兵Lv1
    勤写标兵Lv1
    授予每个自然周发布1篇到3篇原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。