通常在Spring發(fā)布Hession,RMI等,是非常方便的,
但是要發(fā)布SOAP類型的WebService則要依賴一個(gè)獨(dú)立的Servlet容器(如Tomcat+Axis),
1// Create an XFire Service
2ObjectServiceFactory serviceFactory = new ObjectServiceFactory();
3Service service = serviceFactory.create(Echo.class);
4service.setInvoker(new BeanInvoker(new EchoImpl()));
5// Register the service in the ServiceRegistry
6XFire xfire = XFireFactory.newInstance().getXFire();
7xfire.getServiceRegistry().register(service);
8// Start the HTTP server
9XFireHttpServer server = new XFireHttpServer();
10server.setPort(8191);
11server.start();
這樣的話,如果發(fā)布多個(gè)WebSerice則要依次顯式的創(chuàng)建 XFire Service,然后再一一注冊(cè),
這樣顯然是不夠優(yōu)雅的。
我們想要讓開發(fā)者在Spring配置文件中指定要發(fā)布為WebService的POJOs,
然后載入Spring環(huán)境就自動(dòng)發(fā)布為webservice,而不需要跟 XFire API打交道。
首先,我們想要一個(gè)BeanFacory,能把一個(gè)pojo裝配成XFire Service
1 /**
2 *
3 */
4 package com.yovn.ws.xfire.example;
5
6 import org.codehaus.xfire.service.Service;
7 import org.codehaus.xfire.service.binding.BeanInvoker;
8 import org.codehaus.xfire.service.binding.ObjectServiceFactory;
9 import org.springframework.beans.factory.FactoryBean;
10
11 /**
12 * @author new
13 *
14 */
15 public class XFireServiceFactoryBean implements FactoryBean
16 {
17
18
19
20
21 private Class serviceClass;
22
23
24 private Object target;
25
26
27 private Service service;
28
29
30 private final ObjectServiceFactory sf=new ObjectServiceFactory();
31
32 /**
33 *
34 */
35 public XFireServiceFactoryBean()
36 {
37
38 }
39
40 /* (non-Javadoc)
41 * @see org.springframework.beans.factory.FactoryBean#getObject()
42 */
43 public Object getObject() throws Exception
44 {
45 if(service==null)
46 {
47 service=sf.create(serviceClass);
48 service.setInvoker(new BeanInvoker(target));
49 }
50 return service;
51 }
52
53 /* (non-Javadoc)
54 * @see org.springframework.beans.factory.FactoryBean#getObjectType()
55 */
56 public Class getObjectType()
57 {
58
59 return Service.class;
60 }
61
62 /* (non-Javadoc)
63 * @see org.springframework.beans.factory.FactoryBean#isSingleton()
64 */
65 public boolean isSingleton()
66 {
67 return true;
68 }
69
70 public void setServiceClass(Class serviceClass)
71 {
72 this.serviceClass = serviceClass;
73 }
74
75 public void setTarget(Object target)
76 {
77 this.target = target;
78 }
79
80 }
81
這樣我們可以通過(guò)Spring來(lái)裝配一個(gè)pojo,
下一步我們要在Spring容器載入時(shí)候注冊(cè)XFire Service,
并啟動(dòng)一個(gè)嵌入的Http Server,我們可以借助Spring的ApplicationListener來(lái)實(shí)現(xiàn)
Ok,我們完成基礎(chǔ)的代碼,下面試著發(fā)布一個(gè)簡(jiǎn)單的WebServie1 /**
2 *
3 */
4 package com.yovn.ws.xfire.example;
5
6
7 import org.apache.commons.logging.Log;
8 import org.apache.commons.logging.LogFactory;
9 import org.codehaus.xfire.XFire;
10 import org.codehaus.xfire.XFireFactory;
11 import org.codehaus.xfire.server.http.XFireHttpServer;
12 import org.codehaus.xfire.service.Service;
13 import org.codehaus.xfire.service.ServiceRegistry;
14 import org.springframework.context.ApplicationContext;
15 import org.springframework.context.ApplicationEvent;
16 import org.springframework.context.ApplicationListener;
17 import org.springframework.context.event.ContextClosedEvent;
18 import org.springframework.context.event.ContextRefreshedEvent;
19
20 /**
21 * @author new
22 *
23 */
24 public class XFireServiceStarter implements ApplicationListener
25 {
26
27 private int port = 80;
28
29 private XFireHttpServer server;
30 private final Log logger=LogFactory.getLog(getClass().getName());
31
32 public void setPort(int port)
33 {
34 this.port = port;
35 }
36
37 public void onApplicationEvent(ApplicationEvent event)
38 {
39 try
40 {
41 if (event instanceof ContextRefreshedEvent)
42 {
43
44 if (server != null)
45 {
46
47 server.stop();
48 logger.info("xfire server stopped");
49
50 }
51 registerService((ApplicationContext)event.getSource());
52 server = new XFireHttpServer();
53 server.setPort(port);
54 server.start();
55 logger.info("xfire server started");
56
57 } else if (event instanceof ContextClosedEvent)
58 {
59 if(server!=null)
60 {
61 server.stop();
62 logger.info("xfire server stopped");
63 }
64
65 }
66
67 } catch (Exception e)
68 {
69 logger.error("process event "+event+" error",e);
70 }
71
72 }
73
74 private void registerService(ApplicationContext context)
75 {
76 XFire xfire=XFireFactory.newInstance().getXFire();
77 ServiceRegistry registry=xfire.getServiceRegistry();
78 String names[]=context.getBeanNamesForType(Service.class);
79
80 for(int i=0;i<names.length;i++)
81 {
82 Service service=(Service)context.getBean(names[i]);
83 registry.register(service);
84 logger.info("register service:"+service.getName());
85 }
86
87 }
88
89 }
90
該接口的實(shí)現(xiàn)如下1 package com.yovn.ws.xfire.example;
2
3 public interface Add
4 {
5 int add(int a,int b);
6
7 }
聯(lián)系客服