- 浏览: 176662 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (321)
- eclipse (4)
- idea (2)
- Html (8)
- Css (14)
- Javascript (8)
- Jquery (6)
- Ajax Json (4)
- Bootstrap (0)
- EasyUI (0)
- Layui (0)
- 数据结构 (0)
- Java (46)
- DesPattern (24)
- Algorithm (2)
- Jdbc (8)
- Jsp servlet (13)
- Struts2 (17)
- Hibernate (11)
- Spring (5)
- S2SH (1)
- SpringMVC (4)
- SpringBoot (11)
- WebService CXF (4)
- Poi (2)
- JFreeChart (0)
- Shiro (6)
- Lucene (5)
- ElasticSearch (0)
- JMS ActiveMQ (3)
- HttpClient (5)
- Activiti (0)
- SpringCloud (11)
- Dubbo (6)
- Docker (0)
- MySQL (27)
- Oracle (18)
- Redis (5)
- Mybatis (11)
- SSM (1)
- CentOS (10)
- Ant (2)
- Maven (4)
- Log4j (7)
- XML (5)
最新评论
1. CXF添加拦截器
2. CXF添加自定义拦截器
webservice分服务端和客户端,服务端和客户端都是可以加拦截器的,无论是服务端还是客户端,都分进,出(In,Out)拦截器; Server.java package com.andrew.server; import javax.xml.ws.Endpoint; import org.apache.cxf.interceptor.LoggingInInterceptor; import org.apache.cxf.interceptor.LoggingOutInterceptor; import org.apache.cxf.jaxws.JaxWsServerFactoryBean; import com.andrew.webservice.HelloWorld; import com.andrew.webservice.impl.HelloWorldImpl; public class Server { public static void main(String[] args) { System.out.println("web service start"); HelloWorld implementor = new HelloWorldImpl(); String address = "http://192.168.18.2/helloWorld"; // 1. 使用JDK实现 // Endpoint.publish(address, implementor); // 2. 使用CXF实现 JaxWsServerFactoryBean factoryBean = new JaxWsServerFactoryBean(); factoryBean.setAddress(address); // 设置暴露地址 factoryBean.setServiceClass(HelloWorld.class); // 接口类 factoryBean.setServiceBean(implementor); // 设置实现类 factoryBean.getInInterceptors().add(new LoggingInInterceptor()); // 添加in拦截器 日志拦截器 factoryBean.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加out拦截器 factoryBean.create(); System.out.println("web service started"); } } Inbound进信息,Outbound是出信息
pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.andrew.webservice</groupId> <artifactId>WS_Client</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-core</artifactId> <version>3.1.5</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxws</artifactId> <version>3.1.5</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-transports-http-jetty</artifactId> <version>3.1.5</version> </dependency> </dependencies> </project> Client.java package com.andrew.client; import java.util.List; import org.apache.cxf.frontend.ClientProxy; import org.apache.cxf.interceptor.LoggingInInterceptor; import org.apache.cxf.interceptor.LoggingOutInterceptor; import com.andrew.webservice.HelloWorld; import com.andrew.webservice.HelloWorldService; import com.andrew.webservice.MyRole; import com.andrew.webservice.MyRoleArray; import com.andrew.webservice.Role; import com.andrew.webservice.User; public class Client { public static void main(String[] args) { HelloWorldService service = new HelloWorldService(); HelloWorld helloWorld = service.getHelloWorldPort(); org.apache.cxf.endpoint.Client client = ClientProxy.getClient(helloWorld); client.getInInterceptors().add(new LoggingInInterceptor()); // 添加in拦截器 日志拦截器 client.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加out拦截器 System.out.println(helloWorld.say("andrew")); User user = new User(); user.setUserName("tony"); user.setPassword("123456"); List<Role> roleList = helloWorld.getRoleByUser(user); for (Role role : roleList) { System.out.println(role.getId() + "," + role.getRoleName()); } MyRoleArray array = helloWorld.getRoles(); List<MyRole> roleList2 = array.getItem(); for(int i = 0; i < roleList2.size(); i++){ MyRole my = roleList2.get(i); System.out.print(my.getKey() + ":"); for(Role r : my.getValue()){ System.out.print(r.getId() + "," + r.getRoleName() + " "); } System.out.println(); } } } Inbound进信息,Outbound是出信息
2. CXF添加自定义拦截器
MyInterceptor.java package com.andrew.interceptor; import java.util.List; import org.apache.cxf.binding.soap.SoapMessage; import org.apache.cxf.headers.Header; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.AbstractPhaseInterceptor; import org.apache.cxf.phase.Phase; import org.w3c.dom.Element; import org.w3c.dom.NodeList; public class MyInterceptor extends AbstractPhaseInterceptor<SoapMessage>{ public MyInterceptor() { super(Phase.PRE_INVOKE); } public void handleMessage(SoapMessage message) throws Fault { List<Header> headers = message.getHeaders(); if (headers == null || headers.size() == 0) { throw new Fault(new IllegalArgumentException("没有Header,拦截器实施拦截")); } Header firstHeader = headers.get(0); Element ele = (Element) firstHeader.getObject(); NodeList userIds = ele.getElementsByTagName("userName"); NodeList userPasses = ele.getElementsByTagName("password"); if (userIds.getLength() != 1) { throw new Fault(new IllegalArgumentException("用户名格式不对")); } if (userPasses.getLength() != 1) { throw new Fault(new IllegalArgumentException("密码格式不对")); } String userId = userIds.item(0).getTextContent(); String userPass = userPasses.item(0).getTextContent(); if (!userId.equals("tony") || ! userPass.equals("123456")) { throw new Fault(new IllegalArgumentException("用户名或者密码不正确")); } } } Server.java package com.andrew.server; import javax.xml.ws.Endpoint; import org.apache.cxf.interceptor.LoggingInInterceptor; import org.apache.cxf.interceptor.LoggingOutInterceptor; import org.apache.cxf.jaxws.JaxWsServerFactoryBean; import com.andrew.interceptor.MyInterceptor; import com.andrew.webservice.HelloWorld; import com.andrew.webservice.impl.HelloWorldImpl; public class Server { public static void main(String[] args) { System.out.println("web service start"); HelloWorld implementor = new HelloWorldImpl(); String address = "http://192.168.18.2/helloWorld"; // 1. 使用JDK实现 // Endpoint.publish(address, implementor); // 2. 使用CXF实现 JaxWsServerFactoryBean factoryBean = new JaxWsServerFactoryBean(); factoryBean.setAddress(address); // 设置暴露地址 factoryBean.setServiceClass(HelloWorld.class); // 接口类 factoryBean.setServiceBean(implementor); // 设置实现类 factoryBean.getInInterceptors().add(new LoggingInInterceptor()); // 添加in拦截器 日志拦截器 factoryBean.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加out拦截器 factoryBean.getInInterceptors().add(new MyInterceptor()); // 添加自定义拦截器 factoryBean.create(); System.out.println("web service started"); } }
1) cmd 2) cd E:\studyWEBSERVICECXF\WS_Client\src\main\java 3) wsdl2java http://192.168.18.2/helloWorld?wsdl
AddHeaderInterceptor.java package com.andrew.interceptor; import java.util.List; import javax.xml.namespace.QName; import org.apache.cxf.binding.soap.SoapMessage; import org.apache.cxf.headers.Header; import org.apache.cxf.helpers.DOMUtils; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.AbstractPhaseInterceptor; import org.apache.cxf.phase.Phase; import org.w3c.dom.Document; import org.w3c.dom.Element; public class AddHeaderInterceptor extends AbstractPhaseInterceptor<SoapMessage> { private String userName; private String password; public AddHeaderInterceptor(String userName, String password) { super(Phase.PREPARE_SEND); // 发送SOAP消息之前调用拦截器 this.userName = userName; this.password = password; } public void handleMessage(SoapMessage message) throws Fault { List<Header> headers=message.getHeaders(); Document doc=DOMUtils.createDocument(); Element ele=doc.createElement("authHeader"); Element idElement=doc.createElement("userName"); idElement.setTextContent(userName); Element passElement=doc.createElement("password"); passElement.setTextContent(password); ele.appendChild(idElement); ele.appendChild(passElement); headers.add(new Header(new QName("tony"),ele)); } } Client.java package com.andrew.client; import java.util.List; import org.apache.cxf.frontend.ClientProxy; import org.apache.cxf.interceptor.LoggingInInterceptor; import org.apache.cxf.interceptor.LoggingOutInterceptor; import com.andrew.interceptor.AddHeaderInterceptor; import com.andrew.webservice.HelloWorld; import com.andrew.webservice.HelloWorldService; import com.andrew.webservice.MyRole; import com.andrew.webservice.MyRoleArray; import com.andrew.webservice.Role; import com.andrew.webservice.User; public class Client { public static void main(String[] args) { HelloWorldService service = new HelloWorldService(); HelloWorld helloWorld = service.getHelloWorldPort(); org.apache.cxf.endpoint.Client client = ClientProxy.getClient(helloWorld); // client.getInInterceptors().add(new LoggingInInterceptor()); // 添加in拦截器 日志拦截器 client.getOutInterceptors().add(new AddHeaderInterceptor("tony","123456")); // 添加自定义拦截器 client.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加out拦截器 System.out.println(helloWorld.say("andrew")); User user = new User(); user.setUserName("tony"); user.setPassword("123456"); List<Role> roleList = helloWorld.getRoleByUser(user); for (Role role : roleList) { System.out.println(role.getId() + "," + role.getRoleName()); } MyRoleArray array = helloWorld.getRoles(); List<MyRole> roleList2 = array.getItem(); for(int i = 0; i < roleList2.size(); i++){ MyRole my = roleList2.get(i); System.out.print(my.getKey() + ":"); for(Role r : my.getValue()){ System.out.print(r.getId() + "," + r.getRoleName() + " "); } System.out.println(); } } } 如果密码改成123则报错
相关推荐
CXF3.0 Spring3.2 自定义拦截器
10.为CXF服务器端添加自定义拦截器进行权限检查
08.CXF拦截器的理论以及如何为CXF的客户端和服务器端添加拦截器
这里少了一个类,是根据实体类生成xml的文件下载地址为:http://download.csdn.net/detail/qq_14996421/9495688
11.为CXF客户端添加自定义拦截器完成权限控制
CXF+Spring+自定义拦截器 webservice源码下载
讲解了cxf实现拦截器的原因、核心API及使用方法
spring4+cxf3,因为自己项目要用到接口开发,所以综合现有网上所有教程,终于成功写出能自动注入的demo,这个是含拦截器
Cxf拦截器示例的源码,包含客户端和服务器端的内容。
注册自定义拦截器,添加拦截路径和排除拦截路径WebAppConfig
CXF使用EndpointImpl发布WebService加入拦截器
CXF 自定义拦截器实现的 webservice安全机制实例工程, 带jar包 ,代码注释详细 内有说明文档, 由于资源过大 ,所以客户端jar包 删除掉了, 只需要把服务端的jar 拷贝到 客户端即可 , 小弟刚刚研究完 CXF 安全 。...
Web Service学习-CXF开发Web Service的权限控制(二)
webservice拦截器demo-服务端和调用端
包含表结构(mysql表创建语句),字段说明与使用;拦截器代码(可根据业务进行修改);
本文根据java代理实现CXF拦截器异常时只能进入fault拦截器而不能继续向下执行的问题。 利用java代理让RMI具有拦截器的功能。
CXF发布WebService加入拦截器
webservice的cxf框架拦截器demo.rar
13.为CXF与Spring整合发布WebService添加拦截器进行权限控制
CXF-拦截器-权限控制-登录校验