Tech Blog

Spring Cloud 学习系列：消息总线自动刷新配置——Spring Cloud Bus

2024-09-06




@Configuration
@EnableAutoConfiguration
@EnableConfigServer
@EnableCircuitBreaker
@EnableDiscoveryClient
@EnableFeignClients
@EnableHystrixDashboard
@EnableTurbine
@SpringBootApplication
public class SpringCloudApplication {
 
    // ... 其他配置类定义
 
    @Autowired
    private Environment environment;
 
    @Autowired
    private DiscoveryClient discoveryClient;
 
    @Autowired
    private ServerProperties serverProperties;
 
    @Autowired
    private SpringApplication springApplication;
 
    @Autowired
    private SimpleMonitorController simpleMonitorController;
 
    @Autowired
    private TurbineDataMonitorController turbineDataMonitorController;
 
    @Autowired
    private HystrixMetricsStreamController hystrixMetricsStreamController;
 
    @Autowired
    private DashboardController dashboardController;
 
    @Autowired
    private FeignClientWrapper feignClientWrapper;
 
    @Autowired
    private ConfigServerWrapper configServerWrapper;
 
    @Autowired
    private ConfigClientProperties configClientProperties;
 
    @Autowired
    private ConfigServerProperties configServerProperties;
 
    @Autowired
    private ConfigClientHealthIndicator configClientHealthIndicator;
 
    @Autowired
    private ConfigServerHealthIndicator configServerHealthIndicator;
 
    @Autowired
    private DiscoveryClientHealthIndicator discoveryClientHealthIndicator;
 
    @Autowired
    private FeignClientHealthIndicator feignClientHealthIndicator;
 
    @Autowired
    private HystrixHealthIndicator hystrixHealthIndicator;
 
    @Autowired
    private TurbineHealthIndicator turbineHealthIndicator;
 
    @Autowired
    private RefreshScope refreshScope;
 
    @Autowired
    private ConfigClientRetryInterceptor configClientRetryInterceptor;
 
    @Autowired
    private ConfigClientRequestInterceptor configClientRequestInterceptor;
 
    @Autowired
    private ConfigClientFeignConfiguration configClientFeignConfiguration;
 
    @Autowired
    private ConfigClientAutoConfiguration configClientAutoConfiguration;
 
    @Autowired
    private ConfigServerAutoConfiguration configServerAutoConfiguration;
 
    @Autowired
    private ConfigClientSecurityAutoConfiguration configClientSecurityAutoConfiguration;
 
    @Autowired
    private ConfigServerSecurityAutoConfiguration configServerSecurityAutoConfiguration;
 
    @Autowired
    private ConfigClientNamespaceAutoConfiguration

- 阅读更多 -

SpringBoot整合sa-token，jwt登录及拦截器鉴权Demo

System

2024-09-06

所有,java




import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
@Configuration
public class SaTokenConfig implements WebMvcConfigurer {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        // 拦截所有请求，通过判断是否携带token和是否登录来进行鉴权
        registry.addInterceptor(new LoginInterceptor())
                .addPathPatterns("/**")
                .excludePathPatterns("/login", "/register"); // 登录和注册接口不需要鉴权
    }
}
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.web.servlet.HandlerInterceptor;
 
public class LoginInterceptor implements HandlerInterceptor {
 
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        // 从http头中获取token
        String token = request.getHeader("Authorization");
        // 使用sa-token进行鉴权
        boolean login = StpUtil.checkToken(token, "jwt");
        if (login) {
            return true; // 鉴权通过
        } else {
            // 鉴权失败，返回错误信息
            SaResult.error("登录失效或身份验证过期，请重新登录").setErrorType(ErrorType.LOGIN_TIMEOUT).write(response);
            return false;
        }
    }
}

这个代码示例展示了如何在Spring Boot项目中使用sa-token进行登录鉴权。首先，我们定义了一个SaTokenConfig配置类，实现了WebMvcConfigurer接口，在其中注册了一个自定义的LoginInterceptor拦截器，拦截所有请求，并排除登录和注册接口。在preHandle方法中，我们通过获取请求头中的Authorization来获取jwt token，并使用StpUtil.checkToken方法来进行鉴权。如果鉴权失败，我们返回错误信息给客户端。

- 阅读更多 -

基于spring boot技术的签到管理系统的设计与实现

System

2024-09-06

所有,java

以下是一个基于Spring Boot的签到管理系统的核心功能实现的示例代码。




// 引入Spring Boot相关依赖
import org.springframework.boot.*;
import org.springframework.boot.autoconfigure.*;
import org.springframework.web.bind.annotation.*;
 
@RestController
@EnableAutoConfiguration
public class SignInController {
 
    // 模拟数据库存储签到记录
    private Map<String, Boolean> signInRecords = new HashMap<>();
 
    // 签到接口
    @PostMapping("/signin")
    public String signIn(@RequestParam("userId") String userId) {
        if (signInRecords.containsKey(userId)) {
            return "已经签到";
        }
        signInRecords.put(userId, true);
        return "签到成功";
    }
 
    // 获取签到结果接口
    @GetMapping("/signin/result")
    public String getSignInResult(@RequestParam("userId") String userId) {
        if (signInRecords.containsKey(userId)) {
            return "已经签到";
        }
        return "未签到";
    }
 
    // 主函数，启动Spring Boot应用
    public static void main(String[] args) {
        SpringApplication.run(SignInController.class, args);
    }
}

这段代码定义了一个简单的Spring Boot应用，包含签到和获取签到结果的接口。它使用了@RestController来创建REST API，@EnableAutoConfiguration来自动配置Spring Boot应用，并且使用@PostMapping和@GetMapping注解来映射HTTP请求到具体的处理方法。在实际应用中，签到记录需要持久化到数据库中，并可能需要更复杂的用户权限控制。

- 阅读更多 -

【SpringCloud】Nacos配置管理和Feign远程调用

System

2024-09-06

所有,java

以下是一个简化的示例，展示了如何在Spring Cloud应用中使用Nacos作为配置中心，以及如何使用Feign进行远程服务调用。

引入依赖（pom.xml）：




<dependencies>
    <!-- Spring Cloud Alibaba Nacos Config -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    </dependency>
    <!-- Spring Cloud Alibaba Nacos Discovery -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!-- Spring Cloud OpenFeign -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
</dependencies>

配置文件（bootstrap.properties 或 application.yml）：




spring:
  cloud:
    nacos:
      config:
        server-addr: 127.0.0.1:8848 # Nacos Server 地址
        namespace: 4f1e2b8d-8aa3-4967-a21d-17d217061959 # Nacos 命名空间，可选
        group: DEFAULT_GROUP # Nacos 配置分组，可选
        file-extension: yaml # 配置文件后缀名，可选

使用Nacos作为配置中心的配置类：




@Configuration
public class NacosConfig {
    @Value("${useLocalCache:false}")
    private boolean useLocalCache;
 
    @Bean
    public ConfigService nacosConfigService(Properties properties) throws NacosException {
        return ConfigFactory.createConfigService(properties);
    }
 
    @Bean
    public Properties nacosProperties() {
        Properties properties = new Properties();
        properties.put("serverAddr", "127.0.0.1:8848"); // Nacos Server 地址
        properties.put("namespace", "4f1e2b8d-8aa3-4967-a21d-17d217061959"); // Nacos 命名空间，可选
        properties.put("group", "DEFAULT_GROUP"); // Nacos 配置分组，可选
        return properties;
    }
}

使用Feign进行远程服务调用的接口和使用示例：




@FeignClient(name = "remote-service", url = "${remote.s

- 阅读更多 -

深入理解 MyBatis-Plus 批量保存方法

System

2024-09-06

所有,java




import com.baomidou.mybatisplus.extension.service.IService;
import java.util.List;
 
// 假设有一个User实体类和对应的UserMapper
public interface UserService extends IService<User> {
    // 这里可以添加一些业务方法
}
 
// 实现类
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
    // 实现IService中的方法，或添加自定义业务方法
}
 
// 使用UserService进行批量保存
@Autowired
private UserService userService;
 
public void batchInsertUsers(List<User> users) {
    // 使用MyBatis-Plus提供的saveBatch方法进行批量保存
    boolean success = userService.saveBatch(users);
    if (success) {
        System.out.println("批量保存用户成功！");
    } else {
        System.out.println("批量保存用户失败！");
    }
}

这个代码示例展示了如何在MyBatis-Plus中使用saveBatch方法来批量保存数据。首先定义了一个服务接口UserService，然后实现了这个接口的UserServiceImpl类，在这个类中使用了saveBatch方法。最后，在一个方法batchInsertUsers中，通过注入UserService，使用saveBatch方法来批量插入用户数据。

- 阅读更多 -

Oracle create table 语句转换为 HIVE create table语句

System

2024-09-06

所有,数据库

Oracle的CREATE TABLE语句和Hive的CREATE TABLE语句在语法上有显著的不同。以下是一个简单的转换例子：

假设Oracle中有以下表定义：




CREATE TABLE employees (
    employee_id NUMBER(6) NOT NULL,
    first_name VARCHAR2(20),
    last_name VARCHAR2(25) NOT NULL,
    email VARCHAR2(25) NOT NULL,
    phone_number VARCHAR2(15),
    hire_date DATE NOT NULL,
    job_id VARCHAR2(10) NOT NULL,
    salary NUMBER(8,2),
    commission_pct NUMBER(2,2),
    manager_id NUMBER(6),
    department_id NUMBER(4)
);

转换为Hive的SQL语句如下：




CREATE TABLE employees (
    employee_id INT NOT NULL,
    first_name STRING,
    last_name STRING NOT NULL,
    email STRING NOT NULL,
    phone_number STRING,
    hire_date DATE NOT NULL,
    job_id STRING NOT NULL,
    salary DECIMAL(8,2),
    commission_pct DECIMAL(2,2),
    manager_id INT,
    department_id INT
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ',' -- 这里需要根据实际的分隔符来设定
STORED AS TEXTFILE; -- 可以根据需要选择不同的文件格式，如：SEQUENCEFILE, RCFILE, ORC等

注意事项：

Hive不支持NUMBER类型，使用DECIMAL或者适当的整型类型如INT。
Hive中的字符串类型使用STRING。
Hive不支持DATE数据类型，通常使用字符串或者TIMESTAMP。
Hive表的行格式和文件格式需要指定，默认使用逗号,作为字段分隔符，可以根据实际情况调整。
根据数据量和查询需求选择合适的文件格式和压缩方式以优化性能。

- 阅读更多 -

【Vuex+ElementUI】Vuex中取值存值以及异步加载的使用

System

2024-09-06

所有,elementui




<template>
  <el-select v-model="selectedValue" placeholder="请选择">
    <el-option
      v-for="item in options"
      :key="item.value"
      :label="item.label"
      :value="item.value">
    </el-option>
  </el-select>
</template>
 
<script>
export default {
  data() {
    return {
      selectedValue: '', // 绑定选择器的值
      options: [] // 下拉列表选项
    }
  },
  created() {
    this.fetchOptions(); // 创建组件时获取下拉列表选项
  },
  methods: {
    fetchOptions() {
      // 异步获取下拉列表选项
      this.$store.dispatch('getOptions').then(options => {
        this.options = options;
      }).catch(error => {
        console.error('获取下拉列表选项失败:', error);
      });
    }
  }
}
</script>

在这个例子中，我们使用了el-select和el-option组件来构建下拉列表，并通过Vuex的action来异步获取下拉列表的选项。选项存储在组件的options数组中，并绑定到el-option的v-for指令。用户选择的值绑定到selectedValue，它将与Vuex store中的状态进行同步。

- 阅读更多 -

Spring File Storage（文件的对象存储）框架基本使用指南

System

2024-09-06

所有,java




import org.springframework.core.io.Resource;
import org.springframework.core.io.UrlResource;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.io.InputStream;
 
// 假设我们已经有了配置好的StorageService实例
@Autowired
private StorageService storageService;
 
public void handleFileUpload(String fileName, InputStream inputStream) {
    try {
        // 保存文件到存储服务
        storageService.store(inputStream, fileName);
 
        // 获取文件的Path对象
        Path path = storageService.load(fileName);
 
        // 获取文件的Resource对象
        Resource resource = storageService.loadAsResource(fileName);
 
        // 处理文件的URL资源
        URL url = resource.getURL();
        // 或者使用UrlResource
        UrlResource urlResource = new UrlResource(url.toExternalForm());
 
        // 其他业务逻辑...
    } catch (Exception e) {
        // 异常处理逻辑...
    }
}

这个代码示例展示了如何在Spring应用中使用StorageService来存储、加载和获取文件资源。它演示了如何注入服务实例，如何处理文件上传，以及如何操作存储的文件。注意，异常处理是必要的，因为文件操作可能会失败。

System

2024-09-06

所有,elementui

在Vue项目中使用ElementUI的el-table组件并导出复杂的Excel表格（包括多级表头和合并单元格），可以使用xlsx库来实现。以下是一个简化的例子：

安装xlsx库：




npm install xlsx file-saver

在Vue组件中使用xlsx库导出带有多级表头和合并单元格的Excel表格：




<template>
  <div>
    <el-button @click="exportExcel">导出Excel</el-button>
    <el-table
      ref="multiHeaderTable"
      :data="tableData"
      style="width: 100%">
      <!-- 表格内容 -->
    </el-table>
  </div>
</template>
 
<script>
import XLSX from 'xlsx';
import { saveAs } from 'file-saver';
 
export default {
  data() {
    return {
      tableData: [
        // 数据源
      ],
    };
  },
  methods: {
    exportExcel() {
      // 通过select获取DOM元素，转换为工作表
      const wb = XLSX.utils.table_to_book(document.querySelector('#multiHeaderTable'));
      // 生成Excel的配置项
      const wbout = XLSX.write(wb, { bookType: 'xlsx', bookSST: true, type: 'array' });
      try {
        // 使用Blob进行导出
        const blob = new Blob([wbout], { type: 'application/octet-stream' });
        saveAs(blob, 'export.xlsx');
      } catch (e) {
        if (typeof console !== 'undefined') console.error(e, wbout);
      }
      return wbout;
    },
  },
};
</script>

在上述代码中，exportExcel方法通过xlsx的utils.table_to_book函数将el-table转换为工作表，然后使用XLSX.write方法将工作表写入到新的文件中，并使用saveAs方法从浏览器下载这个文件。

注意：el-table中的数据应该是预先格式化好的，以便xlsx能正确地读取和导出多级表头和合并单元格。

此代码示例假设tableData已经按照需求填充了正确的数据，并且el-table组件已经在模板中正确配置。在实际应用中，你需要根据自己的数据结构和表格配置调整代码。

- 阅读更多 -

Mongodb试题--数据库分类与安装、操作

System

2024-09-06

所有,数据库

MongoDB是一个基于分布式文件存储的开源数据库系统，旨在为WEB应用提供高性能、易部署、高扩展性的数据存储解决方案。MongoDB将数据存储为一个文档，数据结构由键值(key=>value)对组成。字段值可以包含其他文档，数组及文档数组。

分类：
MongoDB是一个非关系型数据库(NoSQL), 主要用于处理大量的文档型数据。

安装：

Windows:




https://www.mongodb.com/try/download/community
下载后，解压缩并运行mongod.exe。

Linux:
```
sudo apt-get install -y mongodb
```
MacOS:
```
brew install mongodb
```

操作：

启动MongoDB服务：
```
mongod
```
连接到MongoDB实例：
```
mongo
```

创建/插入文档：




db.collection.insertOne({ key: 'value' })

查询文档：
```
db.collection.find({ key: 'value' })
```

更新文档：




db.collection.updateOne({ key: 'value' }, { $set: { key: 'new_value' } })

删除文档：




db.collection.deleteOne({ key: 'value' })

注意：以上操作需要先启动MongoDB服务，并通过mongo命令连接到数据库。

以上是MongoDB的基本分类、安装和操作示例，实际应用中可能需要根据具体需求进行更复杂的操作和配置。

- 阅读更多 -