分类后端技术下的文章

Spring Cloud源码解析 - Nacos注册中心原理 - AP与CP模式

2024-09-04

在Spring Cloud中，Nacos作为服务注册中心时，支持AP（高可用性）和CP（一致性）两种模式。

AP模式：当服务注册中心AP模式下，服务注册中心的非强一致性保证，客户端请求可以得到响应，但是可能会出现短暂的网络错误或者服务不一致的情况。

CP模式：当服务注册中心CP模式下，服务注册中心的强一致性保证，在服务注册或者获取服务列表时，会有较高的延迟，但是服务的一致性会得到保证。

在Spring Cloud中，可以通过配置文件来选择Nacos的工作模式：




spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        namespace: 命名空间 # 可选，如果Nacos开启了命名空间，需要配置
        username: 用户名 # 可选，如果Nacos开启了认证，需要配置
        password: 密码 # 可选，如果Nacos开启了认证，需要配置
        # 设置Nacos的工作模式，AP或CP
        cluster-name: BJ

在这个配置文件中，cluster-name 就是用来指定Nacos的工作模式的，如果要选择CP模式，只需要将cluster-name设置为Nacos的CP集群名称即可。

注意：在实际部署时，应该根据实际的网络环境和业务需求来选择AP或CP模式，并且在CP模式下，Nacos服务端的性能要求会更高，因为需要进行更多的数据一致性校验。

- 阅读更多 -

使用eclipse创建一个最基本的Java Web项目

System

2024-09-04

所有,java

在Eclipse中创建一个最基本的Java Web项目，你需要遵循以下步骤：

打开Eclipse，点击 File 菜单，然后选择 New > Dynamic Web Project。
在弹出的 New Dynamic Web Project 对话框中，填写项目名称，例如 BasicJavaWebApp。
选择你的Java版本，例如Java 8。
点击 Next，在接下来的窗口中，你可以选择目标运行时，例如Apache Tomcat。
选择你的Tomcat服务器版本，然后点击 Next。
根据需要修改Web模块名称和Context路径，然后点击 Finish。

以下是一个简单的Servlet示例，它可以添加到你的项目中去处理HTTP请求：




import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
 
public class HelloWorldServlet extends HttpServlet {
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        response.setContentType("text/html");
        PrintWriter out = response.getWriter();
        out.println("<html><body><h1>Hello World</h1></body></html>");
    }
}

将这个Servlet添加到你的项目中，并且配置web.xml文件来映射这个Servlet，例如：




<servlet>
    <servlet-name>HelloWorld</servlet-name>
    <servlet-class>HelloWorldServlet</servlet-class>
</servlet>
<servlet-mapping>
    <servlet-name>HelloWorld</servlet-name>
    <url-pattern>/hello</url-pattern>
</servlet-mapping>

现在，你可以部署应用到Tomcat服务器，并通过浏览器访问，例如 http://localhost:8080/BasicJavaWebApp/hello。

System

2024-09-04

所有,数据库

在Python中使用psycopg2库与PostgreSQL数据库交互时，插入数据后，需要提交事务并正确关闭连接。以下是一个示例代码：




import psycopg2
 
# 连接参数
conn_params = {
    "dbname": "your_db",
    "user": "your_user",
    "password": "your_password",
    "host": "localhost"
}
 
# 创建连接
conn = psycopg2.connect(**conn_params)
 
# 创建游标
cursor = conn.cursor()
 
try:
    # 插入数据的SQL命令
    insert_query = """INSERT INTO your_table (column1, column2) VALUES (%s, %s)"""
    record_to_insert = ("value1", "value2")
 
    # 执行插入命令
    cursor.execute(insert_query, record_to_insert)
 
    # 提交事务
    conn.commit()
 
    # 关闭游标
    cursor.close()
 
    # 可以选择再打开一个新的游标进行查询等操作
    cursor = conn.cursor()
    # cursor.execute("SELECT * FROM your_table")
    # results = cursor.fetchall()
    # print(results)
 
except psycopg2.Error as e:
    print("Error:", e)
    conn.rollback()  # 发生错误时回滚事务
finally:
    # 关闭连接
    conn.close()

在这个例子中，我们首先创建了连接和游标，然后执行了一条插入数据的SQL命令。插入完成后，我们提交了事务。在结束时，我们关闭了游标并关闭了连接。如果在操作过程中发生异常，我们会回滚事务并关闭连接。这是一个管理数据库事务和资源关闭的良好实践。

System

2024-09-04

所有,数据库

解释：

CSRF（跨站请求伪造）是一种安全机制，用于防止恶意网站发送恶意请求到您的Django服务器。当Django框架检测到一个POST请求缺少CSRF cookie时，会抛出“Forbidden (CSRF cookie not set.)”这个错误。

解决方法：

确保在Django模板中包含了CSRF token。通常这是通过在表单中包含一个隐藏的input标签实现的，如下所示：




<form action="/your-name/" method="post">
    {% csrf_token %}
    <input type="text" name="your_name" />
    <input type="submit" value="Submit" />
</form>

如果你在使用AJAX请求，确保在发送请求时包含CSRF token。可以通过jQuery的$.ajaxSetup()方法全局设置，或者在每个请求中手动设置。
如果确信某个视图不需要CSRF保护，可以使用@csrf_exempt装饰器来禁用CSRF保护。但这种做法应谨慎使用，因为它会降低安全性。
确保Django的中间件django.middleware.csrf.CsrfViewMiddleware已经启用。在settings.py文件中，确认有以下代码：
```
MIDDLEWARE = [
    # ...其他中间件...
    'django.middleware.csrf.CsrfViewMiddleware',
    # ...其他中间件...
]
```
如果是跨域请求，确保CORS（跨源资源共享）配置正确，并且服务器正确地提供了CSRF cookie。
如果使用了Django的session-based CSRF，确保用户的浏览器允许cookie。
如果以上都不适用，检查Django的日志文件，查看更详细的错误信息，可能会提供额外的线索。

- 阅读更多 -

RHEL 8下Oracle Database 23ai 安装与配置

System

2024-09-04

所有,数据库

由于篇幅所限，以下是一个简化的示例，展示如何在RHEL 8上安装和配置Oracle Database 23c（23ai）。




#!/bin/bash
 
# 设置Oracle软件源
cat > /etc/yum.repos.d/oracle-database-23c.repo <<EOF
[ol7_u8_base]
name=Oracle Linux \$releasever\$basearch - Base
baseurl=https://yum.oracle.com/repo/OracleLinux/OL8/appstream/x86_64/
gpgkey=file:///etc/pki/rpm-gpg/RPM-GPG-KEY-oracle
gpgcheck=1
enabled=1
 
[ol7_u8_optional]
name=Oracle Linux \$releasever\$basearch - Optional
baseurl=https://yum.oracle.com/repo/OracleLinux/OL8/optional/x86_64/
gpgkey=file:///etc/pki/rpm-gpg/RPM-GPG-KEY-oracle
gpgcheck=1
enabled=1
 
[ol7_u8_addons]
name=Oracle Linux \$releasever\$basearch - Addons
baseurl=https://yum.oracle.com/repo/OracleLinux/OL8/addons/x86_64/
gpgkey=file:///etc/pki/rpm-gpg/RPM-GPG-KEY-oracle
gpgcheck=1
enabled=1
 
[oracle-database-preinstall-23c]
name=Oracle Database 23c Preinstall
baseurl=https://yum.oracle.com/repo/OracleLinux/OL8/appstream/x86_64/
gpgkey=https://yum.oracle.com/RPM-GPG-KEY-oracle-ol7
gpgcheck=1
enabled=1
EOF
 
# 安装Oracle数据库软件
yum install -y oracle-database-ee-23c
 
# 配置Oracle环境变量
echo "export ORACLE_HOME=/opt/oracle/product/23c/dbhome_1" >> ~/.bashrc
echo "export PATH=\$PATH:\$ORACLE_HOME/bin" >> ~/.bashrc
source ~/.bashrc
 
# 创建并配置Oracle实例
dbca -silent -createDatabase \
-templateName General_Purpose.dbc \
-gdbName testdb -createAsContainerDatabase false \
-sid testdb -responseFile NO_VALUE \
-characterSet AL32UTF8 \
-sysPassword password -systemPassword password \
-createSysDBA true -sysDBAPassword password
 
# 注：以上脚本中的密码需要替换为实际的密码，并且需要根据实际情况调整其他参数。

这个脚本展示了如何在RHEL 8上设置Oracle软件源，安装Oracle数据库软件，配置环境变量，并使用dbca创建一个新的数据库实例。在实际应用中，你需要根据自己的需求修改这个脚本。

- 阅读更多 -

sql优化篇 -入门

System

2024-09-04

所有,数据库

在数据库查询优化中，有几个基本的原则和技巧可以提高查询的性能。以下是一些基本的SQL优化方法：

使用索引：适当地在列上添加索引可以显著提高查询速度。
选择合适的列：只选取需要的列，而不是使用SELECT *。
使用WHERE子句过滤数据：只返回匹配WHERE子句条件的行。
避免使用子查询：尽可能使用JOIN来合并表。
使用合适的JOIN类型：例如，如果表之间是一对一的关系，使用INNER JOIN；如果需要包含左边表的所有行，使用LEFT JOIN。
避免使用函数和计算：在WHERE子句中避免对列使用函数或进行复杂的计算。
使用LIMIT来分页：限制返回的结果数量。
优化GROUP BY和ORDER BY子句：确保它们的列有合适的索引。

示例代码：




-- 假设我们有一个名为users的表，我们想快速检索名字为'John'的用户。
 
-- 不好的实践：
SELECT * FROM users WHERE name = 'John';
 
-- 优化后的查询：
SELECT id, name, email FROM users WHERE name = 'John';
 
-- 假设我们有两个表：orders和customers，它们通过customer_id关联。
-- 使用索引优化JOIN操作：
SELECT o.order_id, o.order_date, c.customer_name
FROM orders o
INNER JOIN customers c ON o.customer_id = c.customer_id;

在实际应用中，每个查询的优化都需要根据实际情况进行分析。使用EXPLAIN语句可以帮助你理解数据库是如何执行你的查询，从而进行相应的优化。

- 阅读更多 -

Linux环境搭建（Ubuntu22.04）+ 配置共享文件夹（Samba）

System

2024-09-04

所有,数据库

在Ubuntu 22.04上搭建Samba服务以配置共享文件夹的步骤如下：

安装Samba服务器：




sudo apt update
sudo apt install samba

创建一个共享目录并设置权限（例如创建一个名为share的共享目录）：




mkdir /share
sudo chown nobody:nogroup /share
sudo chmod 0775 /share

配置Samba共享设置。编辑Samba配置文件/etc/samba/smb.conf，在文件末尾添加以下内容：




[share]
   path = /share
   browseable = yes
   read only = no
   writable = yes
   guest ok = yes

重启Samba服务以应用配置更改：




sudo systemctl restart smbd

如果有防火墙正在运行，允许Samba通过防火墙：




sudo ufw allow samba

现在你应该能够从网络上的其他计算机访问你的Ubuntu共享文件夹了。在Windows中，你可以使用\\ubuntu-host-ip\share，在Linux中，你可以使用smbclient //ubuntu-host-ip/share进行访问。

- 阅读更多 -

推荐开源项目：db-to-sqlite

System

2024-09-04

所有,数据库

db-to-sqlite是一个可以将数据库转换为SQLite数据库的工具。以下是一个使用该工具的Python代码示例：




from db_to_sqlite import DBToSQLite
 
# 创建DBToSQLite实例，指定数据库类型和连接字符串
db_to_sqlite = DBToSQLite(db_type='mysql', connection_string='mysql://user:password@localhost/database')
 
# 转换数据库结构到SQLite
db_to_sqlite.convert_schema()
 
# 转换数据库数据到SQLite
db_to_sqlite.convert_data()
 
# 保存SQLite数据库到文件
db_to_sqlite.save_sqlite('output.sqlite')

这段代码展示了如何使用db-to-sqlite库来转换一个MySQL数据库到SQLite格式，并将转换后的SQLite数据库保存到文件。需要注意的是，该代码假定您已经安装了db-to-sqlite库。如果未安装，可以通过pip进行安装：




pip install db-to-sqlite

- 阅读更多 -

Spring Cloud之Nacos动态配置

System

2024-09-04

所有,java

在Spring Cloud中使用Nacos作为配置中心，可以通过以下步骤实现动态配置：

引入Nacos客户端依赖：




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

在bootstrap.properties或bootstrap.yml中配置Nacos服务器地址和应用名：




spring.cloud.nacos.config.server-addr=127.0.0.1:8848
spring.application.name=my-application

在应用中使用@Value注解或@ConfigurationProperties注解来注入配置：




@Value("${my.config}")
private String myConfig;
 
// 或者
@ConfigurationProperties(prefix = "my")
@Data
public class MyConfigProperties {
    private String config;
}

在Nacos控制台配置对应的配置数据，并设置好配置的监听，当配置发生变化时，应用会自动更新配置。
如果需要在代码中动态刷新配置，可以使用RefreshScope注解：




@RefreshScope
@RestController
public class ConfigController {
 
    @Value("${my.config}")
    private String myConfig;
 
    @GetMapping("/config")
    public String getConfig() {
        return myConfig;
    }
}

当配置发生变化时，你可以调用Nacos的Open API或使用Nacos控制台的按钮触发配置的更新，应用会接收到配置的变化，并自动更新配置。

System

2024-09-04

所有,java




import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
 
@Configuration
public class WebConfig extends WebMvcConfigurationSupport {
 
    @Override
    protected void addResourceHandlers(ResourceHandlerRegistry registry) {
        registry.addResourceHandler("/**")
                .addResourceLocations("classpath:/static/")
                .addResourceLocations("classpath:/public/")
                .addResourceLocations("classpath:/resources/");
 
        // 如果你需要添加对其他目录的支持，可以继续添加 .addResourceLocations 方法
        // 例如添加对 /my_static/** 的支持
        // registry.addResourceHandler("/my_static/**")
        //        .addResourceLocations("file:./my_static/");
 
        super.addResourceHandlers(registry);
    }
}

这段代码定义了一个配置类 WebConfig，它扩展了 WebMvcConfigurationSupport 并覆盖了 addResourceHandlers 方法。这个方法用于添加资源处理器，以便 Spring Boot 应用能够正确地处理静态资源。这里使用了三个常用的静态资源目录：classpath:/static/, classpath:/public/ 和 classpath:/resources/，并且调用了 super.addResourceHandlers(registry) 以确保其他的资源处理器仍然有效。这样做可以避免使用 WebMvcConfigurationSupport 带来的问题，如 Spring Boot 自动配置失效。

- 阅读更多 -