Tech Blog

2024-09-06

在Spring Boot整合Redis多数据源时，通常需要定义多个RedisTemplate实例，每个实例连接不同的Redis数据库。以下是一个简化的例子，展示如何配置和使用两个Redis数据源。




@Configuration
public class RedisConfig {
 
    @Bean
    public LettuceConnectionFactory redis1ConnectionFactory() {
        return new LettuceConnectionFactory(new RedisStandaloneConfiguration("host1", 6379));
    }
 
    @Bean
    public LettuceConnectionFactory redis2ConnectionFactory() {
        return new LettuceConnectionFactory(new RedisStandaloneConfiguration("host2", 6379));
    }
 
    @Bean
    public RedisTemplate<String, Object> redis1Template() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redis1ConnectionFactory());
        return template;
    }
 
    @Bean
    public RedisTemplate<String, Object> redis2Template() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redis2ConnectionFactory());
        return template;
    }
}

接下来，可以创建一个RedisUtil类来封装对这些RedisTemplate的操作：




@Component
public class RedisUtil {
 
    @Autowired
    @Qualifier("redis1Template")
    private RedisTemplate<String, Object> redis1Template;
 
    @Autowired
    @Qualifier("redis2Template")
    private RedisTemplate<String, Object> redis2Template;
 
    public void setValueToRedis1(String key, Object value) {
        redis1Template.opsForValue().set(key, value);
    }
 
    public Object getValueFromRedis1(String key) {
        return redis1Template.opsForValue().get(key);
    }
 
    public void setValueToRedis2(String key, Object value) {
        redis2Template.opsForValue().set(key, value);
    }
 
    public Object getValueFromRedis2(String key) {
        return redis2Template.opsForValue().get(key);
    }
}

在这个例子中，我们定义了两个RedisTemplate实例，通过@Qualifier注解指定注入哪一个实例。RedisUtil类提供了简单的设置和获取值的方法，分别操作两个不同的Redis数据库。

- 阅读更多 -

MongoDB 未授权访问

System

2024-09-06

所有,数据库

报错解释：

MongoDB未授权访问错误通常表示客户端尝试连接到MongoDB服务器，但是没有提供正确的认证信息。这可能是因为没有启用认证，或者提供了错误的用户名和密码。

解决方法：

确认MongoDB是否已经启用了认证。你可以在MongoDB配置文件中查找security.authorization设置，或者通过运行db.getMongo().getSiblingDB("admin").auth()来检查是否需要认证。
如果启用了认证，请确保你使用正确的用户名和密码进行连接。你可以通过以下命令在admin数据库下进行认证：
```
use admin
db.auth("username", "password")
```

如果你是第一次设置用户和权限，你可能需要创建一个管理员用户：




use admin
db.createUser({
  user: "myUser",
  pwd: "myPassword",
  roles: [{ role: "userAdminAnyDatabase", db: "admin" }]
})

确保客户端连接字符串中包含了正确的认证信息。例如，在连接字符串中使用mongodb://username:password@host:port/database格式。
如果你正在使用MongoDB的可视化工具或者GUI，请确保在工具的设置中输入了正确的认证信息。
如果以上步骤都无法解决问题，请检查MongoDB服务器的日志文件，以获取更多关于认证失败的信息。

- 阅读更多 -

保姆级教程：SpringBoot 对接支付宝完成扫码支付，完整流程梳理！

System

2024-09-06

所有,java

以下是一个简化的示例，展示了如何在Spring Boot应用中对接支付宝完整的扫码支付流程：




@Configuration
public class AlipayConfig {
    @Value("${alipay.appId}")
    private String appId;
 
    @Value("${alipay.privateKey}")
    private String privateKey;
 
    @Value("${alipay.publicKey}")
    private String publicKey;
 
    @Value("${alipay.serverUrl}")
    private String serverUrl;
 
    @Value("${alipay.domain}")
    private String domain;
 
    // 提供获取配置属性的方法
    public String getAppId() {
        return appId;
    }
 
    // ... 其他配置属性的获取方法
}
 
@Service
public class AlipayService {
    @Autowired
    private AlipayConfig alipayConfig;
 
    public String startPay(String orderId, String totalAmount) throws AlipayApiException {
        AlipayTradePrecreateRequest request = new AlipayTradePrecreateRequest();
        // 设置商户订单信息
        JSONObject bizContent = new JSONObject();
        bizContent.put("out_trade_no", orderId);
        bizContent.put("total_amount", totalAmount);
        bizContent.put("subject", "商品标题");
        // ... 设置其他必要的参数
        request.setBizContent(bizContent.toString());
        // 使用SDK执行请求
        AlipayTradePrecreateResponse response = alipayClient.execute(request);
        if(response.isSuccess()){
            return response.getQrCode(); // 返回二维码图片的地址
        } else {
            // 处理错误
        }
    }
 
    // ... 其他支付相关的方法
}
 
@RestController
public class AlipayController {
    @Autowired
    private AlipayService alipayService;
 
    @GetMapping("/pay")
    public String startPay(@RequestParam("orderId") String orderId,
                           @RequestParam("totalAmount") String totalAmount) {
        try {
            return alipayService.startPay(orderId, totalAmount);
        } catch (AlipayApiException e) {
            // 异常处理
        }
    }
 
    // ... 其他接口方法
}

以上代码提供了一个简化的示例，展示了如何在Spring Boot应用中集成支付宝支付SDK，并实现扫码支付的基本流程。在实际应用中，你需要处理更多的细节，例如异常处理、安全性考虑（如参数签名验证）、日志记录、事务管理等。

- 阅读更多 -

Linux JAVA环境的搭建tomcat的部署（含多实例）

System

2024-09-06

所有,java

在Linux环境下搭建Java Web服务器Tomcat，并部署多个实例，可以按照以下步骤进行：

安装Java JDK




sudo apt-update
sudo apt install default-jdk

验证Java安装




java -version

下载Tomcat




wget https://dlcdn.apache.org/tomcat/tomcat-9/v9.0.65/bin/apache-tomcat-9.0.65.tar.gz

解压Tomcat




tar -xvzf apache-tomcat-9.0.65.tar.gz

多实例部署




cp -R apache-tomcat-9.0.65 /usr/local/tomcat9-instance1
cp -R apache-tomcat-9.0.65 /usr/local/tomcat9-instance2

修改每个实例的端口号，防止冲突
修改/usr/local/tomcat9-instance1/conf/server.xml中的端口号：




<Connector port="8080" protocol="HTTP/1.1" ... />
<Connector port="8009" protocol="AJP/1.3" ... />

修改/usr/local/tomcat9-instance2/conf/server.xml中的端口号，例如将HTTP端口改为8081：




<Connector port="8081" protocol="HTTP/1.1" ... />

并调整其他相关端口号，确保它们不会和其他实例或系统服务冲突。

启动Tomcat实例




/usr/local/tomcat9-instance1/bin/startup.sh
/usr/local/tomcat9-instance2/bin/startup.sh

检查Tomcat实例是否启动




ps aux | grep tomcat

配置防火墙（如果需要）




sudo ufw allow 8080/tcp
sudo ufw allow 8081/tcp

通过浏览器访问




http://<服务器IP>:8080
http://<服务器IP>:8081

以上步骤中，每个实例的端口号应该被修改以避免冲突。这样，你就可以在同一台Linux服务器上运行多个Tomcat实例了。

- 阅读更多 -

SpringBoot系列教程web篇Servlet 注册的四种姿势

System

2024-09-06

所有,java

在Spring Boot中，可以通过以下四种方式注册Servlet：

继承SpringBootServletInitializer类
使用ServletRegistrationBean注册
使用ServletComponentRegister注册
使用@WebServlet注解注册

下面是这四种方式的示例代码：

继承SpringBootServletInitializer类




public class MyServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        resp.getWriter().write("Hello, world");
    }
}
 
public class ServletInitializer extends SpringBootServletInitializer {
    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(ServletInitializer.class);
    }
 
    @Bean
    public ServletRegistrationBean myServlet() {
        return new ServletRegistrationBean(new MyServlet(), "/myServlet");
    }
}

使用ServletRegistrationBean注册




public class MyServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        resp.getWriter().write("Hello, world");
    }
}
 
@Configuration
public class ServletConfig {
    @Bean
    public ServletRegistrationBean myServlet() {
        return new ServletRegistrationBean(new MyServlet(), "/myServlet");
    }
}

使用@WebServlet注解注册




@WebServlet(name = "myServlet", urlPatterns = "/myServlet")
public class MyServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        resp.getWriter().write("Hello, world");
    }
}

使用ServletComponentRegister注册




@WebServlet(name = "myServlet", urlPatterns = "/myServlet")
public class MyServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        resp.getWriter().write("Hello, world");
    }
}
 
@Configuration
public class ServletConfig implements WebServletRegistry {
    @Override
    public void registerServlet(ServletRegistrationBean servletRegistrationBean) {
        servletRegistrationBean.setServlet(new MyServlet());
        servletRegistrationBean.addUrlMappings("/myServlet");
    }
}

以上四种方式均可以在Spring Boot应用中注册Servlet，具体使用哪一种取决于具体的应用场景和需求。

- 阅读更多 -

Spring Boot火车票订票购票票务系统设计与实现

System

2024-09-06

所有,java

由于原始代码较为复杂且涉及到火车票订票的具体业务逻辑，我们将提供核心的Spring Boot应用配置和服务层的简化示例。




// 火车票服务接口
public interface TicketService {
    Order queryOrder(String orderId);
    boolean isTicketLeft(String trainNumber, String from, String to);
    Order purchaseTicket(String trainNumber, String from, String to);
}
 
// 火车票服务实现
@Service
public class TicketServiceImpl implements TicketService {
 
    @Autowired
    private OrderRepository orderRepository;
 
    @Autowired
    private RestTemplate restTemplate;
 
    @Override
    public Order queryOrder(String orderId) {
        return orderRepository.findById(orderId).orElse(null);
    }
 
    @Override
    public boolean isTicketLeft(String trainNumber, String from, String to) {
        String url = "http://ts.sdo.com/train/left_ticket/?train_date=2023-03-01&station_train_code=" + trainNumber + "&from_station=" + from + "&to_station=" + to;
        String response = restTemplate.getForObject(url, String.class);
        // 根据响应结果判断是否有票
        return !"无".equals(response);
    }
 
    @Override
    public Order purchaseTicket(String trainNumber, String from, String to) {
        // 模拟下单操作
        Order order = new Order();
        order.setOrderId(UUID.randomUUID().toString());
        order.setTrainNumber(trainNumber);
        order.setFrom(from);
        order.setTo(to);
        orderRepository.save(order);
        return order;
    }
}
 
// 实体类Order
@Entity
public class Order {
    @Id
    private String orderId;
    private String trainNumber;
    private String from;
    private String to;
    // 省略getter和setter
}
 
// 仓库接口OrderRepository
public interface OrderRepository extends JpaRepository<Order, String> {
}
 
// 控制器类TicketController
@RestController
public class TicketController {
 
    @Autowired
    private TicketService ticketService;
 
    @GetMapping("/query_order")
    public Order queryOrder(@RequestParam String orderId) {
        return ticketService.queryOrder(orderId);
    }
 
    @GetMapping("/is_ticket_left")
    public boolean isTicketLeft(@RequestParam String trainNumber, @RequestParam String from, @RequestParam String to) {

System

2024-09-06

所有,redis

解释：

这个错误表明在尝试部署SmartAdmin项目时，遇到了与Redis服务的连接问题。Redis是一个开源的内存中数据结构存储系统，它可以用作数据库、缓存和消息代理等。如果应用程序配置错误，或者Redis服务未运行，或网络问题导致无法连接，都可能引发此类错误。

解决方法：

检查Redis服务是否正在运行：确保Redis服务已启动并且可以接受连接。在Windows上，可以通过服务管理工具或命令行（使用redis-server命令）来检查。
检查配置文件：确认应用程序的配置文件中Redis的连接信息（如主机名、端口号、密码等）是否正确。
检查网络连接：如果Redis服务在远程服务器上，确保应用服务器能够通过网络连接到Redis服务器的端口（默认为6379）。
防火墙和安全组设置：确保没有防火墙或安全组规则阻止访问Redis端口。
重新启动服务：如果配置和网络没有问题，尝试重新启动Redis服务和应用程序服务。
查看日志：检查应用程序和Redis服务器的日志文件，以获取更多错误信息，这可能会提供更具体的解决线索。

如果以上步骤无法解决问题，可能需要进一步的技术支持来诊断问题。

System

2024-09-06

所有,数据库

解释：

ModuleNotFoundError: No module named '_sqlite3' 这个错误表明Python在尝试导入名为 _sqlite3 的模块时未能找到。这个模块是Python标准库中的SQLite数据库接口，通常情况下它是与Python二进制包一起安装的。如果你遇到这个错误，可能是因为你的SQLite数据库接口没有正确安装，或者你使用的Python环境与你的系统Python环境不一致。

解决方法：

确保你使用的是系统Python环境，并且是通过系统包管理器安装的Python。如果你使用的是虚拟环境，请确保它是正确配置的，并且包含了标准库中的模块。
如果你使用的是Linux或macOS，尝试重新安装Python，或者确保你安装了sqlite3开发包。在Ubuntu或Debian系统上，你可以使用以下命令安装：
```
sudo apt-get install libsqlite3-dev
```
如果你使用的是Windows，确保你的Python安装器是最新的，并且在安装Python时勾选了SQLite作为可选功能。
如果你在使用特定的Python分发版（如Anaconda），尝试通过该分发版的包管理器更新或重新安装Python。
如果你在使用某些Python容器（如Docker），确保容器中包含了SQLite数据库和相应的开发库。
如果你已经尝试了上述方法都没有解决问题，可以尝试编译安装Python，并确保编译时包含了SQLite的支持。

在尝试上述解决方法时，请确保你的环境变量配置正确，并且你没有同时使用多个Python版本导致冲突。如果问题依然存在，可以考虑搜索相关的错误信息，查看是否有其他用户遇到了类似的问题，或者在Python社区寻求帮助。

- 阅读更多 -

Jenkins+Maven+Gitlab+Tomcat自动化构建打包+部署

System

2024-09-06

所有,java

以下是一个基于Jenkins的自动构建和部署的示例流程，使用Maven, GitLab和Tomcat:

安装配置Jenkins。
在Jenkins中安装必要的插件，如Maven插件、GitLab插件、Deploy to Container Plugin等。
配置全局设置，如Maven配置、GitLab认证信息等。
创建一个新的Jenkins项目，并配置：
- 源码管理：选择Git，并配置GitLab仓库地址和认证信息。
- 构建触发器：配置为当向GitLab仓库推送代码时自动构建。
- 构建环境：配置环境变量，如Maven的设置文件。
- 构建：Goals and options中配置Maven命令，如clean install。
- 后置构建操作：配置Deploy to Container，设置Tomcat的用户名、密码、应用上下文、包的URL和本地路径。

以下是一个简化的Jenkins Job配置示例：




// Jenkinsfile
pipeline {
    agent any
    stages {
        stage('Build') {
            steps {
                // 获取代码
                git 'git@gitlab.com:username/project.git'
                // 执行Maven构建
                sh 'mvn clean install'
            }
        }
        stage('Deploy') {
            steps {
                // 部署到Tomcat
                deploy war: 'target/project.war',
                        context: 'project',
                        container: 'tomcat8.example.com'
            }
        }
    }
    // 其他配置...
}

确保Jenkins具有对Tomcat和GitLab仓库的访问权限，并且Deploy to Container插件已正确配置。这样，当代码被推送到GitLab后，Jenkins将自动执行构建并将应用部署到Tomcat容器中。

- 阅读更多 -

Spring Boot 整合 Shiro ，两种方式全总结！

System

2024-09-06

所有,java

Spring Boot整合Shiro主要有两种方式：

使用Shiro Spring Boot Starter
手动配置

1. 使用Shiro Spring Boot Starter

首先，添加依赖到你的pom.xml：




<dependency>
    <groupId>org.apache.shiro</groupId>
    <artifactId>shiro-spring-boot-starter</artifactId>
    <version>版本号</version>
</dependency>

然后，在application.properties或application.yml中配置Shiro：




# 配置Shiro
shiro.sessionManager.globalSessionTimeout = 800000
shiro.unauthorizedUrl = /unauthorized
shiro.user.cookie = user
shiro.user.cookie.maxAge = 3600
shiro.user.cookie.path = /

2. 手动配置

在Spring Boot的配置类中添加Shiro配置：




@Configuration
public class ShiroConfig {
 
    @Bean
    public Realm realm() {
        // 配置你的Realm
        return new YourRealm();
    }
 
    @Bean
    public DefaultWebSecurityManager securityManager() {
        DefaultWebSecurityManager manager = new DefaultWebSecurityManager();
        manager.setRealm(realm());
        // 配置其他组件
        return manager;
    }
 
    @Bean
    public ShiroFilterFactoryBean shiroFilterFactoryBean(DefaultWebSecurityManager securityManager) {
        ShiroFilterFactoryBean factoryBean = new ShiroFilterFactoryBean();
        factoryBean.setSecurityManager(securityManager);
        // 配置过滤链
        return factoryBean;
    }
}

在application.properties或application.yml中配置Shiro：




# 配置Shiro
shiro.sessionManager.globalSessionTimeout = 800000
shiro.unauthorizedUrl = /unauthorized
shiro.user.cookie = user
shiro.user.cookie.maxAge = 3600
shiro.user.cookie.path = /

以上两种方式均可以整合Shiro到Spring Boot项目中，具体使用哪一种取决于你的项目需求和偏好。

- 阅读更多 -