Tech Blog

2024-09-02

所有,redis

Redis主从复制是一种数据复制的模式，其中一个Redis服务器（主节点）与其他Redis服务器（从节点）进行数据同步。数据是从主节点向从节点同步的，因此从节点只能提供读操作。

一主一从结构：一个主节点和一个从节点。

一主多从结构：一个主节点和多个从节点。

树形结构：主从结构可以通过添加从节点构成树形结构。

配置主从复制：

在从节点的redis.conf文件中添加如下配置：




slaveof <master-ip> <master-port>

如果主节点设置了密码，需要在从节点的redis.conf中添加：




masterauth <master-password>

重启Redis从节点服务使配置生效。

示例：

一主一从结构配置：

在从服务器的redis.conf文件中添加：




slaveof 192.168.1.100 6379

一主多从结构配置：

在每个从服务器的redis.conf文件中添加对应的主服务器IP和端口：




slaveof 192.168.1.100 6379

树形结构配置：

可以通过将一个从节点配置为另一个从节点的主节点来实现。例如，如果有两个从节点A和B，可以将从节点B设置为从节点A的从节点：

在从节点B的redis.conf文件中添加：




slaveof 192.168.1.101 6379

其中192.168.1.101是从节点A的IP，6379是从节点A的端口。

使用Java和Spring Integration构建企业集成解决方案

2024-09-02




import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.core.MessageProducer;
import org.springframework.integration.transformer.Transformer;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;
 
@Configuration
public class EnterpriseIntegrationSolution {
 
    @ServiceActivator(inputChannel = "toUpperCaseChannel")
    public MessageHandler upperCaseService() {
        return message -> {
            String payload = (String) message.getPayload();
            message = org.springframework.integration.message.MessageBuilder
                    .withPayload(payload.toUpperCase())
                    .copyHeaders(message.getHeaders())
                    .build();
        };
    }
 
    @Bean
    public MessageChannel toUpperCaseChannel() {
        return new DirectChannel();
    }
 
    @Bean
    public MessageChannel outputChannel() {
        return new DirectChannel();
    }
 
    @Bean
    @ServiceActivator(inputChannel = "toUpperCaseChannel")
    public MessageHandler logger() {
        return message -> {
            try {
                System.out.println("Received message: " + message);
            } catch (Exception e) {
                throw new MessagingException(message, "Failed to handle message", e);
            }
        };
    }
 
    @Bean
    public MessageProducer customTransformerProducer() {
        Transformer transformer = message -> {
            String payload = (String) message.getPayload();
            return message.getHeaders().isEmpty() ? payload : payload.toUpperCase();
        };
        return MessageProducerSupport.fromTransformer(transformer, "outputChannel");
    }
}

这个代码示例展示了如何在Spring Integration中定义一个简单的服务，它接收一个字符串，将其转换为大写，并打印出来。同时，它也展示了如何使用MessageProducerSupport.fromTransformer来创建一个转换消息的生产者。这个解决方案提供了一个基本的参考框架，可以根据实际需求进行扩展和定制。

Vue3+ElementPlus编辑表格数据（指定行变为input）

2024-09-02

所有,elementui

在Vue3和ElementPlus中，可以使用组件el-table和el-input-number来实现指定行编辑。以下是一个简单的例子，展示如何将表格中的特定行转换为可编辑的输入框：




<template>
  <el-table :data="tableData" style="width: 100%">
    <el-table-column prop="date" label="日期" width="180"></el-table-column>
    <el-table-column prop="name" label="姓名" width="180"></el-table-column>
    <el-table-column label="操作">
      <template #default="{ row, $index }">
        <el-input-number
          v-if="editIndex === $index"
          v-model="row.amount"
          :min="0"
          @keyup.enter="confirmEdit($index)"
        ></el-input-number>
        <span v-else>{{ row.amount }}</span>
        <el-button
          v-if="editIndex !== $index"
          type="text"
          @click="editRow($index, row)"
        >
          编辑
        </el-button>
        <el-button
          v-else
          type="text"
          @click="confirmEdit($index)"
        >
          确认
        </el-button>
      </template>
    </el-table-column>
  </el-table>
</template>
 
<script setup>
import { ref } from 'vue';
 
const tableData = ref([
  { date: '2021-05-03', name: '张三', amount: 20 },
  { date: '2021-05-04', name: '李四', amount: 30 },
  // ...更多数据
]);
 
const editIndex = ref(null);
 
function editRow(index, row) {
  editIndex.value = index;
}
 
function confirmEdit(index) {
  editIndex.value = null;
}
</script>

在这个例子中，我们使用了el-table-column的template #default来自定义列的内容。通过editIndex来跟踪当前处于编辑状态的行。当用户点击编辑按钮时，我们将editIndex设置为当前行的索引，从而显示el-input-number组件。用户可以直接在输入框中编辑数值，并在按下键盘的Enter键或点击确认按钮后结束编辑状态。

springcloud集成Spring Security

2024-09-02

Spring Cloud 整合 Spring Security 的方法有很多种，以下是一个简单的例子，使用 Spring Cloud Security 来保护服务间通信的安全。

在你的 Spring Cloud 项目中添加依赖：




<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-security</artifactId>
</dependency>

在你的 application.properties 或 application.yml 配置文件中设置安全属性，例如基本认证的用户名和密码：




# application.properties
spring.security.user.name=user
spring.security.user.password=password

或者使用加密的方式设置密码。

如果你想要对服务间调用进行认证，可以在调用方和服务端的 Spring Security 配置中设置相同的用户和角色。
在你的 WebSecurityConfigurerAdapter 实现中，你可以配置更复杂的安全策略，例如使用 JWT 或者 OAuth2。




@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
 
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http
            .csrf().disable()
            .authorizeRequests()
            .anyRequest().authenticated()
            .and()
            .httpBasic();
    }
 
    @Autowired
    public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception {
        auth
            .inMemoryAuthentication()
            .withUser("user").password("{noop}password").roles("USER");
    }
}

确保你的服务正确地使用了 Spring Cloud 的安全机制，并且在必要时对服务间调用进行了适当的认证。

这只是整合 Spring Security 的一个基本例子，实际应用中可能需要更复杂的配置，如使用数据库来存储用户凭据，或者使用其他认证机制如OAuth2。

logstash同步es

2024-09-02

所有,数据库

Logstash 是一个强大的数据处理管道，可以同步数据到 Elasticsearch。以下是一个基本的 Logstash 配置文件示例，它从 stdin 读取数据，并将其同步到 Elasticsearch。

创建一个名为 logstash-simple.conf 的文件，并填写以下内容：




input {
  stdin {}
}
 
filter {
  # 添加过滤器配置（如果需要）
}
 
output {
  elasticsearch {
    hosts => ["http://localhost:9200"]
    index => "logstash-%{+YYYY.MM.dd}"
    # 如果需要，添加其他 Elasticsearch 输出配置
  }
}

在终端中运行 Logstash 并指定配置文件：




bin/logstash -f logstash-simple.conf

这个配置文件定义了一个 input 来从标准输入读取数据，一个 filter 用于数据处理（这个例子中没有定义过滤器，可以根据需要添加），以及一个 output 将数据发送到 Elasticsearch。

确保 Elasticsearch 正在运行，并且 Logstash 有适当的权限来访问 Elasticsearch 实例。

当你在终端中输入文本并按下回车键时，Logstash 会将数据发送到 Elasticsearch，并将其索引到相应的索引中。

Linux系统下tomcat服务自动重启

2024-09-02

要在Linux系统下配置Tomcat服务自动重启，可以使用以下方法：

使用Shell脚本定期检查Tomcat进程，如果发现Tomcat已经停止，则重新启动它。

创建一个名为restart_tomcat.sh的Shell脚本，内容如下：




#!/bin/bash
 
# 定义Tomcat的安装目录
CATALINA_HOME=/opt/tomcat
 
# 检查Tomcat进程是否存在
if [ `ps -ef | grep "org.apache.catalina.startup.Bootstrap" | grep -v "grep" | wc -l` -eq 0 ]; then
    echo "Tomcat is not running, restarting now..."
    $CATALINA_HOME/bin/startup.sh
else
    echo "Tomcat is running."
fi

给脚本执行权限：




chmod +x restart_tomcat.sh

使用Crontab计划任务定时执行该脚本。

编辑Crontab任务列表：




crontab -e

添加以下行来每隔一小时检查一次Tomcat是否运行，如果已停止则重启：




0 * * * * /path/to/restart_tomcat.sh > /dev/null 2>&1

这行的意思是每小时的第0分钟执行脚本。/path/to/restart_tomcat.sh是你的restart_tomcat.sh脚本的完整路径。

确保Crontab配置正确无误，并保存退出。Crontab会自动按照设定的时间运行你的脚本。

探索Gradle Tomcat插件：便捷的Web应用部署解决方案

2024-09-02




// 引入Gradle Tomcat插件
plugins {
    id 'war'
    id 'com.bmuschko.tomcat' version '2.6'
}
 
// 配置Tomcat服务器
tomcat {
    // 定义一个服务器实例
    server {
        // 端口设置
        HTTPPort = 8080
        // 应用路径设置
        contextPath = 'myapp'
    }
}
 
// 定义WAR任务
war {
    // 打包时排除不需要的文件或目录
    exclude '**/.*', '**/*/.*', '**/.*/**', '**/.*/**/.*/**'
}
 
// 依赖配置
dependencies {
    // 添加项目所需依赖
    implementation 'org.apache.tomcat.embed:tomcat-embed-core:9.0.41'
}
 
// 执行Gradle任务时，可以使用如下命令启动Tomcat并部署应用
// gradle tomcatRun

这个示例展示了如何在Gradle构建脚本中配置Tomcat插件，以便自动化地启动Tomcat服务器并部署Web应用。通过简单的命令gradle tomcatRun，开发者可以快速启动服务器进行测试。这种方式极大地提高了开发效率，是现代Web开发实践中的一个常用工具。

Spring Boot常用依赖

2024-09-02

Spring Boot是一个用于简化Spring应用开发的框架，它提供了一系列的starter POMs（也就是依赖管理的模块），用来简化项目配置。以下是一些常用的Spring Boot starter依赖：

spring-boot-starter：这是Spring Boot的核心starter，包含了自动配置、日志和YAML。
spring-boot-starter-web：包含了spring-boot-starter的所有内容，并且添加了Tomcat和Spring MVC支持，用于创建web应用程序。
spring-boot-starter-data-jpa：包含了spring-boot-starter-data-jpa的所有内容，并添加了Hibernate支持，用于数据库访问。
spring-boot-starter-test：包含了用于测试Spring Boot应用程序的依赖，如JUnit、Spring Test、Mockito和JSONPath。
spring-boot-starter-security：提供了Spring Security的支持，用于身份验证和授权。
spring-boot-starter-aop：提供了Spring AOP的支持，用于面向切面编程。

在Maven中，你可以在pom.xml中添加这些依赖，例如：




<dependencies>
    <!-- Web 应用依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
 
    <!-- JPA 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
 
    <!-- 测试依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

在Gradle中，你可以在build.gradle中添加这些依赖，例如：




dependencies {
    // Web 应用依赖
    implementation 'org.springframework.boot:spring-boot-starter-web'
 
    // JPA 依赖
    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 
    // 测试依赖
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

这些依赖可以帮助你快速搭建一个Spring Boot应用程序，减少配置和代码量。

spring boot学习第六篇:SpringBoot 集成WebSocket详解

2024-09-02




import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.*;
 
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/myWebSocket")
            .setAllowedOrigins("*");
    }
 
    @Bean
    public WebSocketHandler myHandler() {
        // 实现自定义的WebSocketHandler
        return new MyCustomWebSocketHandler();
    }
}
 
// 自定义的WebSocket处理器
public class MyCustomWebSocketHandler implements WebSocketHandler {
    // 实现WebSocketHandler相关的方法
    // ...
}

这个代码示例展示了如何在Spring Boot应用程序中配置和注册一个自定义的WebSocket处理器。首先，我们创建了一个实现了WebSocketConfigurer接口的配置类。在这个类中，我们注册了一个指向/myWebSocket路径的处理器，并设置了允许来自任何origin的WebSocket连接。然后，我们定义了一个名为MyCustomWebSocketHandler的类，该类实现了WebSocketHandler接口，并且可以处理WebSocket的消息接收、发送等逻辑。

Redis数据迁移

2024-09-02

所有,redis

Redis数据迁移通常涉及以下几种方法：

使用SAVE或BGSAVE命令手动生成RDB文件并将其复制到目标服务器。
使用DUMP和RESTORE命令直接在Redis实例间迁移键。
使用redis-cli --pipe来导出数据然后导入到另一个Redis实例。
使用第三方工具如redis-shake或redis-migrate-tool。

以下是使用DUMP和RESTORE命令迁移键的例子：




# 在源Redis服务器上，为要迁移的键使用DUMP命令
redis-cli DUMP mykey > mykey.dump

# 将dump文件传输到目标Redis服务器
scp mykey.dump user@targetserver:/path/to/mykey.dump

# 在目标Redis服务器上，使用RESTORE命令加载键
redis-cli -h targetserver RESTORE mykey 0 /path/to/mykey.dump

请注意，这些方法可能需要额外的步骤，如调整配置文件或设置正确的网络连接，并且在生产环境中执行时应格外小心。