扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这期内容当中小编将会给大家带来有关如何进行Spring MVC框架集成本地HTTP请求和Spring Cloud RPC请求,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
溆浦网站制作公司哪家好,找创新互联建站!从网页设计、网站建设、微信开发、APP开发、响应式网站开发等网站项目制作,到程序开发,运营维护。创新互联建站公司2013年成立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联建站。
请求路径,比如:uri加/rpc前缀用来标识RPC请求
请求头信息,比如:Accept:application/sc-rpc 用来标识RPC请求
对Spring MVC的消息转换进行封装:
输入(@RequestBody): 重写com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter#read方法,对本地请求和RPC请求做兼容。
@Override public Object read(Type type, Class> contextClass, HttpInputMessage inputMessage) throws IOException { try { // transform inputStream to string ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); IOUtils.copy(inputMessage.getBody(), byteArrayOutputStream); String str = byteArrayOutputStream.toString(StandardCharsets.UTF_8.name()); // parse json object JSONObject jsonObject = JSON.parseObject(str, super.getFastJsonConfig().getFeatures()); // if RPC, transform the data format if (jsonObject.containsKey("data")) { return JSON.parseObject(jsonObject.getString("data"), type, super.getFastJsonConfig().getFeatures()); } // otherwise, call super method return readType(super.getType(type, contextClass), new ByteArrayInputStream(byteArrayOutputStream.toByteArray())); } catch (JSONException ex) { throw new HttpMessageNotReadableException("JSON parse error: " + ex.getMessage(), ex); } catch (IOException ex) { throw new IOException("I/O error while reading input message", ex); } } private Object readType(Type type, InputStream in) { try { return JSON.parseObject(in, super.getFastJsonConfig().getCharset(), type, super.getFastJsonConfig().getParserConfig(), super.getFastJsonConfig().getParseProcess(), JSON.DEFAULT_PARSER_FEATURE, super.getFastJsonConfig().getFeatures()); } catch (JSONException ex) { throw new HttpMessageNotReadableException("JSON parse error: " + ex.getMessage(), ex); } catch (IOException ex) { throw new HttpMessageNotReadableException("I/O error while reading input message", ex); } }
输出(@ResponseBody):
重写com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter#writeInternal方法,本地请求和RPC请求的数据格式保持一致。
package com.caiya.web.base; import com.alibaba.fastjson.JSONPObject; import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter; import com.caiya.web.constant.CommonConstant; import com.google.common.base.Joiner; import org.springframework.http.HttpOutputMessage; import org.springframework.http.converter.HttpMessageNotWritableException; import java.io.IOException; /** * fastjson消息转换器. */ public class ExtendedFastJsonHttpMessageConverter extends FastJsonHttpMessageConverter { @Override protected void writeInternal(Object object, HttpOutputMessage outputMessage) throws IOException, HttpMessageNotWritableException { super.writeInternal(wrapResult(object), outputMessage); } private Object wrapResult(Object object) { // 防止json请求重复包装 if (object instanceof ResponseDataWrapper) { return object; } if (object instanceof JSONPObject) { JSONPObject jsonpObject = (JSONPObject) object; JSONPObject newJsonpObject = new JSONPObject(jsonpObject.getFunction()); ResponseDataWrapper data; if (jsonpObject.getParameters().size() == 1) { // 防止jsonp请求重复包装 if (jsonpObject.getParameters().get(0) instanceof ResponseDataWrapper) { return object; } data = ResponseDataWrapperBuilder.build(jsonpObject.getParameters().get(0)); } else if (jsonpObject.getParameters().size() > 1) { data = ResponseDataWrapperBuilder.build(Joiner.on(",").join(jsonpObject.getParameters())); } else { data = ResponseDataWrapperBuilder.build(CommonConstant.PLACEHOLDER_OBJECT_EMPTY); } newJsonpObject.addParameter(data); return newJsonpObject; } return ResponseDataWrapperBuilder.build(object); } }
输入:
不需要处理,RPC请求时指定Accept即可:
package com.caiya.test.spring.cloud.configuration; import org.apache.http.HttpHost; import org.apache.http.client.HttpClient; import org.apache.http.client.config.RequestConfig; import org.apache.http.impl.client.DefaultConnectionKeepAliveStrategy; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.message.BasicHeader; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.util.Collections; import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.TimeUnit; @Configuration public class FeignConfig { @Bean public HttpClient httpClient() { System.out.println("init feign httpclient configuration 1111"); // 生成默认请求配置 RequestConfig.Builder requestConfigBuilder = RequestConfig.custom(); // 超时时间 requestConfigBuilder.setSocketTimeout(5 * 1000); // 连接时间 requestConfigBuilder.setConnectTimeout(5 * 1000); // 设置代理 // requestConfigBuilder.setProxy(new HttpHost("127.0.0.1", 8880)); RequestConfig defaultRequestConfig = requestConfigBuilder.build(); // 连接池配置 // 长连接保持30秒 final PoolingHttpClientConnectionManager pollingConnectionManager = new PoolingHttpClientConnectionManager(30, TimeUnit.MILLISECONDS); // 总连接数 pollingConnectionManager.setMaxTotal(5000); // 同路由的并发数 pollingConnectionManager.setDefaultMaxPerRoute(100); // httpclient 配置 HttpClientBuilder httpClientBuilder = HttpClientBuilder.create(); // 保持长连接配置,需要在头添加Keep-Alive httpClientBuilder.setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()); httpClientBuilder.setConnectionManager(pollingConnectionManager); httpClientBuilder.setDefaultRequestConfig(defaultRequestConfig); httpClientBuilder.setDefaultHeaders(Collections.singleton(new BasicHeader("Accept", "application/sc-rpc"))); HttpClient client = httpClientBuilder.build(); // 启动定时器,定时回收过期的连接 /*Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() { // System.out.println("=====closeIdleConnections==="); pollingConnectionManager.closeExpiredConnections(); pollingConnectionManager.closeIdleConnections(5, TimeUnit.SECONDS); } }, 10 * 1000, 5 * 1000);*/ System.out.println("===== Apache httpclient 初始化连接池==="); return client; } }
输出:
根据mediaType区分消息转换。
package com.caiya.web.configuration; import com.alibaba.fastjson.serializer.SerializerFeature; import com.alibaba.fastjson.support.config.FastJsonConfig; import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter; import com.caiya.web.base.ExtendedFastJsonHttpMessageConverter; import org.springframework.boot.autoconfigure.http.HttpMessageConverters; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.http.MediaType; import java.util.Arrays; import java.util.Collections; /** * fastjson消息转换器配置. * * @author caiya * @since 1.0 */ @Configuration public class FastJsonConfiguration { @Bean public HttpMessageConverters extendedFastJsonHttpMessageConverter() { // for web controller FastJsonHttpMessageConverter fastJsonHttpMessageConverter = new ExtendedFastJsonHttpMessageConverter(); FastJsonConfig fastJsonConfig = new FastJsonConfig(); fastJsonConfig.setSerializerFeatures(SerializerFeature.DisableCircularReferenceDetect); // fastJsonConfig.setSerializerFeatures(SerializerFeature.WriteMapNullValue); fastJsonHttpMessageConverter.setFastJsonConfig(fastJsonConfig); fastJsonHttpMessageConverter.setSupportedMediaTypes(Arrays.asList(MediaType.APPLICATION_JSON, MediaType.APPLICATION_JSON_UTF8)); // for web resource(Spring Cloud RPC) FastJsonHttpMessageConverter fastJsonHttpMessageConverterPlain = new FastJsonHttpMessageConverter(); FastJsonConfig fastJsonConfigPlain = new FastJsonConfig(); fastJsonConfigPlain.setSerializerFeatures(SerializerFeature.DisableCircularReferenceDetect); // fastJsonConfigPlain.setSerializerFeatures(SerializerFeature.WriteMapNullValue); fastJsonHttpMessageConverterPlain.setFastJsonConfig(fastJsonConfigPlain); fastJsonHttpMessageConverterPlain.setSupportedMediaTypes(Collections.singletonList(MediaType.valueOf("application/sc-rpc"))); return new HttpMessageConverters(fastJsonHttpMessageConverter, fastJsonHttpMessageConverterPlain); } }
在每个controller的method,返回最终响应内容。
通过aop处理不同的请求(RPC请求不处理即可):
package com.caiya.web.base; import com.alibaba.fastjson.JSONPObject; import com.caiya.web.constant.CommonConstant; import com.google.common.base.Joiner; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Pointcut; import org.springframework.stereotype.Component; /** * 对响应内容的包装处理AOP. */ @Component @Aspect public class ResponseDataWrapperAspect { @Pointcut("execution(* com.caiya.web.controller.rest..*(..))") public void aspect() { } @Around("aspect()") public Object around(ProceedingJoinPoint joinPoint) throws Throwable { Object object = joinPoint.proceed(joinPoint.getArgs()); return wrapResult(object); } private Object wrapResult(Object object) { // 防止json请求重复包装 if (object instanceof ResponseDataWrapper) { return object; } if (object instanceof JSONPObject) { JSONPObject jsonpObject = (JSONPObject) object; JSONPObject newJsonpObject = new JSONPObject(jsonpObject.getFunction()); ResponseDataWrapper data; if (jsonpObject.getParameters().size() == 1) { // 防止jsonp请求重复包装 if (jsonpObject.getParameters().get(0) instanceof ResponseDataWrapper) { return object; } data = ResponseDataWrapperBuilder.build(jsonpObject.getParameters().get(0)); } else if (jsonpObject.getParameters().size() > 1) { data = ResponseDataWrapperBuilder.build(Joiner.on(",").join(jsonpObject.getParameters())); } else { data = ResponseDataWrapperBuilder.build(CommonConstant.PLACEHOLDER_OBJECT_EMPTY); } newJsonpObject.addParameter(data); return newJsonpObject; } return ResponseDataWrapperBuilder.build(object); } }
对RPC请求都不必拦截,放行处理(包括会话拦截器、权限拦截器、XSS过滤器等)
RPC请求只允许通过Spring Cloud注册中心、网关等调用[schema]://[ip]:[port]/[request_uri] 的形式 ,nginx 需要拦截路径包含 /rpc/ 目录的 RPC 接口调用(彻底隔离只需分离本地请求和RPC请求的应用即可):
location ~* /rpc/ { return 403; }
推荐最外层包裹一层Result对象,表示接口执行结果,包含经过处理的异常信息
开启feignclient的hystrix熔断:
feign: hystrix: enabled: true
实现接口feign.codec.ErrorDecoder,处理服务端异常:
package com.caiya.web.configuration; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.netflix.hystrix.exception.HystrixBadRequestException; import feign.Response; import feign.Util; import feign.codec.ErrorDecoder; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.openfeign.FeignClientsConfiguration; import org.springframework.context.annotation.Configuration; import java.io.IOException; /** * Spring Cloud(feign with hystrix)自定义异常处理. * * @see FeignClientsConfiguration.HystrixFeignConfiguration#feignHystrixBuilder() 开启hystrix入口 * @see HystrixBadRequestException 此异常类型不会进行熔断操作 * HystrixBadRequestException.message: * {"path":"/rpc/session/user/info","error":"Internal Server Error","message":"Illegal Agument Exception..","timestamp":1540266379459,"status":500} */ @Configuration public class FeignErrorDecoder implements ErrorDecoder { private static final Logger logger = LoggerFactory.getLogger(FeignErrorDecoder.class); @Override public Exception decode(String methodKey, Response response) { String message = null; if (response.status() >= 400 && response.status() <= 500) { try { if (response.body() != null) { String body = Util.toString(response.body().asReader()); try { JSONObject jsonObject = JSON.parseObject(body); if (jsonObject.containsKey("data")) { JSONObject content = jsonObject.getJSONObject("data"); if (StringUtils.isNotBlank(content.getString("message"))) { message = content.getString("message"); if ("connect timed out".equals(message)) { return feign.FeignException.errorStatus(methodKey, response); } } else { message = content.getString("error"); } } if (message == null) { message = jsonObject.getString("message"); } } catch (Exception e) { logger.error(e.getMessage(), e); message = body; } } } catch (IOException e) { logger.error(e.getMessage(), e); } return new HystrixBadRequestException(message); } return feign.FeignException.errorStatus(methodKey, response); } }
处理超时异常,实现@FeignClient注解中的属性fallback或fallbackFactory的相关类,进行熔断处理
上述就是小编为大家分享的如何进行Spring MVC框架集成本地HTTP请求和Spring Cloud RPC请求了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流