一、kafka的基础架构 1)Producer :消息生产者,就是向kafka broker发消息的客户端; 2)Consumer :消息消费者,向kafka broker取消息的客户端; 3)Consumer Group (CG):消费者组,由多个consumer组成。消费者组内每个消费者负责消费 ...
分类:
其他好文 时间:
2020-06-02 11:14:14
阅读次数:
69
CAS和AtomicInteger AtomicInteger用来保证自增原子性,它的实现是基于CAS(比较和交换)的。 CAS(CompareAndSwap):判断内存某个位置的值是否与预期值一致,如果是则更改为新值,这个过程是原子的。不会造成数据不一致的问题。 compareAndSet(exc ...
分类:
其他好文 时间:
2020-05-31 16:17:58
阅读次数:
81
总复习: 语句写法: insert into 语句:新增数据 语法:insert into 表名 values(值1,值2……)这里的写的值是要与表中的列一一对应的,自增的列可以不写。 新增指定数据的列: insert into 表名(列1,列2,列3……) values(值1,值2,值3……) 新 ...
分类:
数据库 时间:
2020-05-30 19:41:10
阅读次数:
87
ORM 字段 AutoField(Field) - int自增列,必须填入参数 primary_key=True BigAutoField(AutoField) - bigint自增列,必须填入参数 primary_key=True # 注:当model中如果没有自增列,则自动会创建一个列名为id的 ...
分类:
其他好文 时间:
2020-05-30 10:25:14
阅读次数:
55
说道集合,不得不说一下容器,数组也是集合的一种,那集合和容器的区别是什么呢? 个人认为,数组就是固定死的,而集合则是可以自增。 话不多说,直接上代码 首先是我们的接口层 package com.util.collection; public interface ListCollection { // ...
分类:
其他好文 时间:
2020-05-28 21:16:44
阅读次数:
68
踩了mysql主键自增的坑,一开始因为是自己的mybatisplus的配置错误,发现插入的id都特别大,而且前端展现的和我发现的id不一样,这个应该是框架的问题, 但是插入特别大的问题,其实是mysql的 查看Id类型 去mysql查找主键起始值 发现是这个问题,然后设置小点的,但是看视频发现没有问 ...
分类:
其他好文 时间:
2020-05-28 09:14:47
阅读次数:
108
题意 两种操作,第一种可以向序列里加数,第二种查询长度为k时的序列的第i大元素。 思路 优先队列维护最大堆和最小堆分别存放前i-1大的元素前k-i小的元素。 将当前序列的元素压入最小堆,如果最小堆的最小数大于最大堆的最大数则进行交换,保证最大堆中的所有数小于最小堆。 因为i值每进行一次自增1,所以每 ...
分类:
其他好文 时间:
2020-05-28 09:14:27
阅读次数:
86
insert insert [into] t [(col_name,...)] values(v1,v2...) 如果省略了列名,那么values里必须有所有列的值,自增列的值为null 如果指定了部分列名,其他的列必须允许为null或指定了默认值 连续插入 insert into table(na ...
分类:
数据库 时间:
2020-05-27 20:45:00
阅读次数:
85
算法目标:支持中小型支付系统,单机房生成订单号QPS<=1w,保证订单号绝对唯一,机房内趋势递增; 序列号生成算法(字符串订单号): {2字节,机房唯一序列号}{14字节,年月日时分秒}{3字节,毫秒}{3字节,微秒}{4字节,自增序列号} 举例: 机房A: "{01}{20171028195147 ...
分类:
编程语言 时间:
2020-05-25 19:19:50
阅读次数:
125
-- 创建自增序列 CREATE SEQUENCE seq_interface_info INCREMENT BY 1 START WITH 1 --从1开始 NOMAXVALUE --不设最大值 NOCYCLE --不循环 NOCACHE; -- 创建表interface_info的触发器 CRE ...
分类:
数据库 时间:
2020-05-25 15:54:26
阅读次数:
71