- 博客(201)
- 资源 (14)
- 收藏
- 关注
RSS订阅原创 com.alibaba.nacos.api.exception.NacosException: Request nacos server failed
nacos 抛出异常com.alibaba.nacos.api.exception.NacosException: Request nacos server failed: 解决方案
2022-10-19 15:58:42
10336
2
原创 【无标题】安装linux虚拟机后，怎么关闭selinux,配置ip地址等
如何配置centos的ip地址，关闭selinux, 安装ifconfig命令等
2022-10-18 10:04:30
1307
转载 微服务拥抱k8s
微服务拥抱k8sk8s 和 Spring Cloud 的激烈冲突Spring Cloud 官方提供的解决方案服务发现 (Service Discovery)负载均衡和熔断器 (Load Balancing & Circuit Breaker)Spring Cloud V.S k8s 重叠方案k8s 和 Spring Cloud 的激烈冲突Java 生态的 Spring Cloud 可谓是迄今最完整的微服務框架，基本滿足所有微服务架构需求，网上的教程也不胜枚举。 但也因为 Spring Cloud
2022-01-18 10:39:32
1093
原创 java操作报错误信息：ORA-12505, TNS:listener does not currently know of SID given in connect descriptor
今天在通过代码连接oracel数库库时，一直报ORA-12505, TNS:listener does not currently know of SID given in connect descriptor的错误信息。。经过多方查找问题原因，原来oracle版本比较新，需要升级驱动包或者更改url样式。。如下报错信息： ORA-12505, TNS:listener does not currently know of SID given inconnect descriptor通常建议如下操
2021-04-03 11:20:16
2916
原创 mybatis 先插入主表数据，获得自增主键。然后作为从表的外键插入从表数据怎么做()
案例如题：具体描述如下。主表customer自增主键为cust_id。从表订单表外键为cust_id。数据库框架Mybatis需求:在插入顾客信息后产生cust_id,然后做为订单表的外键继续插入订单信息。Customer 类中有List orderList属性用于存放订单信息。insert into customer(cust_name,cust_address) values(#{custName},#{custAddress});insert into `order`(order_da
2021-03-31 21:51:51
1507
原创 shardingJdbc和Mycat对比，用于分库分表
前言1、什么是分库分表就是把原本存储于一个库的数据分块存储到多个库上，把原本存储于一个表的数据分块存储到多个表上。2、为什么分库分表数据库中的数据量不一定是可控的，在未进行分库分表的情况下，随着时间和业务的发展，库中的表会越来越多，表中的数据量也会越来越大，相应地，数据操作，增删改查的开销也会越来越大；另外，由于无法进行分布式式部署，而一台服务器的资源（CPU、磁盘、内存、IO等）是有限的，最终数据库所能承载的数据量、数据处理能力都将遭遇瓶颈。3、分库分表的实施策略分库分表有垂直切分
2021-03-12 15:23:03
8966
原创 java8为什么会出现Lambda表达式?
前言Java8有一些新的特性，今天老顾给大家分享一下关于Lambda表达式的由来，一开始感觉Lambda可读性蛮差的，不知道为什么Java8会出来这个表达式？既然大佬们推出来，肯定是有原因的，应该是为了解决一些问题，那我们就看看解决了什么问题？案例班导想了解一下各个同学的相关情况：1、来自苏州的有哪些同学上面的伪代码，是不是很简单，写一个方法，直接过滤出苏州地区的学生。班导又想知道来自北京的有哪些同学，那代码执行优化一下，可以动态传地区参数。2、地区参数化这样是不是就解决了，所有地区
2021-03-11 15:03:31
304
1
原创 多线程场景下使用ArrayList的注意点
前言ArrayList 不是线程安全的，这点很多人都知道，但是线程不安全的原因及表现，怎么在多线程情况下使用ArrayList，可能不是很清楚，这里总结一下线程不安全的两种体现查看 ArrayList 的 add 操作源码如下： /** * Appends the specified element to the end of this list. * * @param e element to be appended to this list * @ret
2021-03-10 17:26:48
635
原创 Logback+ELK+SpringMVC搭建日志收集服务器
今天看到一篇logback整合ELK的博文，感觉非常有用，文章中包含了ELK如何安装的步骤，很好用的，所以推荐过来了。。https://cloud.tencent.com/developer/article/1072844
2021-03-09 16:01:37
171
原创 通过Redis实现延迟队列
前言实现延迟队列的方式有很多种，有本地自己jdk方式实现、Quartz 定时任务实现、RabbitMQ 延时队列实现，还有Redis方式实现。综合自己的生产情况，Redis是符合分布式服务及开发成本较小的一种方式。基本的机制如下图本文将通过工具包Redisson用极简单的方式来实现一个延迟队列。同时提供一下比较完备的例子。延迟队列的使用场景背景：1、当订单一直处于未支付状态时，如何及时地关闭订单2、如何定期检查处于退款状态的订单是否已经退款成功3、在订单长时间没有收到下游系统的状态通知的时候
2021-03-09 11:36:19
1117
原创 搭建ELK日志分析系统
今天看到一篇博文，讲如何搭建ELK日志收集系统，非常好用，特意转载过来https://blog.csdn.net/bbwangj/article/details/80600698
2021-03-09 11:11:59
169
原创 微博千万级规模高性能高并发的网络架构设计
前言在开始谈我对架构本质的理解之前，先谈谈自己的个人见解，千万级规模的网站感觉数量级是非常大的，对这个数量级我们战略上要重视它 ，战术上又要藐视它。先举个例子感受一下千万级到底是什么数量级？现在的优步(Uber)，从媒体公布的信息看，它每天接单量平均在百万左右，假如每天有10个小时的服务时间，平均QPS只有30左右。对于一个后台服务器，单机的平均QPS可以到达800-1000，单独看写的业务量很简单 。为什么我们又不能说轻视它？第一，我们看它的数据存储，每天一百万的话，一年数据量的规模是多少？其次，
2021-03-07 20:11:55
305
原创 后起之秀HikariCP为何会受到多人的追捧
前言在实际开发中我们常所熟知的数据库连接池有C3P0，DBCP、阿里Druid,等。但随着Springboot 2.0选择HikariCP作为默认数据库连接池这一事件之后，HiKariCP作为一个后起之秀出现在大众的视野中，以其速度快，性能高等特点受到很多人青睐。下面是我收集到的一些关于HikariCP的资料，用于帮助各位了解认识HiKariCP什么是HikariCPHikariCP是由日本程序员开源的一个数据库连接池组件，是一个打着为“快速、简单、可靠”口号的后起之秀。HikariCP优势亮点在
2021-02-28 14:44:20
434
原创 如何保证API接口数据安全？
前言前后端分离的开发方式，我们以接口为标准来进行推动，定义好接口，各自开发自己的功能，最后进行联调整合。无论是开发原生的APP还是webapp还是PC端的软件,只要是前后端分离的模式，就避免不了调用后端提供的接口来进行业务交互。网页或者app，只要抓下包就可以清楚的知道这个请求获取到的数据，也可以伪造请求去获取或攻击服务器；也对爬虫工程师来说是一种福音，要抓你的数据简直轻而易举。那我们怎么去解决这些问题呢？接口签名我们先考虑一下接口数据被伪造，以及接口被重复调用的问题，要解决这个问题我们就要用到接口
2021-02-24 20:27:54
545
原创 Flink集群报错误：akka.pattern.AskTimeoutException: Ask timed out on
官方配置参考：https://flink.sojb.cn/ops/config.htmljob运行异常：Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Sender[null] sentflink-conf.yaml
2021-02-24 20:23:08
2423
原创 Java中遍历Map集合不同方式的效率比较
1、由来上次博客提到了Map的四种遍历方法，其中有的只是获取了key值或者是value值，但我们应该在什么时刻选择什么样的遍历方式呢，必须通过实践的比较才能看到效率。也看了很多文章，大家建议使用entrySet，认为entrySet对于大数据量的查找来说，速度更快，今天我们就通过下面采用不同方法遍历key+value，key，value不同情景下的差异。2、准备测试数据：HashMap1：大小为1000000，key和value的值均为String，key的值为1、2、3…1000000；Map&
2021-02-19 11:09:51
266
原创 基于Flink的金融流计算开发平台
为什么银行需要流计算开发平台，流计算开发平台的优势是什么？■ 优势流计算开发平台的优势在于可以有效降低实时数据开发准入门槛，助力实时业务快速发展。通过流计算开发平台，提供一个一站式的实时数据开发平台，包括可视化的数据开发，任务管理，实现多租户和多项目的管理，统一运维管理、权限管理，可以在这个平台上完成实时数据任务的开发。流计算开发平台是基于 Flink SQL 来做的，Flink SQL 本身是一种生产力。通过 Flink SQL 的不断应用，可以把流计算开发平台的能力下推至分支行，分支行可以通过平
2021-02-19 10:42:27
971
原创 字符串拼接还在用StringBuilder？快试试Java8中的StringJoiner吧，真香！
前言之前，我们经常会通过StringBuffer或者StingBuilder对字符串进行拼接，但是你知道Java8中推出的StringJoiner吗？它比前者更加优美、灵活，如果你现在还使用StringBuffer拼接，强烈推荐你试试StringJoiner。介绍在实用StringJoiner类之前，如果我们想要数据最终的字符串以逗号隔开，大概是这样的StringBuilder sb = new StringBuilder();IntStream.range(1,10).forEach(i->
2021-02-18 15:08:43
213
1
原创 SQL语句性能优化策略
1、对查询进行优化，应尽量避免全表扫描，首先应考虑在 WHERE 及 ORDER BY 涉及的列上建立索引。2、应尽量避免在 WHERE 子句中对字段进行 NULL 值判断，创建表时 NULL 是默认值，但大多数时候应该使用 NOT NULL，或者使用一个特殊的值，如 0，-1 作为默认值。3、应尽量避免在 WHERE 子句中使用 != 或 <> 操作符。MySQL 只有对以下操作符才使用索引：<，<=，=，>，>=，BETWEEN，IN，以及某些时候的 LIKE。
2021-02-18 11:38:04
109
原创 Spring 的 Controller 是单例还是多例？怎么保证并发的安全
前言controller默认是单例的，不要使用非静态的成员变量，否则会发生数据逻辑混乱。正因为单例所以不是线程安全的。案例下面来简单的验证下：package com.riemann.springbootdemo.controller;import org.springframework.context.annotation.Scope;import org.springframework.stereotype.Controller;import org.springframework.web
2021-02-18 11:11:05
397
原创 Redis通过Redisson实现延迟队列
前言实现延迟队列的方式有很多种，有本地自己jdk方式实现、Quartz 定时任务实现、RabbitMQ 延时队列实现，还有Redis方式实现。综合自己的生产情况，Redis是符合分布式服务及开发成本较小的一种方式。基本的机制如下图本文将通过工具包Redisson用极简单的方式来实现一个延迟队列。同时提供一下比较完备的例子。一、延迟队列的使用场景背景：1、当订单一直处于未支付状态时，如何及时地关闭订单2、如何定期检查处于退款状态的订单是否已经退款成功3、在订单长时间没有收到下游系统的状态通知的
2021-02-04 10:56:19
2767
2
原创 Java8 快速实现List转map 、分组、过滤等操作
## 前言利用java8新特性，可以用简洁高效的代码来实现一些数据处理。实例定义1个Apple对象：public class Apple { private Integer id; private String name; private BigDecimal money; private Integer num; public Apple(Integer id, String name, BigDecimal money, Integer num) {
2021-02-02 10:59:22
135
原创 没有了可用slot，Flink如何新增
如下图所示，一个普通Flink1.7的Local环境，正在运行一个并行度为4的任务，现有Task slot全部被使用，因此Available Task Slots为零：如果这时候再提交一个任务，会出现什么情况呢？如下图，新提交的任务，状态是SCHEDULED（红框所示），执行的主机也没有分配（绿框所示）：看来要想任务顺利执行，首先要保证slot数量够用，目前机器内存是够用的，那么就把slot数量调大些吧；注意由于修改的配置文件要重启Flink才能生效，在生产环境请慎用！修改配置根.
2020-12-29 20:43:14
2436
3
原创 怎么查看pgsql的最大连接数，关闭客户端连接数，当前最多连接数问题
显示客户端连接数SELECT * from pg_stat_activity删除空闲连接数SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHEREstate=‘idle’显示设置的最大连接数show MAX_CONNECTIONS
2020-12-29 17:51:13
1310
1
原创 选择rabbitMQ 还是kafka
前言作为处理许多基于微服务的系统的软件架构师，我经常遇到一个不断重复的问题：“我应该使用RabbitMQ还是Kafka？” 由于某些原因，许多开发人员认为这些技术是可互换的。 尽管在某些情况下确实如此，但这些平台之间存在各种潜在的差异。结果，不同的方案需要不同的解决方案，选择错误的方案可能会严重影响您设计，开发和维护软件解决方案的能力。本文的目的是首先介绍基本的异步消息传递模式。 然后，它将继续介绍RabbitMQ和Kafka及其内部结构。 第2部分将重点介绍这些平台之间的关键区别，它们的各种优缺点以
2020-12-28 17:52:59
330
原创 调试flink时遇到的问题
前言最近在利用flink分布式流式计算引擎开发完项目后，把代码打包到flinkstandlone集群上后，发现很多问题，特记录下来，与大家分享1、无法通过SpringApplication.run初始化容器，也就是不能使用spring注解注入对象，2、sourece和sink成员变量，如果设置为static的话，就不能通过外部的构造函数传人，必须去掉static...
2020-12-28 17:28:13
356
原创 用Arrays.asList()进行数组转换要注意的地方
前言最近使用Arrays.asList()遇到了一些坑，然后在网上看到这篇文章：Java Array to List Examples 感觉挺不错的，但是还不是特别全面。所以，自己对于这块小知识点进行了简单的总结。简说Arrays.asList()在平时开发中还是比较常见的，我们可以使用它将一个数组转换为一个List集合。String[] myArray = { "Apple", "Banana", "Orange" }； List<String> myList = Arrays.as
2020-12-19 16:15:23
753
1
原创 通过正则表达式取Json字符串的value值，不管中文，英文，大小写字符，还是数字，小数点通吃
我们经常编写软件是，json数据格式经常使用，如果快速取到value值呢，直接上代码： public static void main(String[] args) { String parse = "{\"sex\":\"男\"，\"age\":\"23.160\",\"brithday\":\"2010-10-23\"}"; String regex = "\"age\":\"(.*?)\\\"";//使用非贪婪模式！ //String regex="a
2020-12-12 15:39:30
1359
原创 通过客户端快速连接Redis和zookeeper集群的命令
连接redis 集群命令redis-cli -h 10.93.84.53 -p 7000 -c说明：-h 后面的ip为集群机器的任一IP，-p为端口， -c表示连接到集群连接zookeeper集群命令①：连接zookeeper：./zkCli.sh -server ip:port, 默认的端口可以省略②：使用–help查看帮助文档③：查看所有得节点： ls /④：创建节点：create /zkdemo helloworld (默认创建的是永久的节点，如果想要创建临时的节点，
2020-12-09 11:01:51
710
原创 阅读Mybatis源码，熟悉设计模式，太有用了
前言虽然我们都知道有26个设计模式，但是大多停留在概念层面，真实开发中很少遇到，Mybatis源码中使用了大量的设计模式，阅读源码并观察设计模式在其中的应用，能够更深入的理解设计模式Mybatis至少遇到了以下的设计模式的使用：Builder模式，例如SqlSessionFactoryBuilder、XMLConfigBuilder、XMLMapperBuilder、XMLStatementBuilder、CacheBuilder；工厂模式，例如SqlSessionFactory、ObjectFa
2020-12-05 11:33:26
161
原创 如何快速导出flink代码成Jar包
如图1、打开File->Projec Structure->Artifacts2、点击“+”号 -> jar->From modules with dependencies3. 如下图Main class 也可不指定删除所有Jar包，只保留输出的文件，如下图删除多月的Jar后，点击OKD:\workspace\flinkstream\out\artifacts\flinkstream_jar 为导出jar的存储位置和文件名，如下开始导出Jar1 、Buil
2020-12-01 20:39:58
1171
原创 微服务不可用，怎么排查错误
前言下面是线上机器的cpu使用率，可以看到从4月8日开始，随着时间cpu使用率在逐步增高，最终使用率达到100%导致线上服务不可用，后面重启了机器后恢复排查思路简单分析下可能出问题的地方，分为5个方向：系统本身代码问题内部下游系统的问题导致的雪崩效应上游系统调用量突增http请求第三方的问题机器本身的问题开始排查查看日志，没有发现集中的错误日志，初步排除代码逻辑处理错误。首先联系了内部下游系统观察了他们的监控，发现一起正常。可以排除下游系统故障
2020-11-28 09:22:33
1847
原创 解决External Libraries里，没有Maven的依赖包问题
前言这段时间，项目开发一直在外网进行的，由于调试，需要把项目拷贝进内网，由于内网不能连接Internet，于是把maven仓库拷贝进内网，配置maven如下然后各种报错：如下发现idea左侧External Libraries里，只有jdk，没有看到该视频里Maven的依赖包然后各种问题排查，结果发现每个jar目录都有_remote.repositories 文件，如下通过搜索_remote.repositories，批量删除后，问题解决了。。。总结现在开发环境一般都能连接外网，所以很
2020-11-25 17:32:14
10991
5
原创 为什么大多数IOC容器使用ApplicationContext，而不用BeanFactory
前言Spring框架附带了两个IOC容器– BeanFactory 和 ApplicationContext. BeanFactory是IOC容器的最基本版本，ApplicationContext扩展了BeanFactory的功能。那么本篇文章中，我们将通过实际例子了解这两个IOC容器之间的显著差异。延迟加载 vs. 预加载BeanFactory 按需加载bean，而 ApplicationContext 则在启动时加载所有bean。因此，BeanFactory与ApplicationContext相
2020-11-21 15:00:03
199
原创 基于zookeeper实现分布式锁
前言在介绍zookeeper(下文用zk代替)实现分布式锁的机制之前，先粗略介绍一下zk是什么东西：Zookeeper是一种提供配置管理、分布式协同以及命名的中心化服务。zk的模型是这样的：zk包含一系列的节点，叫做znode，就好像文件系统一样每个znode表示一个目录，然后znode有一些特性：有序节点：假如当前有一个父节点为/lock，我们可以在这个父节点下面创建子节点；zookeeper提供了一个可选的有序特性，例如我们可以创建子节点“/lock/node-”并且指明有序，那么zoo
2020-11-08 10:24:03
256
转载 当 TiDB 与 Flink 相结合：高效、易用的实时数仓
前言随着互联网飞速发展，企业业务种类会越来越多，业务数据量会越来越大，当发展到一定规模时，传统的数据存储结构逐渐无法满足企业需求，实时数据仓库就变成了一个必要的基础服务。以维表 Join 为例，数据在业务数据源中以范式表的形式存储，在分析时需要做大量的 Join 操作，降低性能。如果在数据清洗导入过程中就能流式的完成 Join，那么分析时就无需再次 Join，从而提升查询性能。利用实时数仓，企业可以实现实时 OLAP 分析、实时数据看板、实时业务监控、实时数据接口服务等用途。但想到实时数仓，很多人的第一
2020-11-01 08:42:16
1449
原创 如何通过springboot监听 Redis Key 失效事件实现特定任务
前言我们以订单功能为例说明下：生成订单后一段时间不支付订单会自动关闭。最简单的想法是设置定时任务轮询，但是每个订单的创建时间不一样，定时任务的规则无法设定，如果将定时任务执行的间隔设置的过短，太影响效率。还有一种想法，在用户进入订单界面的时候，判断时间执行相关操作。方式可能有很多，在这里介绍一种监听 Redis 键值对过期时间来实现订单自动关闭。实现思路在生成订单时，向 Redis 中增加一个 KV 键值对，K 为订单号，保证通过 K 能定位到数据库中的某个订单即可，V 可为任意值。假设，生成订
2020-10-29 15:28:23
297
flinkdemo.rar
2020-09-25
springboot 整合消息队列kafka(kafka-with-springboot.rar)
2020-08-19
基于RateLimiter的令牌桶算法实现限速控制和计算法实现限流控制
2020-08-01
建造者模式源代码---BuilderDemo.rar
2020-06-27
ForkJoinUtil.java，一个分而治之的框架工具类
2020-06-17
Springboot+SpringCloud微服务架构demo
2020-06-04
qt5-qtwebkit-5.212.20200324-1-omv4002.x86_64.rpm
2020-05-12
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人