CAS5.3使用JPA实现动态注册服务

cas同时支持cas协议和OAuth2协议,官方默认是通过扫描json文件的形式注册客户端服务,但是此种方式需要重启服务才能生效,此次我们将使用JPA来完美实现动态注册服务,如果不知道cas如何部署,可以擦看之前的文章

cas-client基于CAS协议客户端搭建-CSDN博客

cas-server5.3自定义密码校验规则_cas-server 自定义加密验证-CSDN博客

CAS服务端的搭建并配置OAtuh2.0协议_cas oauth2.0-CSDN博客

添加pom依赖

<dependency><groupId>org.apereo.cas</groupId><artifactId>cas-server-support-jpa-service-registry</artifactId><version>${cas.version}</version>
</dependency>
<dependency><groupId>org.apereo.cas</groupId><artifactId>cas-server-core-services-api</artifactId><version>${cas.version}</version>
</dependency>
<dependency><groupId>org.apereo.cas</groupId><artifactId>cas-server-core-authentication-attributes</artifactId><version>${cas.version}</version>
</dependency>

添加配置

#数据库用户名
cas.serviceRegistry.jpa.user=root
#数据库密码
cas.serviceRegistry.jpa.password=root
#mysql驱动
cas.serviceRegistry.jpa.driverClass=com.mysql.cj.jdbc.Driver
#数据库连接
cas.serviceRegistry.jpa.url=jdbc:mysql://localhost:3306/db_user?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false
cas.serviceRegistry.jpa.dialect=org.hibernate.dialect.MySQL5Dialect
#连接池配置
cas.serviceRegistry.jpa.pool.suspension=false
cas.serviceRegistry.jpa.pool.minSize=6
cas.serviceRegistry.jpa.pool.maxSize=18
cas.serviceRegistry.jpa.pool.maxWait=2000
cas.serviceRegistry.jpa.pool.timeoutMillis=1000
#默认为create-drop，表示每次启动服务都会清除你之前注册的cas服务
cas.serviceRegistry.jpa.ddlAuto=update

第一次启动需要将cas.serviceRegistry.jpa.ddlAuto设置为create-drop,启动后会创建如下表结构

编写逻辑

@RestController
@RequestMapping
public class RegistrationServiceController {@Autowired@Qualifier("servicesManager")private ServicesManager servicesManager;@Autowiredprivate RegexregisteredserviceService regexregisteredserviceService;@GetMapping("/addOAuth")public void addOAuthClient(@RequestParam("serviceId") String serviceId,@RequestParam("clientId") String clientId,@RequestParam("clientSecret") String clientSecret,@RequestParam("name")String name) {OAuthRegisteredService service = new OAuthRegisteredService();ReturnAllAttributeReleasePolicy re = new ReturnAllAttributeReleasePolicy();service.setClientId(clientId);service.setClientSecret(clientSecret);service.setServiceId(serviceId);service.setAttributeReleasePolicy(re);service.setName(name);servicesManager.save(service);// 执行load让他生效servicesManager.load();}@GetMapping("/addCas")public void addOAuthClient(@RequestParam("serviceId") String serviceId,@RequestParam("name")String name) {RegexRegisteredService service = new RegexRegisteredService();ReturnAllAttributeReleasePolicy re = new ReturnAllAttributeReleasePolicy();service.setServiceId(serviceId);service.setAttributeReleasePolicy(re);service.setName(name);servicesManager.save(service);// 执行load让他生效servicesManager.load();}@GetMapping("/deleteService")public void deleteServiceClient(@RequestParam("id") String id) {regexregisteredserviceService.removeById(id);// 执行load让他生效servicesManager.load();}

可以看到这个controller中最主要的就是ServicesManager 这个Bean,可以看一下它的源码,这里提供了对于服务操作的实现,这里我们主要用到的是load方法,其作用是当我们增加或删除一个服务后执行load()方法会使我们的修改生效,可以理解为是一个刷新的操作

其中这不分的参数,可以参考 resources.services下的json文件的参数来添加,