1. REST方式的WebService概述
1.1 REST架构风格
REST是 Roy Fielding 博士在 2000 年提出的。
REST（Representational State Transfer-表现层状态转化）是一种新的软件架构风格，它以资源（resource）为核心，使用 HTTP、 URI、XML 以及 HTML 等流行协议和标准来完成对资源的操作及显示。 这些操作包括获取、创建、修改和删除资源（CRUD），分别对应于 HTTP 协议的 GET、POST、PUT 和 DELETE 方法。
RESTful架构可以总结为以下三个内容：
（1）每一个URI代表一种资源；
（2）客户端和服务器之间，传递这种资源的某种表现层；
（3）客户端通过四个HTTP动词，对服务器端资源进行操作，实现”表现层状态转化”。
- GET用来获取资源，
- POST用来新建资源（也可以用于更新资源），
- PUT用来更新资源，
- DELETE用来删除资源。
1.2. REST风格服务
REST （风格的）服务（RESTful Service）是一种基于 HTTP 和 REST 准则的轻量级 Web 服务。
这类服务可以看作一系列资源（resource）的集合，服务的定义可以视为以下三个切面的组合 :
- 访问 Web Service 的 URI，如：http://example.com/resources。
- Web Service 所支持的数据 MIME 类型，如：JSON, XML, YAML 等。
- Web Service 使用 HTTP 协议支持的操作，如 GET, POST, PUT, DELETE。
1.3.优点
REST风格的服务的性能，效率和易用性等方面均优于 SOAP 协议：
- 相比SOAP 和 XML-RPC, REST 服务更加简洁，
- 它可以完全通过 HTTP 协议实现，
- 支持多种消息格式，比如XML 、JSON
- 还可以利用缓存 Cache 来提高响应速度（第一次访问资源 缓存，第二次访问资源，返回304客户端调用本地）。
1.4.JAX-RS
JAX-RS (JSR 311)是Java世界中的另一套Web Service规范，用于开发RESTful Web Service。它属于Java EE 6规范中的子规范，逐步取代了JAX-WS（大WebService的规范）的地位。
基于JAX-RS规范实现的RESTful API可达到：支持资源抽象、统一接口的 “CRUD式Web服务”。
2.CXF服务端开发
CXF框架支持JAX-WS，也支持JAX-RS规范，都是远程调用。
2.1 新建maven项目，引入依赖
pom.xml
<properties> <cxf.version>3.1.9</cxf.version> <slf4j.version>1.7.21</slf4j.version> </properties> <dependencies> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxrs</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-transports-http-jetty</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-client</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-extension-providers</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.codehaus.jettison</groupId> <artifactId>jettison</artifactId> <version>1.3.8</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.1</version> <configuration> <source>1.7</source> <target>1.7</target> </configuration> </plugin> </plugins> </build>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
2.2 资源-实体类编写
@XmlRootElement 指定序列化（转换XML、JSON） 对象名字。
//指定序列化（转换XML、JSON） 对象名字 //实体类:资源对应的类 //@XmlRootElement//默认情况下，该对象在传输表现的时候，表现方式xml，要转成xml，根元素：<user类名></user> name:默认类名小写 @XmlRootElement(name="users")//根元素：<users></users> //比如查询列表:<users><user><id>123</id>....</user></users> //如果是json：{users:[{"id":"2342",...},{...}} public class User { private Integer id; private String username; private String password; private Integer age;
2.3 SEI业务
第一种 @Path 服务访问资源路径
如果访问saveUser方法 /userService/user
第二种 @Produces 生成（方法返回值） @Consumes 消费 （方法参数）
@Consumes 指定能够处理客户端传递过来数据格式
@Produces 指定能否生成哪种格式数据返回给客户端
第三种 @GET 查询 @PUT 修改 @POST 增加 @DELETE 删除
第四种：
@PathParam来自于URL的路径，@QueryParam来自于URL的查询参数
@Path("/userService") public interface UserService { /** * 说明：保存用户 * @param user */ @Path("/users") @POST @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public void saveUser(User user); /** * * 说明：修改用户 * @param user */ @Path("/users") @PUT @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public void updateUser(User user); /** * * 说明：直接根据id删除 * @param id */ @Path("/users/{id}") @DELETE @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public void deleteUser(@PathParam("id")Integer id); /** * * 说明：查询所有数据列表 * @return */ @Path("/users") @GET @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public List<User> findUserList(); /** * * 说明：根据id来查询用户 * @param id * @return */ @Path("/users/{id}") @GET @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public User findUserById(@PathParam("id")Integer id); /** * * 说明：使用参数传参:/users?id=1 * @param id * @return */ @Path("/usersparam") @GET @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public User findUserById2(@QueryParam("id")Integer id); } /** * SEI实现 */ public class UserServiceImpl implements UserService { @Override public void save(User user) { System.out.println("----保存:"+user); } @Override public void update(User user) { System.out.println("-----更新对象："+user); } @Override public void delete(Integer id) { System.out.println("-----删除的id："+id); } @Override public List<User> findUserList() { List<User> userList = new ArrayList<>(); userList.add(new User(1,"jack","123",19)); userList.add(new User(2,"rose","1234",18)); return userList; } @Override public User findUserById(Integer id) { System.out.println("----根据id查询，id是："+id); return new User(1,"jack","123",19); } @Override public User findUserById2(Integer id) { System.out.println("----根据id参数查询，id是："+id); return new User(2,"rose","1234",18); } }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
- 93
- 94
- 95
- 96
- 97
- 98
- 99
- 100
- 101
- 102
- 103
- 104
- 105
- 106
- 107
- 108
- 109
- 110
- 111
- 112
- 113
- 114
- 115
- 116
- 117
- 118
- 119
- 120
- 121
- 122
- 123
- 124
- 125
2.4 发布服务
public class CxfJaxRsServer { public static void main(String[] args) { JAXRSServerFactoryBean jaxrsServiceFactoryBean = new JAXRSServerFactoryBean(); jaxrsServiceFactoryBean.setAddress("http://localhost:8888/cxf_jaxrs"); jaxrsServiceFactoryBean.setResourceClasses(User.class); jaxrsServiceFactoryBean.setServiceBean(new UserServiceImpl()); jaxrsServiceFactoryBean.create(); System.out.println("rest服务发布了！"); } }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
2.5 测试
浏览器测试（只能是get方法测试）
查询所有：http://localhost:8888/cxf_jaxrs/userService/users
根据id查询（路径方式）：http://localhost:8888/cxf_jaxrs/userService/users/1
根据id查询（参数方式）：http://localhost:8888/cxf_jaxrs/userService/users?id=1
3. CXF客户端开发
客户端编程有两种做法：
1）HttpClient工具需要自己对HTTP协议内容进行定制和解析。
2）WebClient工具类（CXF自带）(使用)。
3.1 客户端调用类
主要的方法说明：
- create:调用服务资源路径，并建立连接
- type:客户端发送给服务器的数据（资源）格式，对应服务端的@consumes的数据类型
- accept:客户端接收服务器的数据（资源）格式，对应服务端的@Produces的数据类型
- get,post,put,delete四个方法，分别是要采用HTTP协议的那种方式访问服务器。
public class CxfRsClient { public static void main(String[] args) { int status = WebClient.create("http://127.0.0.1:8888/cxf_jaxrs/userService/users") .accept(MediaType.APPLICATION_JSON) .get() .getStatus(); System.out.println(status); System.out.println("客户端操作完成！"); }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
4. CRM系统的CXF服务端构建开发(与spring整合)
4.1. SSH基础环境搭建
技术架构：
Spring + Hibernate（spring和hibernate直接整合）+CXF+Oracle
4.1.1 新建Maven项目
引入Maven坐标：
Spring、Hibernate、数据库和连接池、日志、Servlet、JSP、junit、编译版本覆盖、tomcat端口覆盖8888:
<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>cn.aric.project</groupId> <artifactId>crm</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>war</packaging> <name>crm</name> <description>物流的客户子系统</description> <properties> <spring.version>3.2.12.RELEASE</spring.version> <hibernate.version>3.6.10.Final</hibernate.version> <slf4j.version>1.7.5</slf4j.version> <c3p0.version>0.9.1.2</c3p0.version> <oracle.version>10.2.0.4.0</oracle.version> <servlet.version>2.5</servlet.version> <jsp.version>2.0</jsp.version> <junit.version>4.11</junit.version> <cxf.version>3.1.9</cxf.version> </properties> <dependencies> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-orm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.hibernate</groupId> <artifactId>hibernate-core</artifactId> <version>${hibernate.version}</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>c3p0</groupId> <artifactId>c3p0</artifactId> <version>${c3p0.version}</version> </dependency> <dependency> <groupId>com.oracle</groupId> <artifactId>ojdbc14</artifactId> <version>${oracle.version}</version> <scope>runtime</scope> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> <version>${servlet.version}</version> <scope>provided</scope> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>jsp-api</artifactId> <version>${jsp.version}</version> <scope>provided</scope> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>javassist</groupId> <artifactId>javassist</artifactId> <version>3.12.0.GA</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxrs</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-extension-providers</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.codehaus.jettison</groupId> <artifactId>jettison</artifactId> <version>1.3.8</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-client</artifactId> <version>${cxf.version}</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>tomcat-maven-plugin</artifactId> <version>1.1</version> <configuration> <port>8888</port> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <version>2.6</version> <configuration> <encoding>UTF-8</encoding> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.1</version> <configuration> <source>1.7</source> <target>1.7</target> </configuration> </plugin> </plugins> </build> </project> </project>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
- 93
- 94
- 95
- 96
- 97
- 98
- 99
- 100
- 101
- 102
- 103
- 104
- 105
- 106
- 107
- 108
- 109
- 110
- 111
- 112
- 113
- 114
- 115
- 116
- 117
- 118
- 119
- 120
- 121
- 122
- 123
- 124
- 125
- 126
- 127
- 128
- 129
- 130
- 131
- 132
- 133
- 134
- 135
- 136
- 137
- 138
- 139
- 140
- 141
- 142
- 143
- 144
- 145
- 146
- 147
- 148
- 149
4.1.2 整合spring
配置Spring整合Hibernate（几个配置文件：applicationContext.xml、db.properties,web.xml,log4j.properties等）
web.xml
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5"> <display-name>crm</display-name> <servlet> <description>Apache CXF Endpoint</description> <display-name>cxf</display-name> <servlet-name>cxf</servlet-name> <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>cxf</servlet-name> <url-pattern>/services/*</url-pattern> </servlet-mapping> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:applicationContext.xml</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <welcome-file-list> <welcome-file>index.jsp</welcome-file> </welcome-file-list> </web-app>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
db.properties
jdbc.driver=oracle.jdbc.driver.OracleDriver jdbc.url=jdbc:oracle:thin:@127.0.0.1:1521:xe jdbc.user=scott jdbc.password=tigger
log4j.properties
### direct log messages to stdout ### log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.Target=System.err log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n ### direct messages to file mylog.log ### log4j.appender.file=org.apache.log4j.FileAppender log4j.appender.file.File=d:/mylog.log log4j.appender.file.layout=org.apache.log4j.PatternLayout log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n ### set log levels - for more verbose logging change 'info' to 'debug' ### log4j.rootLogger=info, stdout
applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"> <context:property-placeholder location="classpath:db.properties"/> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="${jdbc.driver}"/> <property name="jdbcUrl" value="${jdbc.url}"/> <property name="user" value="${jdbc.user}"/> <property name="password" value="${jdbc.password}"/> </bean> <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"> <property name="dataSource" ref="dataSource"/> <property name="hibernateProperties"> <props> <prop key="hibernate.dialect">org.hibernate.dialect.Oracle10gDialect</prop> <prop key="hibernate.hbm2ddl.auto">update</prop> <prop key="hibernate.show_sql">true</prop> <prop key="hibernate.format_sql">true </prop> </props> </property> <property name="packagesToScan"> <list> <value>cn.aric.crm.domain</value> </list> </property> </bean> <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"> <property name="sessionFactory" ref="sessionFactory" /> </bean> <tx:annotation-driven transaction-manager="transactionManager"/> <context:component-scan base-package="cn.aric.crm.service,cn.aric.crm.dao"/> <import resource="applicationContext-cxf.xml"/> </beans>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
4.2 新建实体类
@Entity @Table(name="t_customer",schema="scott") public class Customer { @Id @GeneratedValue(strategy=GenerationType.AUTO) private Integer id; private String name; private String address; private String telephone; private String decidedZoneId; public Integer getId() { return id; } public String getName() { return name; } public String getAddress() { return address; } public String getTelephone() { return telephone; } public String getDecidedZoneId() { return decidedZoneId; } public void setId(Integer id) { this.id = id; } public void setName(String name) { this.name = name; } public void setAddress(String address) { this.address = address; } public void setTelephone(String telephone) { this.telephone = telephone; } public void setDecidedZoneId(String decidedZoneId) { this.decidedZoneId = decidedZoneId; } }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
测试上面的配置，启动服务，自动建表：tomcat：run
4.3 引入CXF环境 ###
<properties> <cxf.version>3.1.9</cxf.version> </properties> <dependencies> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxrs</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-extension-providers</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.codehaus.jettison</groupId> <artifactId>jettison</artifactId> <version>1.3.8</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-client</artifactId> <version>${cxf.version}</version> </dependency> </dependencies>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
4.4 Spring整合CXF-RS的服务
@Entity @Table(name="t_customer",schema="SCOTT") @XmlRootElement(name="customer") public class Customer { @Id @GeneratedValue(strategy=GenerationType.AUTO) private Integer id; private String name; private String address; private String telephone; private String decidedZoneId;
4.4.1 编写SEI
@Path("/customerService") @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public interface CustomerService { /** * * 说明：查询没有关联定区的客户的列表 * @return */ @Path("/customers") @GET @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public List<Customer> findCustomerListNoDecidedZoneId(); /** * * 说明：查询关联某个定区的客户的列表 * @return */ @Path("/customers/{decidedZoneId}") @GET @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public List<Customer> findCustomerListByDecidedZoneId(@PathParam("decidedZoneId")String decidedZoneId); /** * * 说明：批量更新定区编号，通过客户编号 * @param decidedZoneId:DQ001 * @param customerIds：用逗号分割编号：2,3 */ @Path("/customers/{decidedZoneId}/{customerIds}") @PUT @Produces({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) @Consumes({MediaType.APPLICATION_XML,MediaType.APPLICATION_JSON}) public void updateDecidedZoneIdByIds(@PathParam("decidedZoneId")String decidedZoneId,@PathParam("customerIds")String customerIds); } Service("customeService") @Transactional public class CustomerServiceImpl implements CustomerService{ @Autowired private GenericDAO<Customer, Integer> customerDAO; @Override public List<Customer> findCustomerListNoDecidedZoneId() { DetachedCriteria criteria =DetachedCriteria.forClass(Customer.class) .add(Restrictions.isNull("decidedZoneId")); return customerDAO.findByCriteria(criteria); } @Override public List<Customer> findCustomerListByDecidedZoneId(String decidedZoneId) { DetachedCriteria criteria =DetachedCriteria.forClass(Customer.class) .add(Restrictions.eq("decidedZoneId", decidedZoneId)); return customerDAO.findByCriteria(criteria); } @Override public void updateDecidedZoneIdByIds(String decidedZoneId, String customerIds) { DetachedCriteria criteria =DetachedCriteria.forClass(Customer.class) .add(Restrictions.eq("decidedZoneId", decidedZoneId)); List<Customer> customerList = customerDAO.findByCriteria(criteria); for (Customer customer : customerList) { customer.setDecidedZoneId(null); } if(!StringUtils.isEmpty(customerIds)){ String[] customerArray = customerIds.split(","); for (String customerId : customerArray) { Customer customer = customerDAO.findById(Customer.class, Integer.parseInt(customerId)); customer.setDecidedZoneId(decidedZoneId); } } }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
}
4.4.2 编写DAO
略
4.4.3 配置web.xml（CXF的核心控制器）
<servlet> <description>Apache CXF Endpoint</description> <display-name>cxf</display-name> <servlet-name>cxf</servlet-name> <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>cxf</servlet-name> <url-pattern>/services/*</url-pattern> </servlet-mapping>cxf配置：applicationContext-cxf.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xmlns:jaxrs="http://cxf.apache.org/jaxrs" xmlns:jaxrsclient="http://cxf.apache.org/jaxrs-client" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd http://cxf.apache.org/jaxrs-client http://cxf.apache.org/schemas/jaxrs-client.xsd"> <import resource="classpath:META-INF/cxf/cxf.xml" /> <import resource="classpath:META-INF/cxf/cxf-servlet.xml" /> <jaxrs:server id="customerWebService" address="/CustomerWS" > <jaxrs:serviceBeans> <ref bean="customerService" /> </jaxrs:serviceBeans> <jaxrs:inInterceptors> <ref bean="loggingInInterceptor"/> </jaxrs:inInterceptors> <jaxrs:outInterceptors> <ref bean="loggingOutInterceptor" /> </jaxrs:outInterceptors> </jaxrs:server> <bean id="loggingInInterceptor" class="org.apache.cxf.interceptor.LoggingInInterceptor"></bean> <bean id="loggingOutInterceptor" class="org.apache.cxf.interceptor.LoggingOutInterceptor"></bean> </beans>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
4.4.4 测试
测试的访问路径：
web上下文+cxf前端控制器+配置的服务路径+类上的具体的服务路径
web上下文+cxf前端控制器+配置的服务路径+类上的具体的服务路径+资源路径（方法上）
使用SoapUI—webservice的调试工具，Encoding改UTF-8。
5. BOS系统的CXF客户端
5.1.项目中引入CXF开发环境
引入Maven坐标（Pom.xml）：
<cxf.version>3.1.9</cxf.version> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-extension-providers</artifactId> <version>${cxf.version}</version> </dependency> <dependency> <groupId>org.codehaus.jettison</groupId> <artifactId>jettison</artifactId> <version>1.3.8</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-rs-client</artifactId> <version>${cxf.version}</version> </dependency>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
5.2 CXF-RS的客户端开发
5.2.1 编写Domain
@XmlRootElement(name="customer") public class Customer { private Integer id; private String name; private String residence; private String telephone; private String decidedZoneId;
5.2.2 编写Jsp
略
5.2.3 后台代码
@Action("decidedZone_listCustomerListNoDecidedZoneId") public String listCustomerListNoDecidedZoneId(){ WebClient webClient = WebClient.create("http://localhost:8888/crm/services"); Collection<? extends Customer> collection = webClient .path("/crmService/customerService") .path("/customers") .accept(MediaType.APPLICATION_JSON) .type(MediaType.APPLICATION_JSON) .getCollection(Customer.class); pushToValuestackRoot(collection); return JSON; } @Action("decidedZone_listCustomerListHasDecidedZoneId") public String listCustomerListHasDecidedZoneId(){ WebClient webClient = WebClient.create("http://localhost:8888/crm/services"); Collection<? extends Customer> collection = webClient .path("/crmService/customerService") .path("/customers") .path("/"+model.getId()) .accept(MediaType.APPLICATION_JSON) .type(MediaType.APPLICATION_JSON) .getCollection(Customer.class); pushToValuestackRoot(collection); return JSON;
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
