搜索到
93
篇与
的结果
-
微信小程序获取用户头像后上传到七牛云 一、事情起因【油耗笔记OilNote】小程序好久没有升级了，最近打算对代码进行一些优化，但是新版本突然发现无法获取到用户微信头像及微信昵称了。查阅官方文档才知道，官方有对getUserProfile接口进行调整了。自 2022 年 10 月 25 日 24 时后（以下统称 “生效期” ），用户头像昵称获取规则将进行如下调整：自生效期起，小程序 wx.getUserProfile 接口将被收回：生效期后发布的小程序新版本，通过 wx.getUserProfile 接口获取用户头像将统一返回默认灰色头像，昵称将统一返回 “微信用户”。生效期前发布的小程序版本不受影响，但如果要进行版本更新则需要进行适配。自生效期起，插件通过 wx.getUserInfo 接口获取用户昵称头像将被收回：生效期后发布的插件新版本，通过 wx.getUserInfo 接口获取用户头像将统一返回默认灰色头像，昵称将统一返回 “微信用户”。生效期前发布的插件版本不受影响，但如果要进行版本更新则需要进行适配。通过 wx.login 与 wx.getUserInfo 接口获取 openId、unionId 能力不受影响。「头像昵称填写能力」支持获取用户头像昵称：如业务需获取用户头像昵称，可以使用「头像昵称填写能力」（基础库 2.21.2 版本开始支持，覆盖iOS与安卓微信 8.0.16 以上版本），具体实践可见下方《最佳实践》。小程序 wx.getUserProfile 与插件 wx.getUserInfo 接口兼容基础库 2.27.1 以下版本的头像昵称获取需求：对于来自低版本的基础库与微信客户端的访问，小程序通过 wx.getUserProfile 接口将正常返回用户头像昵称，插件通过 wx.getUserInfo 接口将正常返回用户头像昵称，开发者可继续使用以上能力做向下兼容。现在只要是发布的新版本，默认都需要调整，不然就显示下面灰色头像，已经发布的版本不受影响。既然官方调整了，那么我们也只有被动接受的份。二、油耗笔记的开发框架油耗笔记OilNote不是直接使用微信开发者工具开发的，而是使用UniApp开发的，后端是SpringBoot。三、改进思路3.1、获取用户头像由于官方指导意见是，使用button组件 open-type 的值设置为 chooseAvatar，当用户选择需要使用的头像之后，可以通过 bindchooseavatar 事件回调获取到头像信息的临时路径。从官方的指导我们可以看到，微信并没有给我们返回一个具体的路径，只是返回了一个临时的路径，因此我们就必须自己获取到这个临时的文件，然后存储起来。3.2、使用七牛云由于使用的腾讯云的低配服务器，带宽、存储都比较捉襟见肘，所以我打算把头像都存储到七牛云上，既能减轻带宽压力也能节省服务器空间。四、具体改进4.1、UniApp页面改进当用户通过微信登录时，此时获取用户头像信息，如果头像存在，登录之后跳转到首页，否则跳转到个人信息界面，让用户维护头像及昵称，此方法适用于新用户，同时也适用于老用户重新登录。//微信授权登录 getUserInfo(e) { let that = this; var p = this.getSetting(); p.then(function(isAuth) { console.log('是否已经授权', isAuth); if (isAuth) { console.log('用户信息，加密数据', e); //eData 包括//微信头像//微信名称 还有加密的数据. // let eData = JSON.parse(e.detail.rawData); uni.getUserProfile({ desc: 'Wexin', // 这个参数是必须的 success: function(infoRes) { //接下来就是访问接口. that.$request( 'wechat/authCode2Session?code=' + that.weChatCode, 'POST' ).then(function(res) { if (res.code == 200) { //将接口返回的数据保存在全局变量中. let userInfo = {} // 用户id userInfo.id = res.data.id userInfo.username = res.data.username userInfo.tel = res.data.tel userInfo.email = res.data.email userInfo.wechatOpenId = res.data.wechatOpenId userInfo.nickName = res.data.nickName userInfo.avatarUrl = res.data.avatarUrl ? res.data .avatarUrl : infoRes.userInfo.avatarUrl userInfo.gender = infoRes.userInfo.gender userInfo.password = '' if (!userInfo.province) { userInfo.province = uni.getStorageSync('province') } if (!userInfo.city) { userInfo.city = uni.getStorageSync('city') } uni.setStorageSync('userInfo', userInfo); if (!res.data.avatarUrl) { //没有头像时，跳转到用户信息维护界面 uni.redirectTo({ url: '/pages/profile/profile' }) } else { uni.redirectTo({ url: '/pages/index/index' }) } } }, function(err) { uni.showToast({ title: '授权登录失败！', mask: true, icon: 'none' }) } ) } }); } else { uni.showToast({ title: '授权失败，请确认授权已开启', mask: true, icon: 'none' }) } }); },4.1.1、登录界面改造4.1.2、个人信息界面改造油耗笔记之前有一个【个人信息】页面，因此我打算把修改头像的功能发放到里面。在合适的位置放入选择头像的按钮<button class="avatar-wrapper" open-type="chooseAvatar" @chooseavatar="onChooseAvatar"> <view class="cu-avatar xl round margin-center" :style="{backgroundImage:'url('+userInfo.avatarUrl+')'}"></view> </button>增加回调方法用户选择微信头像之后，会回调chooseavatar方法，因此我们增加一个chooseavatar用于用户选择头像之后上传到服务器（进一步上传到七牛）//选择头像回调 onChooseAvatar(e) { const that = this; this.$set(this.userInfo, "avatarUrl", e.detail.avatarUrl); uni.uploadFile({ url: operate.api + 'user/uploadAvatar/', //上传接口 header: { token: that.userInfo.id ? that.userInfo.id : '', }, formData: { 'userInfo': JSON.stringify(that.userInfo) }, filePath: e.detail.avatarUrl, name: 'file', success: (uploadFileRes) => { uni.hideLoading(); const back = JSON.parse(uploadFileRes.data); if (back.code == 200) { that.$set(that.userInfo, 'avatarUrl', back.data.avatarUrl) } else { uni.showToast(back.msg) } }, fail: (error) => { uni.hideLoading(); uni.showToast("图片上传失败，请联系开发！") }, complete: function() { uni.hideLoading(); } }); }4.2、后端改造我们首先在后端增加一个方法，用于接受前端传递的附件及其他参数（我这里主要传递的是用户信息，用户更新用户表，记录头像地址）。4.2.1、Controller增加接受用户上传头像的Api，具体的实现我们稍后在说。/** * 上传头像 * * @param multipartFile 文件信息 * @return 用户信息 */ @PostMapping("uploadAvatar") public AjaxResult uploadAvatar(@RequestParam("file") MultipartFile multipartFile,@RequestParam("userInfo") String oilUser) { return AjaxResult.success(oilUserService.uploadAvatar(multipartFile)); }4.2.2、增加七牛云依赖经过上面改造，我们已经可以将用户头像上传到我们的后端了，接下来的任务就是将头像上传到我们的七牛云了。现在pom.xml中增加七牛云的依赖<!-- 七牛云--> <dependency> <groupId>com.qiniu</groupId> <artifactId>qiniu-java-sdk</artifactId> <version>7.2.28</version> </dependency>4.2.3、增加七牛云配置为了方便使用，我们将七牛云的一些配置信息放入yaml文件中，方便维护。# ========================== ↓↓↓↓↓↓ 七牛云配置 ↓↓↓↓↓↓ ========================== qiniu: accessKey: XXX # Key secretKey: XXX # 密钥 bucket: XXX # 空间名称 domain: XXX # 访问域名 dir: XXX/ # 目录参数说明：accessKey：AK，在七牛云，个人中心，密钥管理中可以看到secretKey：SK，在七牛云，个人中心，密钥管理中可以看到bucket：空间名称，根据自己创建的空间填写domain：访问域名，根据控件绑定的域名实际填写dir：存储路径，因为七牛云默认是直接存储到根目录，为了方便管理，我们可以创建子目录，比如avatar，可以填写avatar/4.2.4、增加配置类为了方便使用，我们将yaml的值，映射到配置类上。/** * 七牛云实体 */ @Component @ConfigurationProperties(prefix = "qiniu") public class QiNiuConfig { /** * Key */ private static String accessKey; /** * 密钥 */ private static String secretKey; /** * 空间名称 */ private static String bucket; /** * 访问域名 */ private static String domain; /** * 目录 */ private static String dir; public static String getAccessKey() { return accessKey; } public void setAccessKey(String accessKey) { QiNiuConfig.accessKey = accessKey; } public static String getSecretKey() { return secretKey; } public void setSecretKey(String secretKey) { QiNiuConfig.secretKey = secretKey; } public static String getBucket() { return bucket; } public void setBucket(String bucket) { QiNiuConfig.bucket = bucket; } public static String getDomain() { return domain; } public void setDomain(String domain) { QiNiuConfig.domain = domain; } public static String getDir() { return dir; } public void setDir(String dir) { QiNiuConfig.dir = dir; } } 4.2.5、封装公共方法为了方便调用，我们将上传、删除等方法封装到单独的服务中。接口/** * 七牛接口 */ public interface IQiNiuService { /** * 以文件的形式上传 * * @param file * @param fileName: * @return: java.lang.String */ String uploadFile(File file, String fileName) throws QiniuException; /** * 以流的形式上传 * * @param inputStream * @param fileName: * @return: java.lang.String */ String uploadFile(InputStream inputStream, String fileName) throws QiniuException; /** * 删除文件 * * @param key: * @return: java.lang.String */ String delete(String key) throws QiniuException; } 实现@Service public class QiNiuServiceImpl implements IQiNiuService, InitializingBean { // 七牛文件上传管理器 private final Configuration cfg; private final Auth auth; public QiNiuServiceImpl() { // //构造一个带指定 Region 对象的配置类 cfg = new Configuration(Region.huadong()); auth = Auth.create(QiNiuConfig.getAccessKey(), QiNiuConfig.getSecretKey()); } /** * 定义七牛云上传的相关策略 */ private StringMap putPolicy; @Override public String uploadFile(File file, String fileName) throws QiniuException { if (!StringUtils.isEmpty(QiNiuConfig.getDir())) { fileName = QiNiuConfig.getDir() + fileName; } UploadManager uploadManager = new UploadManager(cfg); Response response = uploadManager.put(file, fileName, getUploadToken()); int retry = 0; while (response.needRetry() && retry < 3) { response = uploadManager.put(file, fileName, getUploadToken()); retry++; } if (response.statusCode == 200) { return "http://" + QiNiuConfig.getDomain() + "/" + fileName; } return "上传失败!"; } @Override public String uploadFile(InputStream inputStream, String fileName) throws QiniuException { if (!StringUtils.isEmpty(QiNiuConfig.getDir())) { fileName = QiNiuConfig.getDir() + fileName; } UploadManager uploadManager = new UploadManager(cfg); Response response = uploadManager.put(inputStream, fileName, getUploadToken(), null, null); int retry = 0; while (response.needRetry() && retry < 3) { response = uploadManager.put(inputStream, fileName, getUploadToken(), null, null); retry++; } if (response.statusCode == 200) { return "http://" + QiNiuConfig.getDomain() + "/" + fileName; } return "上传失败!"; } @Override public String delete(String key) throws QiniuException { BucketManager bucketManager = new BucketManager(auth, cfg); Response response = bucketManager.delete(QiNiuConfig.getBucket(), key); int retry = 0; while (response.needRetry() && retry++ < 3) { response = bucketManager.delete(QiNiuConfig.getBucket(), key); } return response.statusCode == 200 ? "删除成功!" : "删除失败!"; } @Override public void afterPropertiesSet() throws Exception { this.putPolicy = new StringMap(); putPolicy.put("insertOnly", 0); } /** * 获取上传凭证 */ private String getUploadToken() { return this.auth.uploadToken(QiNiuConfig.getBucket(), null, 3600, putPolicy); } } 有几个需要注意的点：在构造函数中，构造Configuration时，需要指定区域，因为我是华东区域的，因此使用的是Region.huadong()，如果使用的其他区域的，需要根据自己实际区域指定。在指定策略时，因为我一个用户只允许一个头像，因此上传时，如果存在我们直接覆盖的，所以在afterPropertiesSet方法中，设置上传策略时，直接指定的putPolicy.put("insertOnly", 0);，即如果存在就覆盖，如果不想覆盖，可以设置putPolicy.put("insertOnly", 1);，但是此时需要注意，如果上传重名文件，会返回异常。4.2.6、完善后用户上传头像方法用户上传头像后，更新用户实体（但是此时不更新数据库），将更新后的实体返回到前端，点击保存时，再更新数据库。 @Override public OilUser uploadAvatar(MultipartFile multipartFile, OilUser oilUser) throws IOException { String originalFilename = multipartFile.getOriginalFilename(); if (originalFilename == null || !originalFilename.contains(".")) { throw new CustomException("文件名不正确"); } String fileName = "avatar" + oilUser.getId() + originalFilename.substring(originalFilename.lastIndexOf(".")); String avatarUrl = qiNiuService.uploadFile(multipartFile.getInputStream(), fileName); oilUser.setAvatarUrl(avatarUrl); // LambdaUpdateWrapper<OilUser> userUpdateWrapper = new LambdaUpdateWrapper<>(); // userUpdateWrapper.set(OilUser::getAvatarUrl, oilUser.getAvatarUrl()); // userUpdateWrapper.eq(OilUser::getId, oilUser.getId()); // oilUserMapper.update(null, userUpdateWrapper); return oilUser; }4.2.7、用户保存方法分改造用户保存方法主要增加userUpdateWrapper.set(OilUser::getAvatarUrl, user.getAvatarUrl());,当用户有头像时，同步更新用户的头像信息。/** * 新增或保存用户 * * @param user 用户 * @return 结果 */ public OilUser saveUser(OilUser user) { if (user == null) { throw new CustomException("用户信息不能为空"); } if (user.getId() == null) { user.setId(""); } if (checkUserNameExist(user)) { throw new CustomException("用户名已存在"); } if (StringUtils.isEmpty(user.getId())) { user.setId(UUID.randomUUID().toString()); if (!StringUtils.isEmpty(user.getPassword())) { user.setPassword(passwordEncoder.encode(user.getPassword())); } oilUserMapper.insert(user); } else { LambdaUpdateWrapper<OilUser> userUpdateWrapper = new LambdaUpdateWrapper<>(); userUpdateWrapper.set(OilUser::getUsername, user.getUsername()); userUpdateWrapper.set(OilUser::getNickName, user.getNickName()); userUpdateWrapper.set(OilUser::getTel, user.getTel()); userUpdateWrapper.set(OilUser::getEmail, user.getEmail()); if (!StringUtils.isEmpty(user.getPassword())) { userUpdateWrapper.set(OilUser::getPassword, passwordEncoder.encode(user.getPassword())); } if (!StringUtils.isEmpty(user.getProvince())) { userUpdateWrapper.set(OilUser::getProvince, user.getProvince()); } if (!StringUtils.isEmpty(user.getCity())) { userUpdateWrapper.set(OilUser::getCity, user.getCity()); } if (!StringUtils.isEmpty(user.getAvatarUrl())) { userUpdateWrapper.set(OilUser::getAvatarUrl, user.getAvatarUrl()); } userUpdateWrapper.eq(OilUser::getId, user.getId()); oilUserMapper.update(null, userUpdateWrapper); user.setPassword(""); } return user; }五、效果微信用户登录后，如果没有上传过头像，会自动跳转到【个人信息】页面在个人信息上传头像后，自动跳转到首页。六、其他注意事项七牛云域名需要配置HTTPS小程序域名白名单uploadFile合法域名需要配置后台上传附件的域名。 -
Jackson反序列化时忽略某些属性的方法 在开发接口时，出于某些目的（比如有些字段我要设置默认值，不能受入参的影响），我们在入参字符串序列化成实体时，可能需要忽略某些属性。我们要达到的目的非常简单，一个用户类User.java，我们要达到的目的有两个：（1）控制序列化时，忽略name属性。（2）控制反序列化是，忽略name属性。一、@JsonIgnore注解当我们想控制是一个实体在序列化时，忽略某些属性，我们第一个想到的也许就是@JsonIgnore注解了，@JsonIgnore注解能控制实体在序列化时，忽略某些属性，但是无法控制实体在反序列化时忽略的属性。先来看一下我们测试用的User.java类。public class User implements Serializable { private String code; @JsonIgnore private String name; public String getCode() { return code; } public void setCode(String code) { this.code = code; } public String getName() { return name; } public void setName(String name) { this.name = name; } }1.1、序列化我们先试一下序列化，看看name属性能否在序列化时自动忽略掉。测试方法也非常简单ObjectMapper objectMapper = new ObjectMapper(); User user = new User(); user.setCode("code123"); user.setName("name123"); System.out.println(objectMapper.writeValueAsString(user));可以看到，name属性确实忽略了，也就是这个注解针对序列化是生效的。1.2、反序列化序列化时候没问题，那么反序列化时候是否也没问题呢，我们接着往下看。String userStr = "{\"code\":\"code123\",\"name\":\"name123\"}"; User user1 = objectMapper.readValue(userStr, User.class);这个时候我们不能在序列化输出显示了，我们调试看一下。我们可以看到，也是能够正常忽略掉的。但是，今天在项目开发时，我使用了同样的方法，发现@JsonIgnore注解没有起作用，但是实体类是这么样的@Data @NoArgsConstructor public class User implements Serializable { private String code; @JsonProperty(value = "name") @JsonIgnore private String name; @JsonProperty(value = "billCateProp") @JsonIgnore @JSONField(deserialize = false) private String billCateProp; @JsonFormat(pattern = "yyyy-MM-dd") private Date date; }怀疑了Data注解，也怀疑了@JsonProperty与@JsonIgnore注解冲突，甚至是属性Camel命名等，但是同样的代码，我拿到别的地方也有没有再现问题，所以终究也不知道是什么原因导致的。2、@JsonProperty@JsonIgnore的问题没有解决，只能另辟蹊径，最终发现@JsonIgnore注解有个access属性，通过access属性解决了问题，在反序列化时，不会再读取忽略的字段，遂将代码调整如下 @JsonProperty(value = "billCateProp",access = JsonProperty.Access.READ_ONLY) // @JsonIgnore @JSONField(deserialize = false) private String billCateProp;JsonProperty.Access.READ_ONLY代表反序列化是忽略字段。JsonProperty.Access.WRITE_ONLY代表序列化时忽略字段。@JsonIgnore失效的问题，最终也没找到答案，有知道的童鞋不妨留言说明一下。
-
SpringBoot事务提交后执行异步代码 一般情况下，我们在使用事务时，都是在方法上添加一个@Transactional注解 @Transactional(rollbackFor = Exception.class) public void test1() { }但是有些时候，除了主要核心业务外，我们可能还需要推送消息，但是推送消息我们又需要使用我们核心业务的数据，比如我在核心业务代码中执行了插入，之后需要异步获取插入的数据，推送消息或者发送给异构系统，这个时候，我们可以使用Spring Boot提供的TransactionSynchronization接口，并实现afterCommit方法package com.example.demo.service; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.support.TransactionSynchronizationAdapter; import org.springframework.transaction.support.TransactionSynchronizationManager; import javax.annotation.Resource; @Service public class Test123Service { @Resource Test2Service test2Service; @Transactional(rollbackFor = Exception.class) public void test1() { boolean synchronizationActive = TransactionSynchronizationManager.isSynchronizationActive(); if (synchronizationActive) { TransactionSynchronizationManager.registerSynchronization( new TransactionSynchronizationAdapter() { @Override public void afterCommit() { test2Service.test2(); } } ); } else { test2Service.test2(); } } } package com.example.demo.service; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @Service public class Test2Service { @Async public void test2(){ System.out.println("test2"); } }注意：方法test1()不能调用同一给类中使用了@Async注解的方法test2()（此时@Async会失效）
-
spring boot主流办公文档的在线预览源码 kkFileView此项目为文件文档在线预览项目解决方案，对标业内付费产品有【永中office】【office365】【idocv】等，在取得公司高层同意后以Apache协议开源出来反哺社区，在此特别感谢@唐老大的支持以及@端木详笑的贡献。该项目使用流行的spring boot搭建，易上手和部署，基本支持主流办公文档的在线预览，如doc,docx,Excel,pdf,txt,zip,rar,图片等等项目特性支持 office, pdf, cad 等办公文档支持 txt, xml(渲染), md(渲染), java, php, py, js, css 等所有纯文本支持 zip, rar, jar, tar, gzip 等压缩包支持 jpg, jpeg, png, gif, tif, tiff 等图片预览（翻转，缩放，镜像）使用 spring-boot 开发，预览服务搭建部署非常简便rest 接口提供服务，跨语言、跨平台特性(java,php,python,go,php，....)都支持，应用接入简单方便抽象预览服务接口，方便二次开发，非常方便添加其他类型文件预览支持最最重要 Apache 协议开源，代码 pull 下来想干嘛就干嘛官网及文档地址：https://kkfileview.keking.cn在线体验请善待公共服务，会不定时停用地址：https://file.keking.cn项目文档（Project documentation）详细wiki文档：https://gitee.com/kekingcn/file-online-preview/wikis/pages中文文档：https://gitee.com/kekingcn/file-online-preview/blob/master/README.mdEnglish document：https://gitee.com/kekingcn/file-online-preview/blob/master/README.en.md联系我们，加入组织我们会用心回答解决大家在项目使用中的问题，也请大家在提问前至少 Google 或 baidu 过，珍爱生命远离无效的交流沟通QQ群号：613025121(已满) 2群：484680571文档预览效果1. 文本预览支持所有类型的文本文档预览， 由于文本文档类型过多，无法全部枚举，默认开启的类型如下 txt,html,htm,asp,jsp,xml,json,properties,md,gitignore,log,java,py,c,cpp,sql,sh,bat,m,bas,prg,cmd 文本预览效果如下 2. 图片预览支持jpg，jpeg，png，gif等图片预览（翻转，缩放，镜像），预览效果如下 3. word文档预览支持doc，docx文档预览，word预览有两种模式：一种是每页word转为图片预览，另一种是整个word文档转成pdf，再预览pdf。两种模式的适用场景如下图片预览：word文件大，前台加载整个pdf过慢pdf预览：内网访问，加载pdf快图片预览模式预览效果如下 pdf预览模式预览效果如下 4. ppt文档预览支持ppt，pptx文档预览，和word文档一样，有两种预览模式 图片预览模式预览效果如下 pdf预览模式预览效果如下 5. pdf文档预览支持pdf文档预览，和word文档一样，有两种预览模式 图片预览模式预览效果如下 pdf预览模式预览效果如下 6. excel文档预览支持xls，xlsx文档预览，预览效果如下 7. 压缩文件预览支持zip,rar,jar,tar,gzip等压缩包，预览效果如下 可点击压缩包中的文件名，直接预览文件，预览效果如下 8. 多媒体文件预览理论上支持所有的视频、音频文件，由于无法枚举所有文件格式，默认开启的类型如下 mp3,wav,mp4,flv 视频预览效果如下 音频预览效果如下 9. CAD文档预览支持CAD dwg文档预览，和word文档一样，有两种预览模式 图片预览模式预览效果如下 pdf预览模式预览效果如下 考虑说明篇幅原因，就不贴其他格式文件的预览效果了，感兴趣的可以参考下面的实例搭建下快速开始项目使用技术spring boot： spring boot开发参考指南freemarkerredissonjodconverter依赖外部环境redis (可选，默认不用)OpenOffice 或者 LibreOffice( Windows 下已内置，Linux 脚本启动模式会自动安装，Mac OS 下需要手动安装)第一步：pull 项目 https://github.com/kekingcn/file-online-preview.git第二步：运行 ServerMain 的 main 方法，服务启动后，访问 http://localhost:8012/会看到如下界面，代表服务启动成功历史更新记录2021年7月6日，v4.0.0 版本发布 ：底层集成OpenOffice替换为LibreOffice，Office文件兼容性增强，预览效果提升修复压缩文件目录穿越漏洞修复PPT预览使用PDF模式无效修复PPT图片预览模式前端显示异常新增功能：首页文件上传功能可通过配置实时开启或禁用优化增加Office进程关闭日志优化Windows环境下，查找Office组件逻辑(内置的LibreOffice优先)优化启动Office进程改同步执行2021年6月17日，v3.6.0 版本发布 ：ofd 类型文件支持版本，本次版本重要功能均由社区开发贡献，感谢 @gaoxingzaq、@zhangxiaoxiao9527 的代码贡献新增 ofd 类型文件预览支持，ofd 是国产的类似 pdf 格式的文件新增了 ffmpeg 视频文件转码预览支持，打开转码功能后，理论上支持所有主流视频的预览，如 rm、rmvb、flv 等美化了 ppt、pptx 类型文件预览效果，比之前版本好看太多更新了 pdfbox、xstream、common-io 等依赖的版本2021年1月28日 ：2020农历年最后一个版本发布，主要包含了部分 UI 改进，和解决了 QQ 群友、 Issue 里反馈的 Bug 修复，最最重要的是发个新版，过个好年引入galimatias,解决不规范文件名导致文件下载异常更新index接入演示界面UI风格更新markdown文件预览UI风格更新XML文件预览UI风格，调整类文本预览架构，更方便扩展更新simTxT文件预览UI风格调整多图连续预览上下翻图的UI采用apache-common-io包简化所有的文件下载io操作XML文件预览支持切换纯文本模式增强url base64解码失败时的提示信息修复导包错误以及图片预览 bug修复发行包运行时找不到日志目录的问题修复压缩包内多图连续预览的bug修复大小写文件类型后缀没通用匹配的问题指定Base64转码采用Apache Commons-code中的实现，修复base64部分jdk版本下出现的异常修复类文本类型HTML文件预览的bug修复：dwg文件预览时无法在jpg和pdf两种类型之间切换escaping of dangerous characters to prevent reflected xss修复重复编码导致文档转图片预览失败的问题&编码规范2020年12月27日 ：2020年年终大版本更新，架构全面设计，代码全面重构，代码质量全面提升，二次开发更便捷，欢迎拉源码品鉴，提issue、pr共同建设架构模块调整,大量的代码重构，代码质量提升N个等级，欢迎品鉴增强XML文件预览效果，新增XML文档数结构预览新增markdown文件预览支持，预览支持md渲染和源文本切换支持切换底层web server为jetty，解决这个issue：https://github.com/kekingcn/kkFileView/issues/168引入cpdetector，解决文件编码识别问题url采用base64+urlencode双编码，彻底解决各种奇葩文件名预览问题新增配置项office.preview.switch.disabled，控制offic文件预览切换开关优化文本类型文件预览逻辑，采用Base64传输内容，避免预览时再次请求文件内容office预览图片模式禁用图片放大效果，达到图片和pdf预览效果一致的体验直接代码静态设置pdfbox兼容低版本jdk，在IDEA中运行也不会有警告提示移除guava、hutool等非必须的工具包，减少代码体积Office组件加载异步化，提速应用启动速度最快到5秒内合理设置预览消费队列的线程数修复压缩包里文件再次预览失败的bug修复图片预览的bug2020年05月20日 ：新增支持全局水印，并支持通过参数动态改变水印内容新增支持CAD文件预览新增base.url配置，支持使用nginx反向代理和使用context-path支持所有配置项支持从环境变量里读取，方便Docker镜像部署和集群中大规模使用支持配置限信任站点（只能预览来自信任点的文件源），保护预览服务不被滥用支持配置自定义缓存清理时间（cron表达式）全部能识别的纯文本直接预览，不用再转跳下载，如.md .java .py等支持配置限制转换后的PDF文件下载优化maven打包配置，解决 .sh 脚本可能出现换行符问题将前端所有CDN依赖放到本地，方便没有外网连接的用户使用首页评论服务由搜狐畅言切换到Gitalk修复url中包含特殊字符可能会引起的预览异常修复转换文件队列addTask异常修复其他已经问题官网建设：https://kkfileview.keking.cn官方Docker镜像仓库建设：https://hub.docker.com/r/keking/kkfileview2019年06月18日 ：支持自动清理缓存及预览文件支持http/https下载流url文件预览支持FTP url文件预览加入Docker构建2019年04月08日 ：缓存及队列实现抽象，提供JDK和REDIS两种实现(REDIS成为可选依赖)打包方式提供zip和tar.gz包，并提供一键启动脚本2018年01月19日 ：大文件入队提前处理新增addTask文件转换入队接口采用redis队列，支持kkFIleView接口和异构系统入队两种方式2018年01月17日 ：优化项目结构，抽象文件预览接口，更方便的加入更多的文件类型预览支持，方便二次开发新增英文文档说明（@幻幻Fate，@汝辉）贡献新增图片预览文件支持类型修复压缩包内轮播图片总是从第一张开始的问题2018年01月12日 ：新增多图片同时预览支持压缩包内图片轮番预览2018年01月02日 ：修复txt等文本编码问题导致预览乱码修复项目模块依赖引入不到的问题新增spring boot profile，支持多环境配置引入pdf.js预览doc等文件，支持doc标题生成pdf预览菜单，支持手机端预览使用登记如果这个项目解决了你的实际问题，可在 https://gitee.com/kekingcn/file-online-preview/issues/IGSBV登记下，如果节省了你的三方预览服务费用，也愿意支持下的话，可点击下方【捐助】请作者喝杯咖啡，也是非常感谢Stars 趋势图GiteeGitHub
-
Spring Boot另类前后端分离项目部署 对于前后端分离的项目，一般情况下，我们是把静态文件放到nginx中，然后通过端口转发，请求后端避免跨域的问题。我们知道，Spring Boot项目中，我们可以添加静态资源，根据约定大于配置的规则，默认静态文件位置位于以下位置classpath:/static,classpath:/public,classpath:/resources,classpath:/META-INF/resources,servlet context:将前端文件放到Spring Boot静态资源中的好处是不存在跨域的问题。默认静态资源，如果我们放到resources中，这显然不是我们想看到的。我们希望的是，将静态文件放到jar包之外的某个特定位置，这样静态资源的修改，不会涉及jar包的修改。配置文件修改为了实现静态资源文件的配置，我们需要通过spring.web.resources.static-locations指定静态文件的位置web: spring: web: resources: static-locations: file:${web}之所以添加一个web，是为了方便我们在命令行动态指定位置。放置静态资源我这里演示将index.html放到--web=/Users/lisen/IdeaProjects/demo/web中进行访问。内容如下：<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Title</title> <script src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"> </script> </head> <body> 这是首页1 <div id="div1"></div> <script> $(document).ready(function(){ $.ajax({ url:"/book/get/1", type : "POST", //请求成功 success : function(result) { $("#div1").html(result); }, }) }); </script> </body> </html>启动命令java -jar /Users/lisen/IdeaProjects/demo/target/demo-0.0.1-SNAPSHOT.jar --web=/Users/lisen/IdeaProjects/demo/web访问前端页面可以看到，页面正确访问，并且没有出现跨域的问题。
-
SpringBoot JPA自动设置创建者、最后修改者 书接上文，SpringBoot JPA自动设置创建时间、修改时间，审计不可能只包含创建时间、最后修改时间，肯定得有人，也就是必须得有创建者、最后修改者。Spring Data Jpa设置创建者、最后修改者也非常简单。实体修改@Data @Entity @Table(name = "Book") @EntityListeners(AuditingEntityListener.class) public class Book { @Id private long id; private String name; private String author; private BigDecimal price; @CreatedDate private Timestamp createdDate; @CreatedBy private String createBy; @LastModifiedDate private Timestamp lastModifiedDate; @LastModifiedBy private String lastModifiedBy; }@CreatedBy注解用于标识创建者。@LastModifiedBy注解用于标识最后修改者。其他注解跟设置创建时间、最后修改时间一致，不再赘述，这里重点说一下，如何获取创建者、最后修改者。设置创建者、最后修改者值在Spring Data Jpa中，可以通过实现AuditorAware接口让程序知道当前审核程序的用户，实现逻辑根据项目实际情况编写。/** * 审计接口，获取当前人员 */ @Configuration public class JpaAuditWare implements AuditorAware<String> { @Override public Optional<String> getCurrentAuditor() { return Optional.of(UUID.randomUUID().toString()); } }验证创建验证 @GetMapping("save") public Book saveBook() { Book book = new Book(); book.setId(1L); book.setName("《山海经》"); book.setAuthor("佚名"); book.setPrice(new BigDecimal("500")); return bookService.saveBook(book); }修改验证然后我们修改一下数据，验证一下最后修改人、最后修改时间[alt type="info"]如果数据未发生改变，那么最后修改者、最后修改时间是不会发生改变的。[/alt]
-
SpringBoot JPA自动设置创建时间、修改时间 JPA提供了审计功能，用于设置创建者、创建时间、修改者、修改时间等参数。创建时间、修改时间很好理解，就是当前时间，但是创建者、修改者一般都是通过上下文信息获取的，由于我这边是接口里面使用，未使用创建者、修改者，所以先介绍一下创建时间、修改时间的使用。添加依赖那些巴拉巴拉的就不啰嗦。创建实体@Getter @Setter @ToString @Entity @Table(name = "ARAPDiscountRecord") @EntityListeners(AuditingEntityListener.class) public class ARAPDiscountRecordEntity implements Serializable { @CreatedDate @Column(name = "timestamp_createdon") private Timestamp timestampCreatedon; @LastModifiedDate @Column(name = "timestamp_lastchangedon") private Timestamp timestampLastchangedon; }@CreatedDate注解用于标识创建时间。@LastModifiedDate注解用于标识修改时间。实体类添加@EntityListeners(AuditingEntityListener.class)标识启动审计。启动审计再启用或者配置类上添加@EnableJpaAuditing启动审计。@EnableJpaAuditing @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } }这样的话，每次创建数据，系统会自动赋值timestampCreatedon列，修改数据时，系统会自动赋值timestampLastchangedon字段。
-
Spring Boot中ThreadLocal踩坑 ThreadLocal作用ThreadLocal的作用:用来存当前线程的局部变量，不同线程间互不干扰。拿完数据记得需要移除数据，不然JVM不会将ThreadLocal回收(可能还会被引用)，多了就会出现内存泄漏的情况。解析ThreadLocal类ThreadLocal包含几个方法：public T get() { } public void set(T value) { } public void remove() { } protected T initialValue() { }T get()get()方法是用来获取ThreadLocal在当前线程中保存的变量副本set(T value)set()用来设置当前线程中变量的副本void remove()remove()用来移除当前线程中变量的副本T initialValue()initialValue()是一个protected方法，一般是用来在使用时进行重写的，它是一个延迟加载方法。ThreadLocal变量污染ThreadLocal会在每个线程存储一个副本，但是如果我们使用的是比如Tomcat，Tomcat自身会维护一个线程池，线程结束后，并不会马上销毁，而是会重新进入线程池，下次有请求时，有可能会复用当前线程，如果我们每次使用ThreadLocal之前，没有进行Set(T value),那么就有可能导致不同线程之间变量污染，比如下面的代码@RestController @RequestMapping(value = "book") @Slf4j public class BookController { private static final ThreadLocal<String> THREAD_LOCAL_TEST = new ThreadLocal<>(); @Resource private IBookService bookService; /** * 构造函数 */ public BookController() { log.info("构造函数，此时bookService ：" + bookService); } @PostConstruct public void init() { log.info("PostConstruct，此时bookService ：" + bookService); } @PreDestroy public void destroy() { log.info("PreDestroy"); } @GetMapping(value = "set") public void set() { if (StringUtils.isEmpty(THREAD_LOCAL_TEST.get())) { THREAD_LOCAL_TEST.set(UUID.randomUUID().toString()); } } @GetMapping(value = "search") public List<Book> search() { log.error(THREAD_LOCAL_TEST.get()); return bookService.search(); } }使用jmeter进行请求，可以看到同一线程，输出的内容永远不会发生改变。可以在内次使用之前进行set(T value),但是set(T value)可能会导致内存无法释放。ThreadLocal可能导致的内存泄露ThreadLocal为了避免内存泄露，不仅使用了弱引用维护key，还会在每个操作上检查key是否被回收，进而再回收value。但是从中也可以看到，ThreadLocal并不能100%保证不发生内存泄漏。比如，很不幸的，你的get()方法总是访问固定几个一直存在的ThreadLocal，那么清理动作就不会执行，如果你没有机会调用set()和remove()，那么这个内存泄漏依然会发生。一个良好的习惯依然是：当你不需要这个ThreadLocal变量时，主动调用remove()，这样对整个系统是有好处的。@RestController @RequestMapping(value = "book") @Slf4j public class BookController { private static final ThreadLocal<String> THREAD_LOCAL_TEST = new ThreadLocal<>(); @Resource private IBookService bookService; /** * 构造函数 */ public BookController() { log.info("构造函数，此时bookService ：" + bookService); } @PostConstruct public void init() { log.info("PostConstruct，此时bookService ：" + bookService); } @PreDestroy public void destroy() { log.info("PreDestroy"); } @GetMapping(value = "set") public void set() { THREAD_LOCAL_TEST.set(UUID.randomUUID().toString()); } @GetMapping(value = "search") public List<Book> search() { log.error(THREAD_LOCAL_TEST.get()); THREAD_LOCAL_TEST.remove(); return bookService.search(); } }ThreadLocal与局部变量局部变量和ThreadLocal起到的作用是一样的，保证了并发环境下数据的安全性。那就是说，完全可以用局部变量来代替ThreadLocal咯？This class provides thread-local variables. These variables differ from their normal counterparts in that each thread that accesses one (via its {@code get} or {@code set} method) has its own, independently initialized copy of the variable. {@code ThreadLocal} instances are typically private static fields in classes that wish to associate state with a thread (e.g., a user ID or Transaction ID).[typing]翻译过来[/typing] ThreadLocal提供的是一种线程局部变量。这些变量不同于其它变量的点在于每个线程在获取变量的时候，都拥有它自己相对独立的变量初始化拷贝。ThreadLocal的实例一般是私有静态的，可以做到与一个线程绑定某一种状态。所以就这段话而言，我们知道ThreadLocal不是为了满足多线程安全而开发出来的，因为局部变量已经足够安全。ThreadLocal是为了方便线程处理自己的某种状态。 可以看到ThreadLocal实例化所处的位置，是一个线程共有区域。好比一个银行和个人，我们可以把钱存在银行，也可以把钱存在家。存在家里的钱是局部变量，仅供个人使用；存在银行里的钱也不是说可以让别人随便使用，只有我们以个人身份去获取才能得到。所以说ThreadLocal封装的变量我们是在外面某个区域保存了处于我们个人的一个状态，只允许我们自己去访问和修改的状态。
-
@SpringBootApplication标注非引导类 一般情况下，@SpringBootApplication一般都是标注在项目引导类上。像下面这样：@Slf4j @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoConfiguration.class, args); } }但是@SpringBootApplication一定要标注到引导类上吗？答案是否定的。我们可以将@SpringBootApplication标注到任意的类上。比如我们增加以下类package cc.lisen.demo.config; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class DemoConfiguration { }然后改造引导类@Slf4j public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoConfiguration.class, args); } }再次运行项目，可以发现项目可以正常运行但是如果我们访问我们的接口，会发现提示404注意我们DemoConfiguration所在的包cc.lisen.demo.config,@SpringBootApplication只会扫描当前包及下级包，所以，我们的接口它扫描不到，就提示404。如果希望我们其他的类被扫描到，我们就需要添加scanBasePackages属性。package cc.lisen.demo.config; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication(scanBasePackages = {"cc.lisen.demo"}) public class DemoConfiguration { }重启项目，在访问接口，发现能正常访问
-
理解SpringBoot 中的@AliasFor注解 感觉Spring Boot中的@AliasFor注解是一个既熟悉又陌生的注解。说熟悉，是因为我们经常使用的比如@Service、@RestController、@Repository甚至@SpringBootApplication中都有他们的身影。说陌生，是因为其实从来没有真正用过这个注解。@AliasFor注解有两个作用：定义一个注解中的两个属性互为别名。桥接其他注解的属性。一、定义一个注解中的两个属性互为别名。我们以ComponentScan注解为例，先来看下ComponentScan的定义@Retention(RetentionPolicy.RUNTIME) @Target({ElementType.TYPE}) @Documented @Repeatable(ComponentScans.class) public @interface ComponentScan { @AliasFor("basePackages") String[] value() default {}; @AliasFor("value") String[] basePackages() default {}; Class<?>[] basePackageClasses() default {}; Class<? extends BeanNameGenerator> nameGenerator() default BeanNameGenerator.class; Class<? extends ScopeMetadataResolver> scopeResolver() default AnnotationScopeMetadataResolver.class; ScopedProxyMode scopedProxy() default ScopedProxyMode.DEFAULT; String resourcePattern() default "**/*.class"; boolean useDefaultFilters() default true; ComponentScan.Filter[] includeFilters() default {}; ComponentScan.Filter[] excludeFilters() default {}; boolean lazyInit() default false; @Retention(RetentionPolicy.RUNTIME) @Target({}) public @interface Filter { FilterType type() default FilterType.ANNOTATION; @AliasFor("classes") Class<?>[] value() default {}; @AliasFor("value") Class<?>[] classes() default {}; String[] pattern() default {}; } }以上代码，我们关注点在于 @AliasFor("basePackages") String[] value() default {}; @AliasFor("value") String[] basePackages() default {};这段代码，代表着，在ComponentScan注解中，basePackages属性与value是一样的，可以相互调用。我们可以测试一下@ComponentScan(basePackages = {"cc.lisen.demo"}) @Component @EnableAutoConfiguration @Slf4j public class DemoApplication { public static void main(String[] args) { ComponentScan componentScan = AnnotatedElementUtils.getMergedAnnotation(DemoApplication.class, ComponentScan.class); assert componentScan != null; System.out.println(Arrays.toString(componentScan.basePackages())); System.out.println(Arrays.toString(componentScan.value())); SpringApplication.run(DemoApplication.class, args); } }二、桥接其他注解的属性这次，我们看下@Service的代码@Target({ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented @Component public @interface Service { @AliasFor( annotation = Component.class ) String value() default ""; }可以看到，@Service将value属性，桥接到了@Component注解的value属性。@ComponentScan(basePackages = {"cc.lisen.demo"}) @Component @EnableAutoConfiguration @Slf4j public class DemoApplication { public static void main(String[] args) { Component component = AnnotatedElementUtils.getMergedAnnotation(BookService.class, Component.class); assert component != null; System.out.println(component.value()); SpringApplication.run(DemoApplication.class, args); } }
-
Spring PostConstruct注解的使用 一、基本介绍@PostConstruct该注解被用来修饰一个非静态的void()方法。被@PostConstruct修饰的方法会在服务器加载Servlet的时候运行，并且只会被服务器执行一次。@PostConstruct在构造函数之后执行，init()方法之前执行。通常我们会是在Spring框架中使用到@PostConstruct注解 该注解的方法在整个Bean初始化中的执行顺序：Constructor(构造方法) -> @Autowired(依赖注入) -> @PostConstruct(注解的方法)二、用途@PostConstruct主要用于处理一些初始化工作。比如下面代码@RestController @RequestMapping(value = "book") @Slf4j public class BookController { @Resource private IBookService bookService; /** * 构造函数 */ public BookController() { log.info("构造函数，此时bookService ：" + bookService); } @PostConstruct public void init() { log.info("PostConstruct，此时bookService ：" + bookService); } @GetMapping(value = "search") public List<Book> search() { return bookService.search(); } }看下控制台可以看到，构造函数里面，Bean还没有初始化,@PostConstruct里面已经完成初始化，所以，我们可以通过@PostConstruct完成一些初始化后的操作。
-
Spring Cloud集成Gateway 一、SpringCloud Gateway 简介SpringCloud Gateway 是 Spring Cloud 的一个全新项目，该项目是基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等技术开发的网关，它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。SpringCloud Gateway 作为 Spring Cloud 生态系统中的网关，目标是替代 Zuul，在Spring Cloud 2.0以上版本中，没有对新版本的Zuul 2.0以上最新高性能版本进行集成，仍然还是使用的Zuul 2.0之前的非Reactor模式的老版本。而为了提升网关的性能，SpringCloud Gateway是基于WebFlux框架实现的，而WebFlux框架底层则使用了高性能的Reactor模式通信框架Netty。Spring Cloud Gateway 的目标，不仅提供统一的路由方式，并且基于 Filter 链的方式提供了网关基本的功能，例如：安全，监控/指标，和限流。二、SpringCloud Gateway 特征SpringCloud官方，对SpringCloud Gateway 特征介绍如下：基于 Spring Framework 5，Project Reactor 和 Spring Boot 2.0集成 Hystrix 断路器集成 Spring Cloud DiscoveryClientPredicates 和 Filters 作用于特定路由，易于编写的 Predicates 和 Filters具备一些网关的高级功能：动态路由、限流、路径重写从以上的特征来说，和Zuul的特征差别不大。SpringCloud Gateway和Zuul主要的区别，还是在底层的通信框架上。简单说明一下上文中的三个术语：Filter（过滤器）：和Zuul的过滤器在概念上类似，可以使用它拦截和修改请求，并且对上游的响应，进行二次处理。过滤器为org.springframework.cloud.gateway.filter.GatewayFilter类的实例。Route（路由）：网关配置的基本组成模块，和Zuul的路由配置模块类似。一个Route模块由一个ID，一个目标URI，一组断言和一组过滤器定义。如果断言为真，则路由匹配，目标URI会被访问。Predicate（断言）：这是一个 Java 8 的Predicate，可以使用它来匹配来自HTTP请求的任何内容，例如headers或参数。断言的输入类型是一个 ServerWebExchange。三、Spring Cloud Gateway的处理流程客户端向 Spring Cloud Gateway 发出请求。然后在Gateway Handler Mapping中找到与请求相匹配的路由，将其发送到Gateway Web Handler。Handler再通过指定的过滤器链来将请求发送到我们实际的服务执行业务逻辑，然后返回。过滤器之间用虚线分开是因为过滤器可能会在发送代理请求之前（pre）或之后（post）执行业务逻辑。四、路由匹配规则对于这种配置类的，我们一般情况都会放到配置文件中去配置。Spring Cloud Gateway 的功能很强大，我们仅仅通过 Predicates 的设计就可以看出来，前面我们只是使用了 predicates 进行了简单的条件匹配，其实 Spring Cloud Gataway 帮我们内置了很多 Predicates 功能。Spring Cloud Gateway 是通过 Spring WebFlux 的 HandlerMapping 做为底层支持来匹配到转发路由，Spring Cloud Gateway 内置了很多 Predicates 工厂，这些 Predicates 工厂通过不同的 HTTP 请求参数来匹配，多个 Predicates 工厂可以组合使用。代码Demo父工程依赖<dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>2.3.12.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Hoxton.SR12</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-dependencies</artifactId> <!-- <version>2.1.0.RELEASE</version>--> <version>2.2.1.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>${druid.version}</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>${mysql.version}</version> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>${mybatis.spring.boot.version}</version> </dependency> </dependencies> </dependencyManagement>当前模块依赖 <dependencies> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> </dependency> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> </dependencies>配置文件server: port: 9527 spring: application: name: cloud-gateway-service cloud: nacos: discovery: server-addr: 192.168.120.180:8848 gateway: discovery: locator: enabled: true routes: - id: payment-routh uri: lb://nacos-provider-payment # 服务名称 predicates: - Path=/app/** - Header=username,laughing可以看到gateway的路由匹配规格主要是包含id、uri、predicates。id随意指定，唯一即可。uri代表配置的路径，可以匹配URL或者服务名称，如果是服务名称，以lb:打头。predicates代表断言，条件为true时才能进入对应的路径。说白了 Predicate 就是为了实现一组匹配规则，方便让请求过来找到对应的 Route 进行处理，接下来我们接下 Spring Cloud GateWay 内置几种 Predicate 的使用。假定转发uri都设定为lb://nacos-provider-payment规则实例说明Path- Path=/gate/,/rule/当请求的路径为gate、rule开头的时，转发到nacos-provider-payment服务Before- Before=2017-01-20T17:42:47.789-07:00[America/Denver]在某个时间之前的请求才会被转发到nacos-provider-payment服务After- After=2017-01-20T17:42:47.789-07:00[America/Denver]在某个时间之后的请求才会被转发到nacos-provider-payment服务Between- Between=2017-01-20T17:42:47.789-07:00[America/Denver],2017-01-21T17:42:47.789-07:00[America/Denver]在某个时间段之间的才会被转发Cookie- Cookie=chocolate, ch.p名为chocolate的表单或者满足正则ch.p的表单才会被匹配到进行请求转发Header- Header=X-Request-Id, \d+携带参数X-Request-Id或者满足\d+的请求头才会匹配Host- Host=lisen.cc当主机名为lisen.cc的时候直接转发到nacos-provider-payment服务Method- Method=GET只有GET方法才会匹配转发请求，还可以限定POST、PUT等请求方式测试我们上面代码的匹配规则如果我们访问的路径是/echo开头，并且Header中username=laughing就转发到nacos-provider-payment服务。第一次正常访问第二次，我们配置Header可以看到报404第三次，我们配置Header但是参数值设置为test,可以看到也是报404其他参数配置我们不再测试。五、过滤器规则（Filter）过滤规则实例说明PrefixPath- PrefixPath=/app在请求路径前加上appRewritePath- RewritePath=/test, /app/test访问localhost:9022/test,请求会转发到localhost:8001/app/testSetPathSetPath=/app/{path}通过模板设置路径，转发的规则时会在路径前增加app，{path}表示原请求路径RedirectTo 重定向RemoveRequestHeader 去掉某个请求头信息测试Demo我们只测试一个PrefixPath服务提供者 @GetMapping(value = "app/echo/{string}") public String echo1(@PathVariable("string") String string) { return "app/echo/{string} " + string+"\t当前服务端口:"+serverPort; }配置文件server: port: 9527 spring: application: name: cloud-gateway-service cloud: nacos: discovery: server-addr: 192.168.120.180:8848 gateway: discovery: locator: enabled: true routes: - id: payment-routh uri: lb://nacos-provider-payment # 服务名称 predicates: - Path=/** filters: PrefixPath=/app测试
