首页
学习
活动
专区
工具
TVP
发布

java达人

专栏作者
284
文章
425733
阅读量
90
订阅数
Kafka Streams 核心讲解
•Kafka Stream 提供了一个非常简单而轻量的 Library,它可以非常方便地嵌入任意Java应用中,也可以任意方式打包和部署•除了 Kafka 外,无任何外部依赖•充分利用 Kafka 分区机制实现水平扩展和顺序性保证•通过可容错的 state store 实现高效的状态操作(如 windowed join 和aggregation)•支持正好一次处理语义•提供记录级的处理能力,从而实现毫秒级的低延迟•支持基于事件时间的窗口操作,并且可处理晚到的数据(late arrival of records)•同时提供底层的处理原语 Processor(类似于 Storm 的 spout 和 bolt),以及高层抽象的DSL(类似于 Spark 的 map/group/reduce)
java达人
2021-06-21
2.4K0
分布式系统模式3-Segmented Log
来源: https://martinfowler.com/articles/patterns-of-distributed-systems/
java达人
2020-12-03
3630
分布式系统模式2-Write-Ahead Log
来源: https://martinfowler.com/articles/patterns-of-distributed-systems/
java达人
2020-12-03
5390
与我一起学习微服务架构设计模式10—测试策略(下)
为了确保服务按预期工作,必须编写测试来验证服务是否可以正确地与基础设施服务和其他服务进行交互。一种方法是启动所有服务并通过其API进行测试,而这是所谓的端到端测试,缓慢、脆弱而且昂贵,它位于金字塔顶端,有其价值,但应该最大限度减少端到端测试的数量。
java达人
2019-12-19
1.1K0
与我一起学习微服务架构设计模式6—使用事件溯源开发业务逻辑
事件溯源是构建业务逻辑和持久化聚合的另一种选择,它将聚合以一系列的方式持久化保存,每个事件代表聚合的一次状态变化。应用通过重放事件来重新创建聚合的当前状态。
java达人
2019-11-18
1.1K0
与我一起学习微服务架构设计模式7—在微服务架构中实现查询
命令查询职责隔离。将持久化数据模型和使用数据的模块分为两部分:命令端和查询端。命令端模块和数据模型实现CUD操作,查询端模块和数据模型实现查询。查询端通过订阅命令端发布的事件,使其数据模型与命令端数据模型保持同步。
java达人
2019-11-18
7690
与我一起学习微服务架构设计模式4—使用Saga管理事务
微服务架构下的事务往往需要横跨多个服务,每个服务都有属于自己的私有数据库。传统的分布式事务管理并不是合适选择,需要使用Saga机制。
java达人
2019-10-30
1.1K0
与我一起学习微服务架构设计模式3—微服务架构中的进程间通信
选择合适的进程间通信机制是一个重要的架构决策,它会影响应用的可用性,甚至与事务管理相互影响。
java达人
2019-10-23
1.8K0
与我一起学习微服务架构设计模式1—逃离单体地狱
软件架构对功能性需求影响并不大,它影响非功能性需求,即质量属性或者其他能力,如交付速度的可维护性、可扩展性和可测试性。
java达人
2019-10-08
9010
一段简单代码在并发环境下的优化思路
有一段简单的代码,主要功能是根据好友的注册等活动来计算邀请者本人的贡献分,因此,每次有新的好友参与活动都会触发下面的方法:
java达人
2018-07-31
3150
关于mysql锁的两个例子
版本:mysql5.5.52 存储引擎:InnoDB 隔离级别:READ-COMMITTED 示例一: 事务1:左图 事务2:右图 1、 事务2中属于快照读,基于多版本的并发控制协议——
java达人
2018-02-01
1K0
sql server 获取每一个类别中值最大的一条数据
数据如下: name val memo a 2 a2(a的第二个值) a 1 a1--a的第一个值 a 3 a3:a的第三个值 b 1 b1--b的第一个值 b 3 b3:b的第三个值 b 2 b2b2b2b2 b 4 b4b4 b 5 b5b5b5b5b5 --创建表并插入数据: create table tb(name varchar(10),val int,memo varchar(20)) ins
java达人
2018-01-31
1.1K0
一次sql注入引发的多个mysql进程锁住的问题(针对myisam)
以前碰到过一个sql注入式攻击引发大量mysql进程被锁住的例子,现在分享给大家。当时数据表用的是myisam存储引擎。 基本知识点: InnoDB存储引擎既支持行级锁(row-level locking),也支持表级锁,而MyISAM支持的是表级锁。 对MyISAM表的读操作,不会阻塞其他用户对同一表的读请求,但会阻塞对同一表的写请求;对MyISAM表的写操作,则会阻塞其他用户对同一表的读和写操作;MyISAM表的读操作与写操作之间,以及写操作之间是串行的。 模拟示例: create table myis
java达人
2018-01-31
1K0
MySQL 加锁处理分析
背景 MySQL/InnoDB的加锁分析,一直是一个比较困难的话题。我在工作过程中,经常会有同事咨询这方面的问题。同时,微博上也经常会收到MySQL锁相关的私信,让我帮助解决一些死锁的问题。本文,准备就MySQL/InnoDB的加锁问题,展开较为深入的分析与讨论,主要是介绍一种思路,运用此思路,拿到任何一条SQL语句,都能完整的分析出这条语句会加什么锁?会有什么样的使用风险?甚至是分析线上的一个死锁场景,了解死锁产生的原因。 注:MySQL是一个支持插件式存储引擎的数据库系统。本文下面的所有介绍,都是基于I
java达人
2018-01-31
3.4K0
Redis与Memcached的区别
传统MySQL+ Memcached架构遇到的问题   实际MySQL是适合进行海量数据存储的,通过Memcached将热点数据加载到cache,加速访问,很多公司都曾经使用过这样的架构,但随着业务数据量的不断增加,和访问量的持续增长,我们遇到了很多问题:   1.MySQL需要不断进行拆库拆表,Memcached也需不断跟着扩容,扩容和维护工作占据大量开发时间。   2.Memcached与MySQL数据库数据一致性问题。   3.Memcached数据命中率低或down机,大量访问直接穿透到DB,MyS
java达人
2018-01-31
9360
switch.....case....使用最容易犯错的地方
请诸位看这段代码,如果runtimeDatabase 为MYSQL或H2,标注1的那行代码是否会执行。 final RuntimeDatabase runtimeDatabase = Latkes.getRuntimeDatabase(); switch (runtimeDatabase) { case MYSQL: case H2: case MSSQL: 1、 repositoryClass = (Class<Repository>) Class.forName("org.b3log.latke.rep
java达人
2018-01-31
7790
Oracle执行计划详解
简介: 本文全面详细介绍oracle执行计划的相关的概念,访问数据的存取方法,表之间的连接等内容。 并有总结和概述,便于理解与记忆! +++ 目录 --- 一.相关的概念 Rowid的概念 Recursive Sql概念 Predicate(谓词) DRiving Table(驱动表) Probed Table(被探查表) 组合索引(concatenated index) 可选择性(selectivity) 二.oracle访问数据的存取方法
java达人
2018-01-31
1.5K0
Oracle执行计划详解
简介: 本文全面详细介绍oracle执行计划的相关的概念,访问数据的存取方法,表之间的连接等内容。 并有总结和概述,便于理解与记忆! +++ 目录 --- 一.相关的概念 Rowid的概念 Recursive Sql概念 Predicate(谓词) DRiving Table(驱动表) Probed Table(被探查表) 组合索引(concatenated index) 可选择性(selectivity) 二.oracle访问数据的存取方法
java达人
2018-01-31
3.1K0
PostgreSQL中的Schema
一个数据库包含一个或多个命名的模式,模式又包含表。模式还包含其它命名的对象,包括数据类型、函数,以及操作符。同一个对象名可以在不同的模式里使用而不会导致冲突; 比如,schema1和myschema都可以包含叫做mytable的表。和数据库不同,模式不是严格分离的:一个用户可以访问他所连接的数据库中的任意模式中的对象,只要他有权限。 我们需要模式有以下几个主要原因: 1). 允许多个用户使用一个数据库而不会干扰其它用户。 2). 把数据库对象组织成逻辑组,让它们更便于管理。
java达人
2018-01-31
1.8K0
mysql explain详解
对于经常使用mysql的兄弟们,对explain一定不会陌生。当你在一条SELECT语句前放上关键词EXPLAIN,MySQL解释它将如何处理SELECT,提供有关表如何联合和以什么次序的信息。 借助于EXPLAIN,你可以知道 1)你什么时候必须为表加入索引以得到一个使用索引找到记录的更快的SELECT。 2)你也能知道优化器是否以一个最佳次序联结表。为了强制优化器对一个SELECT语句使用一个特定联结次序,增加一个STRAIGHT_JOIN子句。 官方的关于explain的文档在http://dev.m
java达人
2018-01-31
7550
点击加载更多
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档