分类后端技术下的文章

2024-08-29

Tomcat中的session管理是线程安全的，这是通过StandardManager类中的<Manager>元素实现的，它负责创建、销毁session，并在请求处理期间管理session状态。

以下是一个简化的StandardManager类的核心方法，展示了如何创建和销毁session，以及如何获取和绑定session：




public class StandardManager implements Manager {
    private Map<String, Session> sessions = new ConcurrentHashMap<>();
 
    @Override
    public Session createSession(String sessionId) {
        Session session = new StandardSession(this);
        session.setId(sessionId);
        sessions.put(sessionId, session);
        return session;
    }
 
    @Override
    public void expireSession(Session session) {
        sessions.remove(session.getId());
    }
 
    @Override
    public Session findSession(String id) throws IOException {
        return sessions.get(id);
    }
 
    @Override
    public void load() throws ClassNotFoundException, IOException {
        // 从存储介质加载session
    }
 
    @Override
    public void unload() throws IOException {
        // 将session状态保存到存储介质
    }
 
    @Override
    public void backgroundProcess() {
        // 实现session超时检查等后台处理逻辑
    }
}

在这个例子中，sessions是一个ConcurrentHashMap，它提供了高级的线程安全功能，可以在多线程环境下安全地进行操作。通过createSession、expireSession、findSession等方法，开发者可以管理session的生命周期，实现session的线程安全。

- 阅读更多 -

在Unity中使用SQLite来进行数据存储-01（环境准备篇）

System

2024-08-29

所有,数据库




using System.Data.SQLite;
 
// 创建数据库连接
SQLiteConnection connection = new SQLiteConnection("Data Source=mydatabase.db;Version=3;");
connection.Open();
 
// 创建数据库命令
SQLiteCommand command = connection.CreateCommand();
command.CommandText = "CREATE TABLE IF NOT EXISTS People (Id INTEGER PRIMARY KEY, Name TEXT, Age INTEGER);";
command.ExecuteNonQuery();
 
// 关闭数据库连接
connection.Close();

这段代码演示了如何在Unity中使用C#语言和SQLite数据库进行数据存储。首先，它创建了一个SQLiteConnection对象，并打开了一个数据库连接。然后，它创建了一个SQLiteCommand对象，并设置了创建一个名为"People"的表的SQL命令，该表具有三个字段：Id（主键），Name和Age。最后，它执行了这个命令，并在完成后关闭了数据库连接。这是数据存储系列教程的第一部分，它演示了如何准备数据库环境。

- 阅读更多 -

从HTTP到Tomcat：揭秘Web应用的底层协议与高性能容器

System

2024-08-29

所有,java




HTTP请求和响应的交互是Web开发中的一个核心概念。在这里，我们将深入探讨HTTP的底层工作原理，并介绍Tomcat服务器，它是一个流行的Java Servlet容器。
 
HTTP基础
HTTP（超文本传输协议）是一种用于分布式、协作式和超媒体信息系统的应用层协议。
 
```http
GET /index.html HTTP/1.1
Host: www.example.com
 
HTTP/1.1 200 OK
Content-Type: text/html
Content-Length: 12345
 
<!doctype html>
<html>
...
</html>

Tomcat服务器

Tomcat是一个免费的开放源代码的Web应用服务器，属于轻量级应用服务器，在中小型系统和并发访问用户不多的场合下被普遍使用。

安装Tomcat后，通常需要配置环境变量CATALINA_HOME指向Tomcat的安装目录，然后通过catalina.bat（Windows）或catalina.sh（Unix/Linux）脚本启动服务器。

在Tomcat中，Web应用由一些静态资源（HTML/CSS/JS/图片等）和Servlet组成，这些由开发者编写并编译打包成WAR（Web Application Archive）文件部署到Tomcat的webapps目录下。

Tomcat启动后，会监听配置的端口（默认是8080），等待HTTP请求的到来。当接收到请求后，Tomcat会根据请求的URL和WAR文件内的部署配置找到相应的Servlet进行处理，并返回响应。

以下是一个简单的Servlet示例：




import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
 
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>");
    }
}

在Tomcat中部署Servlet需要在web.xml中配置servlet类或通过注解配置URL映射，然后将其打包成WAR文件部署到Tomcat。

总结：HTTP定义了客户端和服务器之间交换数据的格式，而Tomcat作为Servlet容器，负责解析HTTP请求，查找并执行对应的Servlet代码，并生成响应返回给客户端。

System

2024-08-29

所有,数据库

报错解释：

这个错误是PostgreSQL数据库在解析SQL语句时发生的语法错误。$1是一个占位符，通常在使用预编译的SQL语句时使用，比如在使用JDBC时。错误提示表明在查询的某个位置，解析器遇到了一个不符合语法规则的字符串$1。

可能的原因：

使用了预编译的SQL语句，但是在拼接参数时出现了错误。
在SQL语句中使用了不正确的引号或者转义字符。
在SQL语句中包含了不应该出现的特殊字符。

解决方法：

检查SQL语句的拼写是否正确，特别是在拼接参数时，确保使用正确的语法和转义。
如果是在使用预编译的PreparedStatement，确保使用正确的占位符（通常是问号?），而不是$1这种形式。
确保所有的字符串都被正确地用单引号包围，特别是在动态构建SQL语句时。
如果确实需要使用$1这种形式的参数占位符，请确保它是在正确的上下文中，例如在PL/pgSQL代码块中。
如果使用了ORM工具（如Hibernate、Entity Framework等），确保它们的配置正确，不会引入不必要的语法错误。

在调试时，可以打印出完整的SQL语句，检查其中的参数是否正确，并检查是否有不可见的特殊字符或不匹配的引号。如果问题仍然存在，可以考虑查看数据库日志以获取更多信息。

- 阅读更多 -

Spring Boot国际化i18n配置指南

System

2024-08-29

所有,java




import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.support.ResourceBundleMessageSource;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import org.springframework.web.servlet.i18n.LocaleChangeInterceptor;
import org.springframework.web.servlet.i18n.SessionLocaleResolver;
 
@Configuration
public class I18nConfig {
 
    @Bean
    public WebMvcConfigurer localeInterceptor() {
        return new WebMvcConfigurer() {
            @Override
            public void addInterceptors(InterceptorRegistry registry) {
                LocaleChangeInterceptor localeInterceptor = new LocaleChangeInterceptor();
                localeInterceptor.setParamName("lang");
                registry.addInterceptor(localeInterceptor);
            }
        };
    }
 
    @Bean
    public ResourceBundleMessageSource messageSource() {
        ResourceBundleMessageSource messageSource = new ResourceBundleMessageSource();
        messageSource.setBasename("messages");
        messageSource.setDefaultEncoding("UTF-8");
        return messageSource;
    }
 
    @Bean
    public SessionLocaleResolver localeResolver() {
        return new SessionLocaleResolver();
    }
}

这段代码定义了一个配置类I18nConfig，其中包含了国际化功能的三个核心组件：LocaleChangeInterceptor、ResourceBundleMessageSource和SessionLocaleResolver。通过addInterceptors方法，我们可以根据请求中的参数改变会话的区域设置，从而实现语言的切换。ResourceBundleMessageSource则用于查找国际化消息，而SessionLocaleResolver则用于在会话中解析区域设置信息。这个配置类可以直接用于Spring Boot项目中，简化了国际化的配置流程。

System

2024-08-29

所有,数据库




import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import com.ververica.cdc.connectors.oracle.OracleSource;
import com.ververica.cdc.debezium.StringDebeziumDeserializationSchema;
 
public class OracleCdcExample {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
 
        Properties properties = new Properties();
        properties.setProperty("connector", "oracle-cdc");
        properties.setProperty("hostname", "your-oracle-host");
        properties.setProperty("port", "1521");
        properties.setProperty("username", "your-username");
        properties.setProperty("password", "your-password");
        properties.setProperty("database-name", "your-database-name");
        properties.setProperty("schema-name", "your-schema-name");
        properties.setProperty("table-name", "your-table-name");
 
        // 创建 Oracle CDC source
        OracleSource<String> source = new OracleSource<>(
            tableEnv,
            properties,
            new StringDebeziumDeserializationSchema(),
            (rowData, rowKind) -> {
                // 处理rowData，这里可以是解析后的数据或者直接处理rowData
            }
        );
 
        // 将source加入到flink作业中
        env.addSource(source).print();
 
        env.execute("Oracle CDC Job");
    }
}

这段代码展示了如何使用Flink CDC连接器来从Oracle数据库中实时读取变更数据并打印输出。需要注意的是，这里的代码仅展示了核心逻辑，并且需要替换相应的数据库连接信息和处理逻辑以适应实际的应用场景。

System

2024-08-29

所有,数据库




from django.shortcuts import render
from .models import Event
from django.utils.timezone import now
 
def events_list(request):
    # 获取当前日期时间
    today = now()
    # 查询未来的事件，排除已经结束的事件
    upcoming_events = Event.objects.filter(end__gte=today).order_by('start')
    # 查询今天结束的事件
    today_events = Event.objects.filter(start__lte=today, end__gte=today)
    # 查询已经结束的事件
    past_events = Event.objects.filter(end__lt=today).order_by('-end')
 
    return render(request, 'events_list.html', {
        'upcoming_events': upcoming_events,
        'today_events': today_events,
        'past_events': past_events,
    })

在模板中：




<!-- 显示未来事件 -->
<h2>Upcoming Events</h2>
<ul>
{% for event in upcoming_events %}
    <li>{{ event.name }} - {{ event.start|date:"SHORT_DATE_FORMAT" }}</li>
{% empty %}
    <li>No upcoming events.</li>
{% endfor %}
</ul>
 
<!-- 显示今天的事件 -->
<h2>Events Today</h2>
<ul>
{% for event in today_events %}
    <li>{{ event.name }} - {{ event.start|time:"SHORT_TIME_FORMAT" }} - {{ event.end|time:"SHORT_TIME_FORMAT" }}</li>
{% empty %}
    <li>No events today.</li>
{% endfor %}
</ul>
 
<!-- 显示已经结束的事件 -->
<h2>Past Events</h2>
<ul>
{% for event in past_events %}
    <li>{{ event.name }} - {{ event.end|date:"SHORT_DATE_FORMAT" }}</li>
{% empty %}
    <li>No past events.</li>
{% endfor %}
</ul>

这个例子中，我们首先从Django中导入了必要的模块，并定义了一个视图函数events_list，它根据日期计算出未来的事件、今天的事件和过去的事件，并将这些事件传递给模板进行渲染。在模板中，我们使用了Django模板标签来格式化日期和时间，并通过逻辑标签{% empty %}来处理没有事件的情况。

- 阅读更多 -

C++操作SQLITE获得查询结果集的几种方法总结

System

2024-08-29

所有,数据库

在C++中操作SQLite数据库获取查询结果集，可以使用以下几种方法：

使用sqlite3_get_table函数
这个函数用于执行查询，并将结果存储在一个连续的内存块中。每一列的值都是相邻的，然后是下一行的值。




int sqlite3_get_table(
  sqlite3 *db,          /* An open database */
  const char *zSql,     /* SQL to be evaluated */
  char ***pazResult,    /* Results of the query */
  int *pnRow,           /* Number of result rows written here */
  int *pnColumn,        /* Number of result columns written here */
  char **pzErrmsg       /* Error msg written here */
);

使用sqlite3_exec函数
这个函数可以执行任何SQL命令，包括查询，但是它不直接返回结果集。为了获取结果，你需要提供一个回调函数，该函数会为每行结果被调用。




int sqlite3_exec(
  sqlite3 *db,          /* An open database */
  const char *sql,     /* SQL to be evaluated */
  int (*callback)(void*,int,char**,char**),  /* Callback function */
  void *,              /* 1st argument to callback */
  char **errmsg         /* Error message returned here */
);

使用sqlite3_prepare_v2和sqlite3_step
这些函数用于逐行执行SQL语句。sqlite3_prepare_v2准备一个SQL语句，sqlite3_step执行这个语句并让我们能够逐行访问结果集。




int sqlite3_prepare_v2(
  sqlite3 *db,            /* Database handle */
  const char *zSql,       /* SQL statement, UTF-8 encoded */
  int nByte,              /* Maximum length of zSql in bytes. */
  sqlite3_stmt **ppStmt,  /* OUT: Statement handle */
  const char **pzTail     /* OUT: Pointer to unused portion of zSql */
);
 
int sqlite3_step(sqlite3_stmt*);

使用SQLite C++ Wrapper，例如SQLiteC++
这是一个C++封装的SQLite接口，使得数据库操作更加面向对象。




#include <sqlite_modern_cpp.h>
 
// ...
 
sqlite::database db("example.db");
auto table = db("SELECT * FROM some_table");
 
for (auto& row : table) {
    std::cout << row.get<int>(0) << ": " << row.get<std::string>(1) << std::endl;
}

以上方法可以根据具体需求选择使用，例如对性能有高要求时可以选择sqlite3_get_table，对于简单查询可以使用sqlite3_exec，而对于复杂的操作或者需要重用SQL语句，则推荐使用sqlite3_prepare_v2和sqlite3_step。

- 阅读更多 -

springboot项目开启ssl双向认证且实现相互访问通信浏览器访问通信

System

2024-08-29

所有,java

在Spring Boot项目中启用SSL双向认证，并实现互相访问通信，你需要进行以下步骤：

生成服务器的私钥和证书签名请求(CSR)。
使用CA签名你的服务器证书。
准备服务器的证书和私钥。
配置Spring Boot以启用SSL和双向认证。
配置客户端以信任服务器的证书。

以下是配置Spring Boot以启用SSL双向认证的示例代码：

application.properties:




server.port=8443
server.ssl.key-store=classpath:keystore.jks
server.ssl.key-store-password=yourKeystorePassword
server.ssl.key-alias=yourKeyAlias
server.ssl.trust-store=classpath:truststore.jks
server.ssl.trust-store-password=yourTruststorePassword
server.ssl.client-auth=need

Java配置类:




@Configuration
public class SslConfig {
 
    @Bean
    public ServletWebServerFactory servletContainer() throws Exception {
        TomcatServletWebServerFactory tomcat = new TomcatServletWebServerFactory() {
            @Override
            protected void postProcessContext(Context context) {
                SecurityConstraint securityConstraint = new SecurityConstraint();
                securityConstraint.setUserConstraint("CONFIDENTIAL");
                SecurityCollection collection = new SecurityCollection();
                collection.addPattern("/*");
                securityConstraint.addCollection(collection);
                context.addConstraint(securityConstraint);
            }
        };
        tomcat.addAdditionalTomcatConnectors(createSslConnector());
        return tomcat;
    }
 
    private Connector createSslConnector() throws Exception {
        Connector connector = new Connector("org.apache.coyote.http11.Http11NioProtocol");
        Http11NioProtocol protocol = (Http11NioProtocol) connector.getProtocolHandler();
        connector.setScheme("http");
        connector.setSecure(false);
        connector.setPort(8080);
        protocol.setSSLEnabled(true);
        protocol.setKeystoreFile("path/to/your/keystore.jks");
        protocol.setKeystorePass("yourKeystorePassword");
        protocol.setKeyPass("yourKeyPassword");
        protocol.setTruststoreFile("path/to/your/truststore.jks");
        protocol.setTruststorePass("yourTruststorePassword");
        protocol.setClientAuth("true");
        return connector;
    }
}

确保你已经准备好了服务器的keystore和truststore文件，并且在代码中指定了正确的路径和密码。这样配置后，你的Spring Boot应用将启用SSL，并要求客户端提供证书以进行双向认证。客户端需要具有正确的证书，并且其私钥也必须被客户端所持有。

对于客户端访问服务端时，你还需要配置客户端的SSL上下文，以信任服务端的证书。这通常涉及到导入服务端的公钥证书到客户端的truststore中。

请注意，这只是一个基本示例，根据你的具体环境和安全需求，你可能需要调整配置细节，例如SSL协议、加密算法等。

- 阅读更多 -

Qt连接加密的SQLite3数据库

System

2024-08-29

所有,数据库

在Qt中连接加密的SQLite3数据库，你需要使用SQLCipher，它是SQLite的一个加密版本。首先确保你的系统中已经安装了SQLCipher。

以下是一个简单的例子，展示如何在Qt中打开一个加密的SQLite3数据库：




#include <QSqlDatabase>
#include <QSqlError>
#include <QDebug>
 
int main(int argc, char *argv[])
{
    // 初始化Qt应用程序
    QApplication app(argc, argv);
 
    // 设置数据库类型
    QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
 
    // 设置数据库文件名（这里假设数据库文件名为"encrypted.db"）
    db.setDatabaseName("encrypted.db");
 
    // 打开数据库连接
    if (!db.open()) {
        qDebug() << "数据库打开失败：" << db.lastError().text();
        return -1;
    }
 
    // 设置数据库加密密钥
    db.exec("PRAGMA key = 'your-encryption-key';");
 
    // 这里可以进行数据库操作
 
    // 关闭数据库连接
    db.close();
 
    return 0;
}

在上面的代码中，你需要将your-encryption-key替换为你的实际加密密钥。当你尝试打开数据库时，SQLCipher会要求你提供密钥，只有正确的密钥才能够访问数据库。

请注意，这个例子假设你已经有一个加密的SQLite数据库文件。如果你还没有加密的数据库，你需要先用SQLCipher创建一个加密的数据库，例如使用SQLCipher的命令行工具来创建一个加密的数据库，并设置密钥。

- 阅读更多 -