Shulou(Shulou.com)05/31 Report--

This article mainly explains "how to configure fastjson serialization verification in SpringCloud Gateway". Interested friends may wish to take a look. The method introduced in this paper is simple, fast and practical. Let's let the editor take you to learn how to configure fastjson serialization verification in SpringCloud Gateway.

First, reactive redis package and fastjson package are introduced into maven.

Org.springframework.boot spring-boot-starter-data-redis-reactive com.alibaba fastjson ${fastjson.version}

Write RedisAutoConfig.class to customize ReactiveRedisTemplate Bean configuration

What I use here is that ReactiveRedisTemplate,key is of type String and value is of type Object, so that value can operate directly with Java objects without the need for display to serialize and deserialize fastjson.

It is important to note that a RedisSerializationContext object needs to be passed in new ReactiveRedisTemplate, and the key and value serialization of redis is configured in RedisSerializationContext.

Here we use StringRedisSerializer to serialize key and hashKey, and fastjson's GenericFastJsonRedisSerializer to serialize value and hashValue.

@ Configurationpublic class RedisAutoConfig {@ Bean public ReactiveRedisTemplate reactiveRedisTemplate (LettuceConnectionFactory connectionFactory) {StringRedisSerializer stringRedisSerializer = new StringRedisSerializer (); GenericFastJsonRedisSerializer fastJsonRedisSerializer = new GenericFastJsonRedisSerializer (); RedisSerializationContext.SerializationPair keySerializationPair = RedisSerializationContext.SerializationPair.fromSerializer (stringRedisSerializer); RedisSerializationContext.SerializationPair valueSerializationPair = RedisSerializationContext.SerializationPair.fromSerializer (fastJsonRedisSerializer); RedisSerializationContext.SerializationPair hashValueSerializationPair = RedisSerializationContext.SerializationPair.fromSerializer (fastJsonRedisSerializer) RedisSerializationContext context = new RedisSerializationContext () {@ Override public SerializationPair getKeySerializationPair () {return keySerializationPair;} @ Override public SerializationPair getValueSerializationPair () {return valueSerializationPair;} @ Override public SerializationPair getHashKeySerializationPair () {return keySerializationPair } @ Override public SerializationPair getHashValueSerializationPair () {return hashValueSerializationPair;} @ Override public SerializationPair getStringSerializationPair () {return keySerializationPair;}}; return new ReactiveRedisTemplate (connectionFactory, context);}}

After the configuration is completed, the ReactiveRedisTemplate object can be automatically injected directly.

@ Autowiredprivate ReactiveRedisTemplate reactiveRedisTemplate

First introduce spring cloud gateway dependency into maven

Org.springframework.cloud spring-cloud-starter-gateway

Write a custom filter factory TokenVerifyGatewayFilterFactory for custom token check

First, extract the token field from the header of request, query the redis according to token, and extract the user id corresponding to token. If the user id exists, the token is valid, if it does not exist, the token is invalid.

@ Componentpublic class TokenVerifyGatewayFilterFactory extends AbstractGatewayFilterFactory {@ Autowired private ReactiveRedisTemplate reactiveRedisTemplate; @ Override public GatewayFilter apply (Object config) {return (exchange, chain)-> {ServerHttpRequest request = exchange.getRequest (); String token = request.getHeaders () .get ("token") .get (0) Return this.getUserId (token) .flatMap (op-> {/ / 1) to determine whether there is a corresponding cache in redis. If it does not exist, return token invalid if (! op.isPresent ()) {ServerHttpResponse response = exchange.getResponse (); byte [] bits = "invalid token" .getBytes (StandardCharsets.UTF_8) DataBuffer buffer = response.bufferFactory (). Wrap (bits); response.setStatusCode (HttpStatus.UNAUTHORIZED); response.getHeaders (). Add (Content-Type, text/plain;charset=UTF-8); return response.writeWith (Mono.just (buffer)) } / / 2. Cache is valid. Get userId, log record or other operations System.out.println ("redis cache token user:" + op.get ()); / / 3. Token authentication passed, continue to execute filter to complete forwarding return chain.filter (exchange);});} } private Mono getUserId (String token) {/ / a, query redis in the way of reactive, get the value corresponding to token return this.reactiveRedisTemplate.opsForValue (). Get (token) / / b, encapsulate the returned result of redis with Optional, where v is the user of String type id .map (v-> Optional.ofNullable ((String) v)) / / c, if token is invalid B will not be executed, and an Optional object with a value of null is returned here. SwitchIfEmpty (Mono.just (Optional.ofNullable (null) }}

Write SpringCloudGateway configuration file

For any uri, TokenVerifyGatewayFilterFactory is used for request filtering and any request from localhost:8080 is forwarded to https://www.baidu.com.

Spring: cloud: gateway: routes:-id: testRoute uri: https://www.baidu.com predicates:-Path=/** filters:-TokenVerify

Redis cache data settings

Cache key= "goodToken" and value= "magicTan" in Redis, that is, goodToken is a legal token and user id is magicTan. If you use an illegal token such as invalidToken, you will not be able to get the user id.

Run the project for testing

If you set token to goodToken in localhost:8080,header, you can see that the request is forwarded to Baidu, and the console outputs the cached user id.

At this point, I believe you have a deeper understanding of "how to configure fastjson serialization verification in SpringCloud Gateway". You might as well do it in practice. Here is the website, more related content can enter the relevant channels to inquire, follow us, continue to learn!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.