添加链接 注册    登录
link之家
链接快照平台
  • 输入网页链接，自动生成快照
  • 标签化管理网页链接
相关文章推荐
忐忑的灯泡  ·  云南省扫黑除恶专项斗争系列新闻发布会·省检察 ...·  2 周前    · 
卖萌的伏特加  ·  孟晚舟与姚安娜姐妹情深，姐姐鼓励妹妹坚定所爱 ...·  1 月前    · 
沉稳的墨镜  ·  古风不“殇”：一个圈子的起落·  3 月前    · 
完美的消炎药  ·  西行纪漫画神战篇是新片吗 - 抖音·  1 年前    · 
爱喝酒的牙膏  ·  宝马集团：加快电动化进程，计划到2030年电 ...·  1 年前    · 
link之家  ›  spring boot-实现WebService(CXF实现)的拦截器(Interceptor)_post_invoke_牛奋lch的博客
token spring框架 header post请求
https://blog.csdn.net/liuchuanhong1/article/details/72627446
文武双全的豆腐
1 年前
拦截器（Interceptor）是CXF功能最主要的扩展点，可以在不对核心模块进行修改的情况下，动态添加很多功能。拦截器和JAX-WS Handler、Filter的功能类似，当服务被调用时，就会创建一个拦截器链（Interceptor Chain），拦截器链在服务输入（IN）或输出（OUT）阶段实现附加功能。

拦截器可以在客户端，也可以在服务端添加。当客户端发起一个WebService请求时，在客户端会创建输出拦截器链(outinterceptor)，服务端接收到客户端的后，会创建输入拦截器链(ininterceptor)。当服务端返回响应消息时，响应消息会经过服务端的输出拦截链，客户端接收到服务端的响应时，会创建输入拦截器链，响应消息先经过输入拦截器链处理。拦截器在服务端和客户端的作用如图所示。

注：上图来源于网络。

下面，我们以一个Header认证为例，来演示CXF的拦截器的使用。

1、客户端拦截器 

public class ClientAuthorInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
	 * 客户端申请的token信息
	private String token;
	public ClientAuthorInterceptor(String token) {
		// 设置拦截器的时机，在发送请求到服务端之前进行拦截
		super(Phase.PREPARE_SEND);
		this.token = token;
	@Override
	public void handleMessage(SoapMessage soap) throws Fault {
     // 在soap消息中添加认证头信息
     List<Header> headers = soap.getHeaders();
		Document doc = DOMUtils.createDocument();
		Element auth = doc.createElement(AuthorHeader.HEADER_NAME);
		Element token = doc.createElement(AuthorHeader.HEADER_TOKEN);
		token.setTextContent(this.token);
		auth.appendChild(token);
		Header header = new SoapHeader(new QName(AuthorHeader.HEADER_NAME), auth);
		headers.add(header);
}
注意：客户端是outinterceptor

2、服务端拦截器

下面，服务端对发送的消息进行拦截，并做认证 

@Slf4j
@Component
public class AuthInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
	@Autowired
	private AuthorizationRepository repository;
	public AuthInterceptor() {
		super(Phase.USER_LOGICAL);
	@Override
	public void handleMessage(SoapMessage message) throws Fault {
		Header header = message.getHeader(new QName("authrity"));
		if(null == header){
			log.warn("token没有认证通过!原因为：客户端请求中不存在认证的Header");
			throw new Fault(new AuthenticationException("token没有认证通过!原因为：客户端请求中不存在认证的Header"));
		Element ele = (Element) header.getObject();
		if(null == ele){
			log.warn("token没有认证通过!原因为：客户端请求中认证的Header无认证信息");
			throw new Fault(new AuthenticationException("token没有认证通过!原因为：客户端请求中认证的Header无认证信息"));
		Node node = ele.getFirstChild();
		if(null == node){
			log.warn("token没有认证通过!原因为：客户端请求中认证的Header无认证信息");
			throw new Fault(new AuthenticationException("token没有认证通过!原因为：客户端请求中认证的Header无认证信息"));
		String token = node.getTextContent();
		if(null == token || token.isEmpty()){
			log.warn("token没有认证通过!原因为：客户端请求中认证的Header无token信息");
			throw new Fault(new AuthenticationException("token没有认证通过!原因为：客户端请求中认证的Header无token信息"));
		Authorization auth = repository.findByToken(token);
		if(null == auth){
			log.warn("token没有认证通过!原因为：客户端请求中认证的token信息无效，请查看申请流程中的正确token信息");
			throw new Fault(new AuthenticationException("token没有认证通过!原因为：客户端请求中认证的token信息无效，请查看申请流程中的正确token信息，流程申请地址:http://127.0.0.1:8080/email"));
		log.info("客户端认证成功，token有效!");
}
注：服务端为ininterceptor

编写拦截器很简单，只需继承AbstractPhaseInterceptor类并实现handleMessage即可。

3、spring boot配置拦截器，并发布服务 

@Configuration
public class WebserviceConfig {
	@Autowired
	private EmailService emailService;
	@Autowired
	private AuthInterceptor interceptor;
	@Autowired
	private ValidateInterceptor validateInterceptor;
	@Bean(name = Bus.DEFAULT_BUS_ID)
	public SpringBus springBus() {
		return new SpringBus();
	 * attention:
	 * Details：发布WebService服务
	 * @author chhliu
	 * 创建时间：2017年5月22日 上午11:30:08
	 * @return
	 * Endpoint
	@Bean
	public Endpoint endpoint() {
		EndpointImpl endPoint = new EndpointImpl(springBus(), emailService);
		endPoint.publish("/eamil");
		endPoint.getInInterceptors().add(interceptor); // 添加Header认证拦截器
		endPoint.getInInterceptors().add(validateInterceptor);// 添加消息格式校验拦截器
		return endPoint;
}
4、拦截器的Phase

Phase用来控制拦截器的工作时机，目前CXF支持的Phase如下： 

public static final String SETUP = "setup";// 设置阶段
    public static final String SETUP_ENDING = "setup-ending"; // 设置完之后
    public static final String PRE_LOGICAL = "pre-logical";// 程序对象编码
    public static final String PRE_LOGICAL_ENDING = "pre-logical-ending";
    public static final String USER_LOGICAL = "user-logical";
    public static final String USER_LOGICAL_ENDING = "user-logical-ending";
    public static final String POST_LOGICAL = "post-logical";
    public static final String POST_LOGICAL_ENDING = "post-logical-ending";
    public static final String PRE_MARSHAL = "pre-marshal";
    public static final String MARSHAL = "marshal";
    public static final String POST_MARSHAL = "post-marshal";
    public static final String MARSHAL_ENDING = "marshal-ending";
    public static final String PRE_PROTOCOL = "pre-protocol";
    public static final String PRE_PROTOCOL_FRONTEND = "pre-protocol-frontend";
    public static final String PRE_PROTOCOL_ENDING = "pre-protocol-ending";
    public static final String USER_PROTOCOL = "user-protocol";
    public static final String USER_PROTOCOL_ENDING = "user-protocol-ending";
    public static final String POST_PROTOCOL = "post-protocol";
    public static final String POST_PROTOCOL_ENDING = "post-protocol-ending";
    public static final String PREPARE_SEND = "prepare-send";
    public static final String PREPARE_SEND_ENDING = "prepare-send-ending";
    public static final String PRE_STREAM = "pre-stream";
    public static final String PRE_STREAM_ENDING = "pre-stream-ending";
    public static final String USER_STREAM = "user-stream";
    public static final String USER_STREAM_ENDING = "user-stream-ending";
    public static final String POST_STREAM = "post-stream";
    public static final String POST_STREAM_ENDING = "post-stream-ending";
    public static final String WRITE = "write";
    public static final String WRITE_ENDING = "write-ending";
    public static final String SEND = "send";
    public static final String SEND_ENDING = "send-ending";
    public static final String RECEIVE = "receive"; // 接收阶段，传输层处理
    public static final String READ = "read";// SOAPHeader读取
    public static final String PROTOCOL = "protocol";// 协议处理阶段，例如JAX-WS的Handler处理
    public static final String PRE_UNMARSHAL = "pre-unmarshal";// SOAP请求解码之前
    public static final String UNMARSHAL = "unmarshal";// SOAP请求解码阶段
    public static final String POST_UNMARSHAL = "post-unmarshal"; // SOAP请求解码之后
    public static final String PRE_INVOKE = "pre-invoke"; // 调用业务处理之前进入该阶段
    public static final String INVOKE = "invoke"; // 调用业务阶段
    public static final String POST_INVOKE = "post-invoke";// 业务调用之后
以下是ininterceptor定义的Phase

Phase

Functions

RECEIVE

Transport level processing

(PRE/USER/POST)_STREAM

Stream level processing/transformations

READ

This is where header reading typically occurs.

(PRE/USER/POST)_PROTOCOL

Protocol processing, such as JAX-WS SOAP handlers

UNMARSHAL

Unmarshalling of the request

(PRE/USER/POST)_LOGICAL

Processing of the umarshalled request

PRE_INVOKE

Pre invocation actions

INVOKE

Invocation of the service

POST_INVOKE

Invocation of the outgoing chain if there is one

以下是outintercptor定义的Phase

On the outgoing chain there are the following phases:

Phase

Functions

SETUP

Any set up for the following phases

(PRE/USER/POST)_LOGICAL

Processing of objects about to marshalled

PREPARE_SEND

Opening of the connection

PRE_STREAM

PRE_PROTOCOL

Misc protocol actions.

WRITE

Writing of the protocol message, such as the SOAP Envelope.

MARSHAL

Marshalling of the objects

(USER/POST)_PROTOCOL

Processing of the protocol message.

(USER/POST)_STREAM

Processing of the byte level message

SEND

在SEND Phase后，有一堆以*_ENDING Phase以及与之对应的Phase，例如SEND和SEND_ENDING，这类以ENDING结尾的Phase允许清理和关闭与之对应的Phase打开或启动的任何资源。

通过上面的示例，可以发现，CXF的拦截器可以为我们实现很多的附加功能。

拦截器（Interceptor）是CXF功能最主要的扩展点，可以在不对核心模块进行修改的情况下，动态添加很多功能。拦截器和JAX-WS Handler、Filter的功能类似，当服务被调用时，就会创建一个拦截器链（Interceptor Chain），拦截器链在服务输入（IN）或输出（OUT）阶段实现附加功能。拦截器可以在客户端，也可以在服务端添加。当客户端发起一个WebService请求
tutorial-soap- spring - boot - cxf 教程如何使用 ， 和创建，测试，部署，监视SOAP 接下来的每个步骤都基于前一个步骤。 因此，如果从第3步开始，则代码中将覆盖第1步和第2步。 步骤1-3：随博客文章一起发布： （或德语版： ） 向您展示如何设置一个简单的 Spring Boot 应用程序以及如何在嵌入式Tomcat中引导可运行的 CXF -Framework。 从流行的汲取灵感，继承了一个完全更改的示例 WebService -Definition作为WSDL 展示如何在构建时使用JAX-WS Commons Maven插件从WSDL生成JAXB类-只需运行 mvn clean generate-sources 首先使用 Spring Boot ， CXF 和JAX-WS运行SOAP-Endpoint。 对于测试，请使用 （在Unittest中测试我们的服务将是后续步骤的一部分）。 完全合同优先，使用生成的JAX-WS服务类不包装WSDL并使用原始的WSDL-包括正确的URL和TargetNamespace（推荐） 步骤4：随博客文章一起发布： （或德语版本：
现在一般很少会用到 Webservice 了，但有时候和第三方传统机构对接，他们用的可能是 WebService 。这里写下 CXF 拦截器 的使用。 拦截器 分为服务端 拦截器 和客户端 拦截器 ，又分为入 拦截器 （in）和出 拦截器 （out） 先讲述一个 Webservice 请求过程如下。 1、首先是客户端发起请求，在请求到达服务端之前，我们可以用客户端出 拦截器 （client  out interceptor ）进...
一、有关调用 CXF 拦截器 1、 拦截器 概述 Interceptor 是 CXF 架构中一个很有特色的模式。你可以在不对核心模块进行修改的情况下，动态添加很多功能。这对于 CXF 这个以处理消息为中心的服务框架来说是非常有用的， CXF 通过在 Interceptor 中对消息进行特殊处理， 实现 了很多重要功能模块，例如：日志记录，Soap消息处理，消息的压缩处理。        在Interc...
最近公司与一些大公司对接服务，使用的是老掉牙的web service协议的接口，其中遇到了不少的坑。在此将自己的经验描述一下，让各位后辈能学习到东西。。。 1：介绍 webservice Web Service是一个平台独立的，低耦合的，自包含的、基于可编程的web的应用程序，可使用开放的XML（标准通用标记语言下的一个子集）标准来描述、发布、发现、协调和配置这些应用程序，用于开发分布式的交互操作的应用程序。 [1]
<artifactId> spring - boot -starter-web-services</artifactId>是 Spring Boot 的一个Starter，它提供了对Web Services的支持。 使用方法： 在你的项目的pom.xml文件中加入如下依赖即可: <dependency> <groupId>org. spring framework. boot </groupId> <artifactId> spring - boot -starter-web-services</artifactId> </dependency> 加入依赖后，你就可以在你的 Spring Boot 应用中使用Web Services功能了。你可以使用JAX-WS或 Spring -WS等框架来创建和使用Web Services。 例如，你可以使用@ WebService 注解在你的服务端代码上来创建一个Web Service，并使用@WebMethod注解来标记哪些方法可以被远程调用。在客户端，你可以使用相关的工具或库来生成代码来调用这些Web Service。 port 26380 sentinel monitor mymaster 127.0.0.1 6379 2 sentinel down-after-milliseconds mymaster 5000 sentinel failover-timeout mymaster 15000 sentinel config-epoch mymaster 0 redis-server sentinel26380.conf --sentinel redis-cli -p 26380 spring boot整合redis主从sentinel we11_done: 这里面怎么没有redis用户名密码的连接配置啊？ spring boot整合quartz实现多个定时任务 sky@sky: 这用的是quartz? springboot整合Quartz实现动态配置定时任务 崇尚自由的男人: 你这写的并发会有问题吧
 
推荐文章
忐忑的灯泡  ·  云南省扫黑除恶专项斗争系列新闻发布会·省检察院专场发布会_云南省网上新闻发布厅
2 周前
卖萌的伏特加  ·  孟晚舟与姚安娜姐妹情深，姐姐鼓励妹妹坚定所爱勇攀高峰|才女|任正非_网易订阅
1 月前
沉稳的墨镜  ·  古风不“殇”：一个圈子的起落
3 月前
完美的消炎药  ·  西行纪漫画神战篇是新片吗 - 抖音
1 年前
爱喝酒的牙膏  ·  宝马集团：加快电动化进程，计划到2030年电动汽车销量占比超50% - MarkLines全球汽车产业平台
1 年前
今天看啥   ·   Py中国   ·   codingpro   ·   藏经阁   ·   小百科   ·   link之家   ·   卧龙AI搜索
删除内容请联系邮箱 2879853325@qq.com
link之家 - 链接快照平台
© 2024 ~ 沪ICP备11025650号