分类后端技术下的文章

2024-08-27

在Redis中，INCR和DECR命令是用于对存储的数字值进行自增和自减的操作。如果你在多线程环境下使用这些命令，你可能会遇到竞争条件，因为这些命令不是原子的。

解决方案：

使用Lua脚本：你可以通过Redis的EVAL命令来运行Lua脚本，Lua脚本是原子的，可以确保自增和自减操作的安全性。

示例代码：




local key = KEYS[1]
local incr = tonumber(ARGV[1])
redis.call('INCRBY', key, incr)

在你的应用程序中，你可以使用EVAL命令来运行这个脚本。

使用事务：你可以使用MULTI和EXEC命令来创建事务，这样可以保证一系列命令的原子性。

示例代码：




def incr_decr(redis_conn, key, incr_value):
    with redis_conn.pipeline() as pipe:
        while True:
            try:
                pipe.watch(key)
                current_value = pipe.get(key)
                if current_value is None:
                    current_value = 0
                new_value = current_value + incr_value
                pipe.multi()
                pipe.set(key, new_value)
                pipe.execute()
                return new_value
            except redis.exceptions.WatchError:
                continue

在这个例子中，我们使用了Python的redis客户端。这个函数尝试在事务中自增一个键的值，如果键不存在，就将其初始化为0，然后自增。如果在监视期间键的值发生了变化，事务会重试。

使用Redlock或Redisson：这两个库都为Redis分布式锁提供了高级抽象，它们都支持自增操作。

示例代码：




// 使用Redisson
RedissonClient redisson = // ... 初始化RedissonClient
RAtomicLong atomicLong = redisson.getAtomicLong("myAtomicLong");
atomicLong.incrementAndGet();

在这个例子中，我们使用了Redisson的原子长整型对象来进行自增操作。Redisson会处理所有的并发问题，确保操作的原子性。

- 阅读更多 -

从回调地狱到Promise乐园：JavaScript异步编程的进化

System

2024-08-27

所有,java




// 回调地狱示例
asyncOperation(function(data){
    // 使用data处理逻辑...
    anotherAsyncOperation(function(moreData){
        // 使用moreData处理逻辑...
        yetAnotherAsyncOperation(function(error){
            if (error) {
                // 错误处理逻辑...
            }
        });
    });
});
 
// Promise示例
asyncOperation()
    .then(function(data){
        // 使用data处理逻辑...
        return anotherAsyncOperation();
    })
    .then(function(moreData){
        // 使用moreData处理逻辑...
        return yetAnotherAsyncOperation();
    })
    .catch(function(error){
        // 错误处理逻辑...
    });

在这个例子中，我们比较了两种处理异步操作的方法。回调地狱通常导致代码难以阅读和维护，而Promise通过链式调用提供了更清晰和线性的代码结构。使用Promise还可以利用.catch()方法集中处理错误，这比回调中的多层嵌套要更简洁和可维护。

- 阅读更多 -

Python3 urllibrequest — 访问网络资源

System

2024-08-27

所有,python

在Python 3中，urllib.request模块被用来打开和读取URLs，它是Python标准库的一部分。以下是一个使用urllib.request模块来获取网络资源的简单例子：




import urllib.request
 
# 打开一个网络资源
response = urllib.request.urlopen('http://www.example.com/')
 
# 读取网络资源的内容
html = response.read()
 
# 将读取的内容转换为字符串
html_str = html.decode('utf-8')
 
print(html_str)

这段代码会打开指定的URL，读取其内容，并把内容解码为UTF-8编码的字符串，然后打印出来。这是一个非常基础的使用urllib.request的例子，它适用于简单的网络请求。如果你需要更高级的功能，比如发送数据、处理cookies、处理HTTPS等，你可能需要使用其他的库，如requests。

System

2024-08-27

所有,java

在Spring Cloud Alibaba中，熔断器Sentinel取代了Hystrix的角色。以下是使用Spring Cloud Alibaba Sentinel实现熔断逻辑的示例：

首先，在pom.xml中添加Sentinel依赖：




<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

在application.yml中配置Sentinel规则，例如流量控制规则：




spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080 # Sentinel 控制台地址
        port: 8719 # 本地端口，用于接收Sentinel控制台的push
      datasource:
        flow:
          default:
            resource: /flowLimit
            count: 1
            grade: 1
            limitApp: default

在Java代码中使用注解@SentinelResource定义资源，并设置熔断降级逻辑：




import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class TestController {
 
    @GetMapping("/test")
    @SentinelResource(value = "test", blockHandler = "handleException")
    public String test() {
        return "Test";
    }
 
    public String handleException(BlockException ex) {
        return "Service is busy, please try again later.";
    }
}

在上述代码中，我们定义了一个名为"test"的资源，并指定了当熔断器被触发时，调用handleException方法来处理请求。

这样，你就可以使用Spring Cloud Alibaba Sentinel来实现服务的熔断保护。

- 阅读更多 -

动态数据源-spring-AbstractRoutingDataSource

System

2024-08-27

所有,java

AbstractRoutingDataSource是Spring框架中用于实现动态数据源路由的一个抽象类。它可以在运行时根据某种键值动态切换数据源。

以下是一个简单的使用AbstractRoutingDataSource的例子：




import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
 
public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        // DynamicDataSourceContextHolder用于存储当前线程使用的数据源标识
        return DynamicDataSourceContextHolder.getDataSourceType();
    }
}
 
// 配置数据源
@Configuration
public class DataSourceConfig {
 
    @Bean
    public DataSource dataSource() {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        
        // 配置默认数据源
        dynamicDataSource.setDefaultTargetDataSource(primaryDataSource());
        
        // 配置多数据源
        Map<Object, Object> dataSourceMap = new HashMap<>();
        dataSourceMap.put("primary", primaryDataSource());
        dataSourceMap.put("secondary", secondaryDataSource());
        
        dynamicDataSource.setTargetDataSources(dataSourceMap);
        
        return dynamicDataSource;
    }
 
    @Bean
    public DataSource primaryDataSource() {
        // 创建并配置主数据源
        return new HikariDataSource(HikariConfig config);
    }
 
    @Bean
    public DataSource secondaryDataSource() {
        // 创建并配置副数据源
        return new HikariDataSource(HikariConfig config);
    }
}
 
// 使用DynamicDataSourceContextHolder来设置当前线程使用的数据源
public class DynamicDataSourceContextHolder {
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
 
    public static void setDataSourceType(String dataSourceType) {
        contextHolder.set(dataSourceType);
    }
 
    public static String getDataSourceType() {
        return contextHolder.get();
    }
 
    public static void clearDataSourceType() {
        contextHolder.remove();
    }
}
 
// 在需要切换数据源的地方调用
DynamicDataSourceContextHolder.setDataSourceType("secondary");
// 执行数据库操作
DynamicDataSourceContextHolder.clearDataSourceType(); // 清除数据源标识

在这个例子中，我们定义了一个DynamicDataSource类，它继承自AbstractRoutingDataSource并重写了determineCurrentLookupKey方法。然后我们配置了两个数据源，并通过DynamicDataSourceContextHolder在运行时动态切换。这样，我们可以在不同的业务场景下使用不同的数据源。

- 阅读更多 -

Golang net.route 包详解

System

2024-08-27

所有,golang

net.route 包在 Go 语言的标准库中并不存在。这可能是因为你在查找某个特定的、可能是自定义的或第三方的 net.route 包。

如果你是在寻找如何在 Go 中操作网络路由，你可能需要使用 netlink 包，这是一个与 Linux 网络子系统通信的包。以下是一个简单的示例，展示如何使用 netlink 包获取和配置路由信息：




package main
 
import (
    "fmt"
    "log"
    "net"
 
    "github.com/vishvananda/netlink"
)
 
func main() {
    // 获取所有路由规则
    rules, err := netlink.RuleList(0)
    if err != nil {
        log.Fatalf("Failed to get rule list: %v", err)
    }
    fmt.Println("Rules:", rules)
 
    // 获取所有路由项
    routes, err := netlink.RouteList(nil, netlink.FAMILY_ALL)
    if err != nil {
        log.Fatalf("Failed to get route list: %v", err)
    }
    fmt.Println("Routes:")
    for _, r := range routes {
        fmt.Printf("Destination: %v, Gateway: %v, Genmask: %v, Flags: %v\n",
            r.Dst, r.Gw, r.Mask, r.Flags)
    }
 
    // 添加一个新的路由
    addr, err := net.ParseCIDR("192.168.1.0/24")
    if err != nil {
        log.Fatalf("ParseCIDR failed: %v", err)
    }
    route := netlink.Route{
        LinkIndex: 1, // 接口索引，例如，1 通常是 eth0
        Dst:       addr,
    }
    if err := netlink.RouteAdd(&route); err != nil {
        log.Fatalf("RouteAdd failed: %v", err)
    }
    fmt.Println("New route added.")
}

请注意，你需要 sudo 权限才能添加或修改路由。

如果你是在寻找 net.route 包的特定功能，那么你需要查看该包的文档或源代码以了解其具体用法。如果是自定义或第三方包，请确保它已经安装在你的 Go 环境中，并且导入路径正确。

- 阅读更多 -

【AntDB数据库】AntDB数据库迁移

System

2024-08-27

所有,数据库

AntDB是一款基于分布式技术的高性能事务型数据库，它支持OLTP和OLAP应用。在实际使用中，可能需要将其他数据库的数据迁移到AntDB。以下是一个简化的示例代码，展示如何将数据从其他数据库类型迁移到AntDB：




import psycopg2
import antdb_driver
 
# 连接到PostgreSQL数据库
conn_pg = psycopg2.connect(
    dbname="your_db_name",
    user="your_username",
    password="your_password",
    host="your_host",
    port="your_port"
)
 
# 连接到AntDB数据库
conn_adb = antdb_driver.connect(
    dbname="your_antdb_dbname",
    user="your_antdb_username",
    password="your_antdb_password",
    host="your_antdb_host",
    port="your_antdb_port"
)
 
# 创建PostgreSQL游标
cur_pg = conn_pg.cursor()
 
# 创建AntDB游标
cur_adb = conn_adb.cursor()
 
# 查询PostgreSQL中需要迁移的数据
cur_pg.execute("SELECT * FROM your_table")
rows = cur_pg.fetchall()
 
# 准备AntDB中的迁移语句
migrate_query = "INSERT INTO your_antdb_table (columns...) VALUES %s;"
 
# 准备数据以批量插入到AntDB
values = []
for row in rows:
    values.append(row)
    # 如果数组达到一定大小，批量插入到AntDB并清空数组
    if len(values) >= 1000:
        cur_adb.execute(migrate_query, values)
        conn_adb.commit()
        values = []
 
# 如果数组中还有剩余数据，执行最后的插入
if values:
    cur_adb.execute(migrate_query, values)
    conn_adb.commit()
 
# 关闭游标和连接
cur_pg.close()
conn_pg.close()
cur_adb.close()
conn_adb.close()

这段代码展示了如何从PostgreSQL数据库中读取数据，并将其批量插入到AntDB数据库中。注意，实际使用时需要根据数据库的具体情况调整连接参数、查询语句和数据处理逻辑。

- 阅读更多 -

Oracle Database 21c 安装和卸载

System

2024-08-27

所有,数据库

Oracle Database 21c的安装和卸载通常涉及运行安装程序或使用命令行工具。以下是安装和卸载的基本步骤：

安装 Oracle Database 21c

下载 Oracle Database 21c 安装文件。
运行安装程序（例如，在 Windows 上是 setup.exe，在 Linux 上是 runInstaller）。
遵循安装向导的步骤，包括软件许可协议、系统要求检查、安装选项配置、执行安装等。
安装完成后，根据提示进行 post-installation 配置，例如创建初始数据库。

卸载 Oracle Database 21c

使用 Oracle Universal Installer (OUI) 或命令行工具启动卸载程序。
选择要卸载的 Oracle 产品或组件。
遵循卸载向导的步骤，包括确认卸载内容、停止数据库服务、移除文件和清理系统资源。
完成后，可能需要手动删除剩余的文件和注册表项。

示例代码和命令（以 Linux 为例）

安装命令:




$ cd $ORACLE_HOME
$ ./runInstaller

卸载命令:




$ $ORACLE_HOME/deinstall/deinstall

注意：实际的卸载步骤可能会有所不同，具体取决于你的系统配置和安装选项。在执行卸载之前，请确保备份任何重要数据。

- 阅读更多 -

POSTGRESQL 统计信息与数据查询的准确性与多种统计信息类型

System

2024-08-27

所有,数据库

在PostgreSQL中，可以使用多种方法来统计信息并提高查询的准确性。以下是一些常用的统计信息类型和查询示例：

查询表的行数：




SELECT relname, reltuples AS estimate FROM pg_class WHERE relkind = 'r';

查询索引的使用情况：




SELECT * FROM pg_stat_user_indexes;

查询表的检查约束：




SELECT conname, convalidated FROM pg_constraint WHERE contype = 'c';

查询最近的Autovacuum操作：




SELECT * FROM pg_stat_bgwriter;

查询数据库的大小：




SELECT pg_size_pretty(pg_database_size('your_database_name'));

查询表的碎片程度：




SELECT relname, n_dead_tup, last_vacuum FROM pg_stat_user_tables;

查询当前数据库的活动状态：




SELECT * FROM pg_stat_database WHERE datname = current_database();

通过使用这些查询，数据库管理员可以获取关键的统计信息，以便进行性能分析和调优。对于查询准确性，可以通过在查询前执行ANALYZE your_table_name;来更新统计信息，从而提高查询计划的准确性。

- 阅读更多 -

Linux 基本指令讲解上

System

2024-08-27

所有,linux

在Linux中，有许多基本且必须掌握的指令。以下是一些常见的基本指令及其用法：

ls




cd /path/to/directory

pwd

touch：创建空文件。




touch filename

cat：查看文件内容。




cat filename




cp source destination




mv source destination




rm filename




mkdir new_directory




rmdir empty_directory

man：查看命令手册。




man command




chmod 755 filename




chown new_owner filename

grep：在文件中查找字符串。




grep "string" filename

find：在系统中查找文件。




find /path/to/search -name "filename"

ps：查看当前进程状态。




ps aux

kill：终止进程。




kill PID

tar：压缩或解压文件。




tar -cvf archive.tar files

wget：从网络下载文件。




wget http://example.com/filename

apt：安装、更新、卸载软件包。




apt install package_name

这些基本指令涵盖了日常操作的大部分需求。记住，每个指令都有许多选项和参数可以进一步细化其功能，但以上提供的是最常用的形式。

- 阅读更多 -