分类后端技术下的文章

2024-08-27




import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
import java.util.concurrent.TimeUnit;
 
public class RedissonLockExample {
 
    public static void main(String[] args) {
        // 配置Redisson客户端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 获取锁对象实例
        RLock lock = redisson.getLock("myLock");
 
        try {
            // 尝试获取锁，最多等待100秒，锁定之后最多持有锁10秒
            boolean isLocked = lock.tryLock(100, 10, TimeUnit.SECONDS);
            if (isLocked) {
                // 业务逻辑
                System.out.println("Lock acquired");
                // 处理完业务逻辑后释放锁
            } else {
                System.out.println("Lock not acquired");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
                System.out.println("Lock released");
            }
        }
 
        // 关闭Redisson客户端
        redisson.shutdown();
    }
}

这段代码展示了如何使用Redisson框架来获取和释放分布式锁。它首先配置了Redisson客户端，然后尝试获取名为"myLock"的锁对象。如果在指定的等待时间内成功获取锁，它将执行被锁保护的代码，并在完成后释放锁。最后，它关闭了Redisson客户端以释放资源。这个例子简单明了地展示了如何在Java中使用Redisson进行分布式锁操作。

- 阅读更多 -

Oracle行转列pivot

System

2024-08-27

所有,数据库

在Oracle中，行转列可以通过PIVOT子句来实现。以下是一个简单的例子，假设我们有一个sales表，包含了year, product 和 amount 三个字段，我们想要将product行转为列，并对每个产品的amount进行汇总。




SELECT * FROM
(
  SELECT year, product, amount
  FROM sales
)
PIVOT
(
  SUM(amount)
  FOR product IN ('产品A' AS product_a, '产品B' AS product_b, '产品C' AS product_c)
) ORDER BY year;

在这个例子中，我们使用PIVOT子句将product行转为列，并对每个产品的销售额amount进行了求和操作。FOR product IN (...)部分定义了我们想要转换的列和它们对应的别名。

注意：Oracle的PIVOT子句不支持动态列名，因此在使用时需要明确指定所有要转换的列和别名。如果列名是动态的，你可能需要使用PL/SQL结合动态SQL来实现行转列的功能。

- 阅读更多 -

Python3 tempfile — 临时文件对象

System

2024-08-27

所有,python

tempfile模块提供了创建临时文件和文件夹的功能。在Python中，临时文件和文件夹通常用于临时存储数据，这些数据在程序结束或系统重启后会被删除。

以下是一些使用tempfile模块的常见方法：

创建临时文件：




import tempfile
 
# 创建临时文件
temp_file = tempfile.NamedTemporaryFile(mode='w+t')
 
# 写入数据到临时文件
temp_file.write("Hello, World!")
 
# 关闭文件
temp_file.close()

创建临时文件夹：




import tempfile
 
# 创建临时文件夹
with tempfile.TemporaryDirectory() as temp_dir:
    print('临时文件夹的路径:', temp_dir)
    # 在临时文件夹中进行操作
    # ...

获取临时文件或文件夹的路径：




import tempfile
 
# 获取临时文件路径
temp_path = tempfile.mkstemp()
print('临时文件路径:', temp_path)
 
# 删除临时文件
os.close(temp_path[0])
os.unlink(temp_path[1])

使用tempfile创建临时文件时，如果需要在文件关闭后保留该文件，可以在创建时指定delete=False：




import tempfile
 
# 创建临时文件但不删除
temp_file = tempfile.NamedTemporaryFile(mode='w+t', delete=False)
temp_file.write("Hello, World!")
temp_file.close()
 
# 文件关闭后，文件仍然存在于系统中，可以通过temp_file.name获取文件路径
print('文件路径:', temp_file.name)

以上代码展示了如何使用tempfile模块来创建临时文件、文件夹、获取临时文件路径，以及在文件关闭后保留文件的方法。

- 阅读更多 -

Laravel 错误处理：抛出 404/403/500 异常

System

2024-08-27

所有,php

在Laravel框架中，处理HTTP异常可以通过创建自定义异常处理器来实现。以下是如何为常见的404、403、500错误创建自定义处理器的示例。

创建自定义异常处理器：




// app/Exceptions/Handler.php
 
public function render($request, Throwable $exception)
{
    if ($exception instanceof \Symfony\Component\HttpKernel\Exception\NotFoundHttpException) {
        return response()->view('errors.404', [], 404);
    }
 
    if ($exception instanceof \Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException) {
        return response()->view('errors.403', [], 403);
    }
 
    if ($exception instanceof \ErrorException) {
        return response()->view('errors.500', [], 500);
    }
 
    return parent::render($request, $exception);
}

创建相应的错误视图模板：




<!-- resources/views/errors/404.blade.php -->
<!DOCTYPE html>
<html>
<head>
    <title>Page Not Found</title>
</head>
<body>
    <h1>404 Error - Page Not Found</h1>
    <p>The page you are looking for might have been removed, had its name changed, or is temporarily unavailable.</p>
</body>
</html>




<!-- resources/views/errors/403.blade.php -->
<!DOCTYPE html>
<html>
<head>
    <title>Forbidden</title>
</head>
<body>
    <h1>403 Error - Forbidden</h1>
    <p>You don't have permission to access this resource on the server.</p>
</body>
</html>




<!-- resources/views/errors/500.blade.php -->
<!DOCTYPE html>
<html>
<head>
    <title>Internal Server Error</title>
</head>
<body>
    <h1>500 Error - Internal Server Error</h1>
    <p>The server encountered a problem and could not complete your request.</p>
</body>
</html>

这样，当Laravel应用程序遇到上述异常时，会返回自定义的错误页面。记得在实际部署时，确保配置了正确的错误报告级别以及存储了错误日志，以便于调试和修复问题。

- 阅读更多 -

Python3 getopt — 解析命令行参数

System

2024-08-27

所有,python

getopt 是 Python 的一个标准库模块，用于解析命令行选项和参数。它可以帮助你在编写脚本时处理命令行输入。

解析命令行参数的基本步骤如下：

导入 getopt 模块。
使用 getopt.getopt 方法解析命令行参数。

下面是一个简单的例子，演示如何使用 getopt 解析命令行参数：




import getopt
 
def main():
    try:
        opts, args = getopt.getopt(sys.argv[1:], "ho:", ["help", "output="])
    except getopt.GetoptError as err:
        # 输出错误信息，并显示帮助信息
        print(err)
        usage()
        sys.exit(2)
 
    output = None
    for o, a in opts:
        if o in ("-h", "--help"):
            usage()
            sys.exit()
        elif o in ("-o", "--output"):
            output = a
        else:
            assert False, "unhandled option"
 
    # 处理位置参数
    for arg in args:
        print("位置参数:", arg)
 
    # 处理解析出的选项和参数
    print("输出文件名:", output)
 
if __name__ == "__main__":
    main()

在这个例子中，我们定义了一个 main 函数，它解析命令行参数。-h 或 --help 选项会显示帮助信息并退出程序，-o 或 --output 选项后面需要跟一个参数，指定输出文件名。sys.argv[1:] 是传给脚本的命令行参数列表，不包括脚本名本身。

getopt.getopt 方法的参数：

第一个参数是要解析的命令行参数列表。
第二个参数是短选项的字母，后面跟一个冒号（:）表示该选项需要参数。
第三个参数是长选项名称的列表，可以选择性地带有 =，表示长选项后面需要参数。

getopt.getopt 返回的是两个列表：

第一个列表 opts 包含一个个 (选项, 值) 元组，如果是短选项，值会以空格分隔；如果是长选项，值会在 = 后面。
第二个列表 args 包含所有未被解析的位置参数。

在解析过程中，如果有任何错误（如未知的选项，需要的选项缺失参数），getopt.GetoptError 异常会被抛出，并包含错误信息。

- 阅读更多 -

Laravel 控制器：修改资源路由动作名称

System

2024-08-27

所有,php

在Laravel框架中，可以通过重写控制器中的resourceMethodNames属性来修改资源路由的动作名称。以下是一个简单的示例：




use Illuminate\Routing\Controller;
 
class CustomController extends Controller
{
    protected $resourceMethodNames = [
        'create' => 'custom_create',
        'edit' => 'custom_edit',
    ];
 
    public function custom_create()
    {
        // 创建资源的逻辑
    }
 
    public function custom_edit()
    {
        // 编辑资源的逻辑
    }
}
 
// 在路由中使用自定义控制器
Route::resource('items', CustomController::class);

在这个示例中，我们创建了一个自定义控制器CustomController，在其中我们重写了resourceMethodNames属性，将默认的create和edit方法改为custom_create和custom_edit。然后，我们在路由中使用Route::resource函数来注册资源路由，这样当我们访问/items/create时，实际上会调用custom_create方法。同理，访问/items/{id}/edit时，会调用custom_edit方法。

- 阅读更多 -

Laravel 中间件：注册全局中间件 Draft

System

2024-08-27

所有,php

在 Laravel 中，你可以在 app/Http/Kernel.php 文件中的 $middleware 属性注册全局中间件。这个属性是一个中间件数组，其中列出了在每个 HTTP 请求会经过的中间件。

例如，如果你想要注册一个全局的中间件，你可以按照以下步骤操作：

确保你的中间件类已经被创建。例如，你的中间件可能位于 app/Http/Middleware/MyMiddleware.php。
打开 app/Http/Kernel.php 文件。
在 $middleware 数组中添加你的中间件，例如：




protected $middleware = [
    // ...
    \App\Http\Middleware\MyMiddleware::class,
    // ...
];

确保将 \App\Http\Middleware\MyMiddleware::class 替换为你自己的中间件完整类名。

这样，你的中间件就会在每个 HTTP 请求上被自动应用。如果你想要为中间件指定一个别名，你也可以在 $middleware 数组中定义别名，例如：




protected $middleware = [
    // ...
    'myMiddleware' => \App\Http\Middleware\MyMiddleware::class,
    // ...
];

这样，你就可以在路由中使用别名来引用这个中间件。

- 阅读更多 -

Laravel 用户授权：判断是否授权

System

2024-08-27

所有,php

在Laravel框架中，我们可以使用Gate和Policy来进行用户的授权检查。以下是一些示例代码。

使用Gate进行授权检查

首先，在AppServiceProvider的boot方法中定义一个gate。




use Illuminate\Support\Facades\Gate;
 
public function boot()
{
    Gate::define('update-post', function ($user, $post) {
        return $user->id === $post->user_id;
    });
}

然后，在控制器或者其他需要的地方使用Gate来判断当前用户是否有权限。




if (Gate::allows('update-post', $post)) {
    // 当前用户有权限
}
 
if (Gate::denies('update-post', $post)) {
    // 当前用户无权限
}

使用Policy进行授权检查

首先，使用artisan命令生成一个Policy。




php artisan make:policy PostPolicy

然后，在生成的PostPolicy中定义方法。




public function update(User $user, Post $post)
{
    return $user->id === $post->user_id;
}

接着，在AuthServiceProvider的policies方法中注册这个Policy。




protected $policies = [
    Post::class => PostPolicy::class,
];

最后，在控制器或者其他需要的地方使用Policy来判断当前用户是否有权限。




if ($this->authorize('update', $post)) {
    // 当前用户有权限
}
 
if (!$this->authorize('update', $post)) {
    // 当前用户无权限
}

以上两种方式都可以用来判断用户是否有权限，具体使用哪一种取决于你的项目需求和团队的代码风格。

- 阅读更多 -

达梦到 oracle的 hs 搭建

System

2024-08-27

所有,数据库

在达梦数据库与Oracle数据库之间使用HS（High-Speed）进行数据迁移或同步，需要进行以下步骤：

在Oracle服务器上安装HS（High-Speed）驱动。
配置Oracle服务器上的sqlnet.ora文件，添加相应的HS连接信息。
在达梦数据库中创建数据库链接，指向Oracle服务器。
使用数据库链接进行数据查询、插入、更新等操作。

以下是创建数据库链接的示例代码：




-- 创建数据库链接
CREATE DATABASE LINK oracle_link
CONNECT TO "oracle_user" IDENTIFIED BY "oracle_password"
USING 'oracle_hs';
 
-- 查询示例
SELECT * FROM all_tables@oracle_link;

在这个例子中，oracle_link 是链接名称，oracle_user 和 oracle_password 是Oracle数据库的用户名和密码，oracle_hs 是在sqlnet.ora中配置的HS连接名。

请确保Oracle服务器的HS驱动安装正确，并且Oracle数据库的用户权限足够允许链接和操作。同时，确保达梦数据库有足够的权限去创建数据库链接。

System

2024-08-27

所有,java

在Kafka中，消息重复、重复消费可能由以下几个原因导致：

生产者重复发送：生产者可能因为网络问题导致消息重复发送到同一个分区。
Broker故障：Broker宕机后重启可能导致已经提交的消息重新被消费。
消费者故障：消费者宕机后重启，可能会再次处理已经提交的消息。
消费者并发问题：如果消费者并发情况下处理消息，可能会导致重复消费。

解决方案：

生产者端：确保消息的唯一性，可以使用Kafka提供的ID来追踪消息。
Broker端：确保Broker的日志（log）机制是可靠的，不会因为故障导致重复数据。
消费者端：
- 确保消费者ID的唯一性。
- 使用消息的唯一标识（如ID或者时间戳）进行去重。
- 实现幂等性日志记录，确保消费者重启后不会重复处理。

具体实现可以参考以下代码示例：




// 生产者设置
props.put("retries", 3); // 设置重试次数
props.put("acks", "all"); // 确保消息被所有副本收到
 
// 消费者设置
props.put("enable.auto.commit", "false"); // 禁用自动提交
props.put("isolation.level", "read_committed"); // 设置隔离级别
 
// 消费者代码中去重逻辑
String key = record.key();
String messageId = getMessageId(key);
if (isMessageProcessed(messageId)) {
    // 如果消息已处理，跳过
    continue;
}
 
// 标记消息为已处理
markMessageAsProcessed(messageId);
 
// 处理消息逻辑
processMessage(record);

在实际应用中，还需要根据具体业务场景和需求来设计合适的去重策略。

- 阅读更多 -