- 博客(102)
- 收藏
- 关注
RSS订阅原创 一个日志应用的例子可以是将应用程序的日志数据存储到 InfluxDB
【代码】一个日志应用的例子可以是将应用程序的日志数据存储到 InfluxDB。
2023-05-17 18:15:32
305
原创 区块链技术详解
区块链 是一个共享的、不可篡改的账本，旨在促进业务网络中的交易记录和资产跟踪流程。资产可以是有形的（如房屋、汽车、现金、土地），也可以是无形的（如知识产权、专利、版权、品牌）。几乎任何有价值的东西都可以在区块链网络上跟踪和交易，从而降低各方面的风险和成本。业务运营依靠信息。信息接收速度越快，内容越准确，越有利于业务运营。区块链是用于传递这些信息的理想之选，因为它可提供即时、共享和完全透明的信息，这些信息存储在不可篡改的账本上，只能由获得许可的网络成员访问。区块链网络可跟踪订单、付款、帐户、生产等信息。
2023-04-20 19:29:56
1372
原创 kafka一些知识
当 Kafka 重启后，它会通过检查分区副本的状态和消费者位移等信息，自动恢复每个分区的状态和消息数据，并重新分配分区的副本。为了避免这种情况的发生，建议在关闭 Kafka 集群之前先确保所有的数据都已经被成功地写入到 Topic 中，并在重启之前备份 Kafka 的数据以便在需要时进行恢复。具体地，Kafka 会从磁盘上的消息日志（message log）中加载以前保存的消息数据，并在内存中重建 Topic 的分区副本和消费者位移（consumer offset）等元数据信息。
2023-04-18 15:31:59
388
原创 MyBatisPlus 查询json类型的数据增加条件
如果你使用MyBatisPlus来查询json类型的数据并且需要增加条件，你可以通过在查询条件中使用MyBatisPlus提供的Lambda表达式来实现。的json类型的列，你想查询。
2023-04-10 19:15:23
2067
原创 spingboot解析CSV文件
那么可以创建一个Person类来描述CSV文件中的每一行数据，并实现MappingStrategy接口来将CSV文件中的每一行数据映射到Person对象中。
2023-03-31 12:55:05
760
原创 用opencsv 生成csv后上传文件服务器
// Maven<dependency> <groupId>com.opencsv</groupId> <artifactId>opencsv</artifactId> <version>5.5.2</version></dependency>// Gradleimplementation 'com.opencsv:opencsv:5.5.2'// 创建一个 CSVWr
2023-03-29 14:51:15
392
原创 隐私计算具体用java 如何实现
的示例代码，实际的隐私计算系统可能需要更多的安全措施和算法，以确保数据隐私得到充分的保护。选择合适的库和框架：Java 语言提供了许多密码学库和框架，例如 BouncyCastle、JCE、Spring Security 等，可以根据实际需求选择合适的库和框架来实现隐私计算功能。保证安全性：隐私计算是一种保护数据隐私的计算方法，因此在实现时需要采取严格的安全措施，以保证数据的安全性和隐私性。Alice 和 Bob 分别将对方发送过来的加密值减去自己的随机数，得到对方的输入值的加密值。
2023-03-28 13:13:49
1105
原创 常见的linux安装
单机版3.1安装工具3.1.1 安装Maven工具3.1.1上传安装包1)root用户创建安装目录如/usr/local /maven：mkdir -p /usr/local/maven2)进入到 /usr/local/maven目录中cd /usr/local/maven3)将maven安装包apache-maven-XX.XX.XX.tar.gz以root用户上传到/usr/local/maven/目录3.1.2解压安装包tar -zxvf apache-mave
2022-05-15 13:38:00
125
原创 如何提升系统的稳定性
流控双11期间，对于一些重要的接口（比如帐号的查询接口，店铺首页）做流量控制，超过阈值直接返回失败。 另外对于一些不重要的业务也可以考虑采用降级方案，大促—>邮件系统。根据28原则，提前将大卖家约1W左右在缓存中预热，并设置起止时间，活动期间内这部分大卖家不发交易邮件提醒，以减轻SA邮件服务器的压力。容灾最大程度保证主链路的可用性，比如我负责交易的下单，而下单过程中有优惠的业务逻辑，此时需要考虑UMP系统挂掉，不会影响用户下单（后面可以通过修改价格弥补），采用的方式是，如果优惠挂掉，重新渲染页
2021-05-08 16:04:38
2208
原创 Kafka简介
我们先来看看Kafka的一些优秀特性。● 高性能：以时间复杂度为O（1）的方式提供消息持久化能力，即使对TB级以上的数据也能保证常数时间复杂度的访问性能，同时支持离线数据处理和实时数据处理。● 高吞吐率：即使在非常廉价的商用机器上也能做到单机支持每秒100千条以上消息的传输。● 支持消息分区及分布式消费。● Scale out：支持在线水平扩展。Kafka能拥有这样优异的特性，与它的优良设计与编码是分不开的。为了在做到高性能的消息持久化及海量消息时仍能保持常数时间复杂度的访问性能，Kaf
2021-03-20 11:57:54
134
原创 Akka简介
虽然Akka基于Scala而非Java语言编写而成，但由于Scala最终还是被编译为Java字节码并运行在JVM之上，所以我们可以认为Akka属于Java领域。Akka官方对Akka的介绍如下。● 是对并发、并行程序的简单的高级别的抽象。● 是异步、非阻塞、高性能的事件驱动编程模型。● 是非常轻量的事件驱动处理机制（1GB内存可容纳约270万个Actor）。我们知道，一个实际的Actor系统是由许多个Actor实例组成的一个复杂的树状结构，父Actor负责子Actor的生命周期并对它们实施必要的
2021-03-19 17:38:19
6737
原创 Actor模型
Actor模型于1970年年初被提出，为并行计算而生，理念非常简单：所有对象皆Actor，在Actor之间仅通过发送消息进行通信，所有操作都是异步的，不同的Actor可以同时处理各自的消息，使整个系统获得大规模的并发能力。但是，该理念在当时有些超前，因此很快被人遗忘。直到Erlang这种基于Actor模型设计的面向并发编程的新语言横空出世，在并发领域竖起一座丰碑，Actor模型才再次成为分布式计算领域的热点技术之一。目前，几乎在所有主流开发平台下都有了Actor模型的实现：Java平台下Scala的Ac
2021-03-19 17:03:14
314
原创 互联网中的分布式事务解决方案
第1种解决方案：业务接口整合，避免分布式事务此方案是将一个业务流程中需要在一个事务里执行的多个相关业务接口包装整合到一个事务中，这属于“就具体问题具体分析”的做法。就问题场景来说，可以将服务A、B、C整合为一个服务D来实现单一事务的业务流程服务。如果在项目一开始就考虑到分布式事务的复杂问题，则采用这里的方案，精心规划和设计系统，避免分布式事务；对于实在不能避免的，则采用其他措施去解决，这应该是最好的做法。第2种解决方案：最终一致性方案之eBay模式这是eBay于2008年公布的关于BASE准则的论文中提
2021-03-18 15:02:18
305
1
原创 经典的CAP理论
CAP理论在互联网界有着广泛的知名度，被称为“帽子理论”，它是由Eric Brewer教授在2000年举行的ACM研讨会上提出的一个著名猜想：一致性（Consistency）、可用性（Availability）、分区容错（Partition-tolerance）无法在分布式系统中被同时满足，并且最多只能满足其中两个！2003年，MIT的Gilbert和Lynch正式证明了这三者确实是不可兼得的。而后CAP被奉为分布式领域的重要理论，被很多人当作分布式系统设计的金律。Brewer教授当时想象的分布式场景是
2021-03-18 11:28:34
581
1
原创 MYSQL知识汇总
1、索引的本质索引的本质是一种排好序的数据结构。这个我相信其实大家并不陌生，因为谈到索引很多人自然而然的就会联想到字典中的目录。没错，这样的类比是很形象的，但是如果再往深处说，恐怕很多小伙伴就有点张口结舌了，那既然你已经知道了索引的本质，那么您就已经有了看这篇文章的基础，相信读文本文的你，一定会对索引的原理有一个全新的了解。2、索引的分类在数据库中，索引是分很多种类的（千万不要狭隘的认为索引只有 B+ 树，那是因为我们平时使用的基本都是 MySQL）。而不同的种类很显然是为了应付不同...
2021-03-17 17:33:37
54
原创 分布式事务知识汇总
作者：哪儿来的moon链接：https://zhuanlan.zhihu.com/p/353781389来源：知乎著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。什么是分布式事务分布式事务是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器「分别位于不同的分布式系统的不同节点之上」。一个大的操作由N多的小的操作共同完成。而这些小的操作又分布在不同的服务上。针对于这些操作，「要么全部成功执行，要么全部不执行」。为什么会有分布式事务？举个例子：转.
2021-03-17 17:23:08
142
原创 多线程知识汇总
1.使用线程创建线程四种方法new Thread()实现runnable接口实现callable接口线程池2基础线程机制四种线程池1、newFixedThreadPool 定长线程池一个有指定的线程数的线程池，有核心的线程，里面有固定的线程数量，响应的速度快。正规的并发线程，多用于服务器。固定的线程数由系统资源设置。核心线程是没有超时机制的，队列大小没有限制，除非线程池关闭了核心线程才会被回收。2、newCachedThreadPool 可缓冲线程池只有非核心线程，最大
2021-03-15 17:43:43
110
原创 Docker知识汇总
1.解决的问题由于不同的机器有不同的操作系统以及不同的库和组件，将在一个应用部署到多台机器上需要大量的环境配置操作。Docker主要解决环境配置问题，是一种虚拟化技术，对进程进行隔离，被隔离的进程独立于宿主操作系统及其它隔离的进程。使用docker可以不修改应用程序。2与虚拟机的比较启动速度：启动虚拟机，先启动操作系统，再启动应用，非常慢启动docker就是在宿主机上启动一个进程占用资源：虚拟机是一个完整的操作系统，需要大量的磁盘，cpu,内存，一台机器只能开几台虚拟机而
2021-03-12 16:09:11
171
2
原创 JVM知识汇总
1.JVM内存模型堆：创建对象的地方栈：方法执行和引用遍历的地方元数据区（本地方法区）：静态遍历，class类本地方法栈：native修饰的方法，c语言写的程序计数器：程序控制2.类加载机制加载-类加载过程的一个阶段，ClassLoader通过一个类的完全限定名查找此类字节码文件，并利用字节码文件创建一个class对象验证-目的在于确保class文件的字节流中包含信息符合当前虚拟机要求，不会危害虚拟机自身的安全，主要包括四种验证：文件格式的验证，元数据的验证，字节码验证，符号
2021-03-11 16:31:44
70
原创 如何在调用接口时进行优雅重试
在日常的编码过程中，无论是和本地服务相关的本机资源交互，还是和本地服务相关的 远程资源甚至是远程服务进行交付，都可能会遇到失败（异常），这时候，我们最常见 的做法就是重试。什么是正确的重试和任何的锲而不舍都需要向着现实低头一样，“重试”也需要有终止条件（即有条件的重试）， 想象一样买彩票的场景，如果屡次不中，一直尝试不停歇，那不是得破产吗？第一种，固定循环次数方式伪代码缺点：不带 backoff 的重试，对于下游来说会在失败发生时进一步遇到更多 的请求压力.
2021-01-28 17:40:06
281
原创 MYSQL的架构
一，先来一张架构图二.MYSQL架构的介绍1.服务层：涵盖所有MYSQL大多数核心服务功能，所有跨存储引擎的所有功能都在这层实现a.连接器：负责和客户端进行连接，维持管理连接b.查询缓存：之前执行过的语句会在key-value形式进行存储，MSYQL进行查询的时候会先在缓存中进行寻找，然后找到对应信息c.分析器：进行词法分析，解析出SQL,识别出语句；语法分析，然后解析出对应的语句进行执行d.优化器：生成执行计划，决策使用的索引，多表进行连接e.执行器：首先校验数据权限.
2021-01-27 14:08:34
88
4
原创 Linux 5 种 IO 模型
阻塞式 IO 模型 最传统的一种 IO 模型，即在读写数据过程中会发生阻塞现象。 当用户线程发出 IO 请求之后，内核会去查看数据是否就绪，如果没有就绪就会等待数 据就绪，而用户线程就会处于阻塞状态，用户线程交出 CPU。当数据就绪之后，内核会将 数据拷贝到用户线程，并返回结果给用户线程，用户线程才解除 block 状态。 典型的阻塞 IO 模型的例子为： data = socket.read(); 如果数据没有就绪，就会一直阻塞在 read 方法。非阻塞 IO 模型 当用户线程发起一个 read 操作
2020-11-06 10:46:59
79
原创 2020-10-30
经营自己并非指自私自利，不顾他人，而是要善待自己，活在当下，体谅他人，与人为善，做好与自己有关的事情。可惜很多人在忙忙碌碌中忽视了这一点。 美好的生活要靠自己精心经营。以下四点虽然不难做到，但恰恰很多人不屑一顾，没有坚持做下去，最后悔恨终生。 一、健康是最大的财富 健康是一切的根源。金钱是财富，年轻是资本，但没有健康，财富何用，没有健康，年轻不再是优势，失去健康便失去一切。我们将“1”代表健康，来看看健康是多么重要： 一个“1”字代健康，后面再写“0”一帮，依次代表是事业，财产汽车和
2020-10-30 15:08:29
828
1
原创 日志切面
package com.ziku.mall.aspect;import com.alibaba.fastjson.JSON;import com.google.common.base.Strings;import com.ziku.mall.entity.MallSysLogWithBLOBs;import com.ziku.mall.enums.ErrorCodeEnum;impo...
2020-10-20 17:30:48
49
原创 HttpUtils远程调用工具类
package com.ziku.care.web.util;import org.apache.commons.httpclient.HttpClient;import org.apache.commons.httpclient.HttpMethod;import org.apache.commons.httpclient.NameValuePair;import org.apac...
2020-10-20 17:30:13
136
原创 阿里大于发送短信工具类
import org.apache.commons.lang3.StringUtils;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.util.Assert;import com.alibaba.fastjson.JSONObject;import com.taob...
2020-10-20 17:29:52
86
原创 防止重复提交
import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;/*** @Description: 禁止重复提交自定义注解* @P...
2020-10-20 17:29:28
85
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人