发表于 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
<dependencies>
	<dependency>
		<groupId>com.nbcb.pluto.pay</groupId>
		<artifactId>nbcb-pluto-pay-sdk</artifactId>
		<version>1.0.1</version>
		<scope>system</scope>
		<systemPath>${basedir}/lib/nbcb-pluto-pay-sdk-1.0.1.jar</systemPath>
	</dependency>
</dependencies>

<build>
	<plugins>
		<plugin>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-maven-plugin</artifactId>
			<configuration>
				<includeSystemScope>true</includeSystemScope>
			</configuration>
		</plugin>
	</plugins>
	<finalName>XXX</finalName>
</build>

发表于

后端接收不到前端自定义Header

在拦截器中添加response.setHeader("Access-Control-Expose-Headers", 自定义Header);

前端接收不到后端自定义Header

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
@Component
public class HeaderInterceptor implements HandlerInterceptor {


    public static final String OPTIONS = "OPTIONS";


    /**
     * 跨域获得自定义header
     *
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        response.setHeader("Access-Control-Allow-Origin", "*");
        // Access-Control-Allow-Credentials为true，那么Origin不能为*
        response.setHeader("Access-Control-Allow-Credentials", "false");
        response.setHeader("Access-Control-Allow-Methods", "GET, HEAD, POST, PUT, PATCH, DELETE, OPTIONS");
        response.setHeader("Access-Control-Max-Age", "86400");
        response.setHeader("Access-Control-Allow-Headers", "token");
        if (OPTIONS.equals(request.getMethod())) {
            response.setStatus(HttpStatus.NO_CONTENT.value());
            return false;
        }
        return true;
    }
}


如果遇到上述问题，后端如果设置了response.setHeader("Access-Control-Allow-Credentials", "false");,那么记得前端需要添加

1
2
3
4
axios({
  ......
  withCredentials: false
})

发表于

elasticsearch注意事项

安装elasticsearch教程

注意

  • elasticsearch对应http的端口是9200，对应java的端口是9300
  • cluster-name为你打开9200端口后页面显示的数据

spring-boot-starter-data-elasticsearch

不清楚原因为啥在yml配置失效，参考文档使用JavaBean的方式成功

1
2
3
4
5
6
7
8
9
10
11
12
13
@Configuration
public class RestClientConfig extends AbstractElasticsearchConfiguration {
    @Override
    @Bean
    public RestHighLevelClient elasticsearchClient() {

        final ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                .connectedTo("192.168.0.158:9200")
                .build();

        return RestClients.create(clientConfiguration).rest();
    }
}

发表于

minIO文档

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
// 上传图片 返回图片url
@RequestMapping(value = "/uploadFile",consumes = "multipart/form-data")
public ApiResult uploadFile(MultipartFile[] files) {
    List<String> imgUrlList = new ArrayList<>();
    try {
        MinioClient minioClient = new MinioClient(minoUrl, accessKey, secretKey);
        // 检查存储桶是否已经存在
        boolean isExist = minioClient.bucketExists(bucketName);
        if (isExist) {
            log.error("Bucket already exists.");
        } else {
            // 创建一个名为asiatrip的存储桶，用于存储照片的zip文件。
            minioClient.makeBucket(bucketName);
        }
        for (MultipartFile file : files) {
            // 图片名称
            String fileName = file.getOriginalFilename();
            // 压缩图片
            BufferedImage image = Thumbnails.of(file.getInputStream()).scale(0.8f).outputQuality(1.0f).asBufferedImage();
            InputStream inputStream = ImageUtil.bufferedImageToInputStream(image);
            // 使用putObject上传一个文件到存储桶中。
            assert inputStream != null;
            minioClient.putObject(bucketName, fileName, inputStream, inputStream.available(), "application/octet-stream");
            String url = minioClient.getObjectUrl(bucketName, fileName);
            log.info("图片url==========>" + url);
            imgUrlList.add(url);
        }
    } catch (Exception e) {
        throw new ApiException(ApiResult.errorWith(ResultCodeEnum.IMG_FAIL,e.getMessage()));
    }
    return ApiResult.resultWith(ResultCodeEnum.SUCCESS, imgUrlList);
}

注意

需要添加如下设置，否则图片不可见

发表于

原先

列表查询时，如果关联多张表，我会在sql中关联表进行查询

新思路

将不同的表，根据我所需要的字段进行查询，先放在对应的Map中，需要的时候从map中取值即可

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
// 封装品牌、分类、供货商查询信息
Set<Long> brandIds = Sets.newHashSet();
Set<Long> categoryIds = Sets.newHashSet();
Set<Long> supplierIds = Sets.newHashSet();
Set<Long> skuIds = Sets.newHashSet();
pages.getContent().forEach(item -> {
    brandIds.add(item.getBrandId());
    categoryIds.add(item.getCategoryId());
    categoryIds.add(item.getSubCategoryId());
    supplierIds.add(item.getSupplierId());
    skuIds.add(item.getSkuId());
});
Map<Long, Brand> brandMap = brandService.getBrandMap(brandIds);
Map<Long, Category> categoryMap = categoryService.getCategoryMap(categoryIds);
Map<Long, Supplier> supplierMap = supplierService.getSupplierMap(supplierIds);
Map<Long, Long> stockMap = storeSkuStockService.getSkuStockMap(Constants.YUN_CANG_ID, skuIds);
// 组装结果信息
    pages.getContent().forEach(item -> {
    SysStoreSkuDTO dto = new SysStoreSkuDTO();
    Supplier supplier = supplierMap.get(item.getSupplierId());
    if (supplier != null) {
        dto.setSupplierName(supplier.getSupplierName());
    }
    Long stock = stockMap.get(item.getSkuId());
    dto.setStock(stock == null ? 0 : stock);
    Brand brand = brandMap.get(item.getBrandId());
    dto.setBrandName(brand == null ? "" : brand.getBrandName());
    Category category = categoryMap.get(item.getCategoryId());
    Category subCategory = categoryMap.get(item.getSubCategoryId());
    dto.setCategoryName(category == null ? "" : category.getCategoryName());
    dto.setSubCategoryName(subCategory == null ? "" : subCategory.getCategoryName());
    dtoList.add(dto);
});

发表于

参考文章

  • 检查是否已经安装MySQL
1
2
3
4
5
6
# 运行命令检查系统中是否存在MySQL 或者 MariaDB
rpm -qa | grep mysql
rpm -qa | grep mariadb
# 如若在，则执行以下命令删除
rpm -e 软件名    #注意：这里的软件名必须包含软件的版本信息
rpm -e --nodeps 软件名   #卸载不成功时使用此命令强制卸载
  • 安装MySQL
1
2
3
4
5
6
7
8
9
10
11
yum install -y libaio-*       #安装依赖

mkdir -p /usr/local/mysql     #创建mysql安装目录

cd /usr/local/src             #进入软件压缩包管理区域

wget http://zy-res.oss-cn-hangzhou.aliyuncs.com/mysql/mysql-5.7.17-linux-glibc2.5-x86_64.tar.gz 
                              #在线下载mysql安装包
tar -xzvf mysql-5.7.17-linux-glibc2.5-x86_64.tar.gz
                              #在线解压mysql安装包
mv mysql-5.7.17-linux-glibc2.5-x86_64/* /usr/local/mysql/
  • 建立MySQL 组和用户，并将用户添加到组中
1
2
groupadd mysql
useradd -g mysql -s /sbin/nologin mysql
  • 初始化数据库
1
/usr/local/mysql/bin/mysqld --initialize-insecure --datadir=/usr/local/mysql/data/ --user=mysql
  • 更改MySQL安装目录的属性
1
chown -R mysql:mysql /usr/local/mysql
  • 开机启动
1
2
3
4
cd /usr/local/mysql/support-files/
cp mysql.server  /etc/init.d/mysqld
chmod +x /etc/init.d/mysqld             # 添加执行权限
vim /etc/rc.d/rc.local
  • 在 rc.local 文件中添加 /etc/init.d/mysqld start
  • /etc/init.d/mysqld start
  • vi /root/.bash_profile修改PATHPATH=$PATH:$HOME/bin:/usr/local/mysql/bin:/usr/local/mysql/lib
  • source /root/.bash_profile
  • mysqladmin -u root password 密码
  • 测试登陆mysql -uroot -p密码
  • 远程数据库授权:GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' IDENTIFIED BY 'your-root-password' WITH GRANT OPTION;

这里需要注意IDENTIFIED BY后面跟上远程数据库设定的密码，比如123456，那么Navicat中登陆数据库，密码即为123456

  • FLUSH PRIVILEGES;

数据库大小写敏感

  • vim /etc/my.cnf
1
2
3
4
5
6
7
8
9
[mysqld]
datadir=/usr/local/mysql/data
port=3306
sql_mode=NO_ENGINE_SUBSTITUTION,STRICT_TRANS_TABLES
symbolic-links=0
max_connections=400
innodb_file_per_table=1
#表名大小写不明感，敏感为
lower_case_table_names=1

发表于

主键

  • JPA的使用必须要求数据库表拥有主键字段
1
2
3
4
// 主键字段，自增
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
public Long id;

一对多

1
2
3
4
5
// fetch:表示抓取策略,默认为FetchType.LAZY,因为关联的多个对象通常不必从数据库预先读取到内存 
// cascade:表示级联操作策略,对于OneToMany类型的关联非常重要,通常该实体更新或删除时,其关联的实体也应当被更新删除 
@OneToMany(fetch = FetchType.EAGER, cascade = CascadeType.ALL)
@JoinColumn(name = "act_coupon_id")
private List<ActCouponDetail> actCouponDetails;

接口继承

一般接口继承JpaRepository<T, ID>和JpaSpecificationExecutor两个接口

1
2
3
4
5
6
7
public interface StoreRepository extends JpaRepository<Store, Long>, JpaSpecificationExecutor{
    List<DOrder> findAllBySrlIn(Set<String> srls);
    
    // 如果要返回自定义的类型 需要在@Query中new那个类，否则只能返回Store类型(包含List<T>、Set<T>)
    @Query("SELECT new com.dp.datatransfer.service.dto.NameDTO(s.id ,s.storeName,s.contactPhone,s.contactAddress )FROM Store s WHERE s.id IN ?1 ")
    List<NameDTO> findNameByIdsContainPhone(Set<Long> ids);
}

发表于

错误

1
org.springframework.web.HttpMediaTypeNotAcceptableException: Could not find acceptable representation

原因

1
2
3
4
5
6
7
8
9
@RestController
public class ExchangeApiController {

	// 返回的是json的对象
	@RequestMapping(value = "/exchange", method = RequestMethod.POST)
    public ApiResult exchange(@RequestAttribute("tradingReq") TradingReqDTO tradingReqDTO) {
        return normalExchangeService.exchange(tradingReqDTO);
    }
}
1
2
3
4
5
// 拦截器将response返回类型设置为了xml文件
   @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        response.setContentType("application/xml;charset=UTF-8");
}

最终导致，想要返回的是xml形式，结果返回了json格式，导致出现如上错误提示

发表于

方法一

1
2
3
4
#配置文件
3311111111111152=hzlxywrcb
3311111111111161=hzlxlcnsh
3311111111111163=hzlxjhyh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 public static Properties signProperties = new Properties();

    static {
        try {
            // 用当前类的 类加载器 的 getResouceAsStream 读取文件中的内容
            InputStream inputStream = ValidateUtils.class.getClassLoader().
                    getResourceAsStream("properties/signparam.properties");
            // load 方法读取 属性列表，机键值对列表
            signProperties.load(inputStream);
        } catch (Exception e) {
            log.error("[ValidateUtils] 配置文件 signparam.properties 读取错误", e);
        }
    }
// 使用signProperties.getProperty方法去获取配置文件的值
// 比如src=3311111111111152 获取值为hzlxywrcb
String SRCKey = signProperties.getProperty(msgRechargeBean.getSrc());

方法二

1
2
@Value("${providers.lj.id}")
private String providerId;

方法三

1
2
3
4
5
## 配置文件
callback:
  yxjfurl: @@@@@@@
  rygurl: XXXXXXXX
  hfyurl: #######
1
2
3
4
5
6
7
@Data
@ConfigurationProperties(prefix = "callback")
public class CallBackUrlParam {
    private String yxjfurl;
    private String rygurl;
    private String hfyurl;
}
1
2
3
// 引入 使用它的get方法即可获取对应的属性
 @Autowired
 private CallBackUrlParam callBackUrlParam;
1
2
3
4
5
6
7
8
9
10
11
12
13
// 添加EnableConfigurationProperties注释即可
@EnableConfigurationProperties({CallBackUrlParam.class})
public class EgiftAppApplication {
    @PostConstruct
    public void start() {
        TimeZone.setDefault(TimeZone.getTimeZone(Constant.DEFAULT_TIME_ZONE));
    }

    public static void main(String[] args) {
        TimeZone.setDefault(TimeZone.getTimeZone(Constant.DEFAULT_TIME_ZONE));
        SpringApplication.run(EgiftAppApplication.class, args);
    }
}

发表于

场景

测试的时候需要另起一个线程去模拟第三方回调

引入ThreadPoolTaskExecutor类

  • 配置ThreadPoolTaskExecutor类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Configuration
public class ThreadPoolTaskConfig {


    @Bean(name="threadPoolTaskExecutor")
    public ThreadPoolTaskExecutor executor(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //此方法返回可用处理器的虚拟机的最大数量; 不小于1
        int core = Runtime.getRuntime().availableProcessors();
        executor.setCorePoolSize(core);//设置核心线程数
        executor.setMaxPoolSize(core*2 + 1);//设置最大线程数
        executor.setKeepAliveSeconds(3);//除核心线程外的线程存活时间
        executor.setQueueCapacity(40);//如果传入值大于0，底层队列使用的是LinkedBlockingQueue,否则默认使用SynchronousQueue
        executor.setThreadNamePrefix("thread-execute");//线程名称前缀
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//设置拒绝策略
        return executor;
    }
}
  • 使用ThreadPoolTaskExecutor
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Autowired
private ThreadPoolTaskExecutor taskExecutor;

//10秒以后自动回调
taskExecutor.execute(() -> {
    try {
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    Map<String, String> requestData = new HashMap<>();
    requestData.put("orderNo", providerResultDTO.getOrderNo());
    requestData.put("providerOrderNo", providerResultDTO.getProviderOrderNo());
    HttpClientUtil.post("http://localhost:8091/exchange/egift/exchange/rest/v_1/callback/10068", requestData);
});
0%