分布式(基础)-WebService(四)

WebService-xfire

xfire是3到5年的存活期，然后就淡出了市场。

1、引入相关的依赖：引入all的话，它会把所有关于xfire相关的东西都加载进来。

1. <dependency>
   
2.      <groupId>org.codehaus.xfire</groupId>
   
3.      <artifactId>xfire-all</artifactId>
   
4.      <version>1.2.6</version>
   
5.    </dependency>
   

引进来之后会把默认的spring1.2.6的版本给引入进来。

所以将spring1.2.6的版本给排除掉，而xfire最高支持spring的版本是3.2的。超过的话就会报错：

1.     <!--引入spring-->
   
2.    <dependency>
   
3.      <groupId>org.springframework</groupId>
   
4.      <artifactId>spring-web</artifactId>
   
5.      <version>3.2.12.RELEASE</version>
   
6.    </dependency>
   
7.  <dependency>
   
8.      <groupId>org.codehaus.xfire</groupId>
   
9.      <artifactId>xfire-all</artifactId>
   
10.      <version>${xfire-version}</version>
    
11.      <exclusions>
    
12.        <exclusion>
    
13.           <groupId>org.springframework</groupId>
    
14.           <artifactId>spring</artifactId>
    
15.        </exclusion>
    
16.      </exclusions>
    
17.    </dependency>
    

2、新建一个接口和对应的实现类如下：

1. package com.xf.demo.service;
   
2. 
   
3. import com.xf.demo.domain.User;
   
4. 
   
5. import java.util.List;
   
6. 
   
7. public interface UserService {
   
8.    void addUser(User user);
   
9.    void delUser(Integer id);
   
10.    User getUserById(Integer id);
    
11.    List<User> getUsers();
    
12. }
    
13. package com.xf.demo.service;
    
14. 
    
15. import com.xf.demo.domain.User;
    
16. import org.springframework.stereotype.Service;
    
17. 
    
18. import java.util.ArrayList;
    
19. import java.util.List;
    
20. //下面的接口中的方法是要暴漏出来的接口，然后通过接口找到对应的实现类，然后去实现远程的调用
    
21. @Service("userService")
    
22. public class UserServiceImpl implements  UserService {
    
23.    @Override
    
24.    public void addUser(User user) {
    
25.        System.out.println("新增的用户为"+user);
    
26.    }
    
27. 
    
28.    @Override
    
29.    public void delUser(Integer id) {
    
30.        System.out.println("删除了"+id+"用户信息");
    
31.    }
    
32. 
    
33.    @Override
    
34.    public User getUserById(Integer id) {
    
35.        User user = new User();
    
36.        user.setId(id);

    
37.        user.setName("魏朝阳");
    
38.        user.setPass("123");
    
39.        return null;
    
40.    }
    
41.    @Override
    
42.    public List<User> getUsers() {
    
43.        List<User> userList=new ArrayList<>();
    
44.        userList.add(new User(1234567,"李四","234"));
    
45.        userList.add(new User(1234568,"王五","235"));
    
46.        userList.add(new User(1234569,"赵六","236"));
    
47.        return userList;
    
48.    }
    
49. }
    

2.1、写一个xml文件用来spring和xfire整合的：把这个导入进去，就是把整个xfire和spring整合的需要的对象就都交给Spring容器去管理。

在xfire.xml文件中导入了自定义的编辑器：

注册为单例的。

传输管理器，用的是默认的传输管理对象。

里面会定义一个默认的xfire的文件，当发布服务的时候必须有xfire的对象存在。因为这个对象是靠构造函数来注入的。是靠参数(的索引来注入的。

就是把刚刚的两个对象注入到xfire对象里面去。

数据格式提供绑定器：所以说在配置的时候要指定哪种数据格式来进行访问。

消息绑定的提供器：就是序列化和反序列化的提供器

消息在网络中进行传输肯定是需要序列化和反序列化将数据在网络中传输

2.2、配置哪些服务被发布：发布的接口是哪一个，发布的接口的实现类是哪一个。

2.3、配置web.xml，告诉哪些请求交给WebService去做处理，去配置xfire的控制器：

2.4、把该项目发布出去：

2.5、访问下xfire对应的wsdl文件：

2.6、这就成功的生成了wsdl的文件：

这样的一个WebService的服务就发布成功了，每一个元素都有一些约束。

name有in和out。in0代表传入的第一个参数。类型为整型。

getUserByIdResponse就是getUserById的响应结果，响应结果就是out

返回的类型是User对象。

它也把User的实体类映射一个xml,而且也保证了参数的顺序的。

当去调用的话，是需要下面的访问地址去调用 ：这是一个服务终端的请求接口。

写一个主函数，然后运行启动：

WebService的Xfire就是这么做的。

在不同的项目中是如何去调用的呢？

3、新建一个客户端的项目，

3.1、加入相应的依赖，这里加的依赖与server端的依赖是一样的，这里就不贴了。

3.2、把server端的接口和实体类拷贝到client端，代码如下：

1. package com.xf.demo.domain;
   
2. 
   
3. public class User {
   
4.    private Integer id;
   
5.    private String name;
   
6.    private String pass;
   
7. 
   
8.    public User() {
   
9.    }
   
10. 
    
11.    public User(Integer id, String name, String pass) {
    
12.        this.id = id;
    
13.        this.name = name;
    
14.        this.pass = pass;
    
15.    }
    
16. 
    
17.    public Integer getId() {
    
18.        return id;
    
19.    }
    
20. 
    
21.    public void setId(Integer id) {
    
22.        this.id = id;
    
23.    }
    
24. 
    
25.    public String getName() {
    
26.        return name;
    
27.    }
    
28. 
    
29.    public void setName(String name) {
    
30.        this.name = name;
    
31.    }
    
32. 
    
33.    public String getPass() {
    
34.        return pass;
    
35.    }
    
36. 
    
37.    public void setPass(String pass) {
    
38.        this.pass = pass;
    
39.    }
    
40. 
    
41.    @Override
    
42.    public String toString() {
    
43.        return "User{" +
    
44.                "id=" + id +
    
45.                ", name='" + name + '\'' +
    
46.                ", pass='" + pass + '\'' +
    
47.                '}';
    
48.    }
    
49. }
    
50. package com.xf.demo.service;
    
51. 
    
52. import com.xf.demo.domain.User;
    
53. 
    
54. import java.util.List;
    
55. 
    
56. public interface UserService {
    
57.    void addUser(User user);
    
58.    void delUser(Integer id);
    
59.    User getUserById(Integer id);
    
60.    List<User> getUsers();
    
61. }
    

客户端的代码如下：

然后启动客户端：当客户端添加成功之后，就在server端的控制台就有对应的输出语句：

革命尚未成功，继续努力！！！！