SpringBoot整合WebService服務
WebService是一個SOA(面向服務的程式設計)的架構,它是不依賴於語言,不依賴於平臺,可以實現不同的語言間的相互呼叫,通過Internet進行基於Http協議的網路應用間的互動。 其實WebService並不是什麼神祕的東西,它就是一個可以遠端呼叫的類,或者說是元件,把你本地的功能開放出去共別人呼叫。
為什麼使用WebService?
簡單解釋一下WebService,比如你的專案需要查詢某銀行賬戶餘額。你能直接查嗎,肯定不行,因為資料庫是銀行的,他不可能給你許可權。你想訪問他的資料庫獲取資料,這就需要用到WebService。通過呼叫銀行暴露的介面來得到你想要的資料。
適用場景:
軟體的整合和複用,如氣象局(服務端系統)、天氣查詢網站等。
- 釋出一個服務(對內/對外),不考慮客戶端型別,不考慮效能,建議WebService
- 服務端已經確定使用webservice,客戶端不能選擇,必須使用WebService
軟體整合:通過遠端呼叫技術,將兩個系統整合到一起,從而實現軟體整合。
軟體複用:同一個款軟體的多次整合,最終實現複用。
不適用場景:
- 考慮效能時不建議使用WebService
- 同構程式下不建議使用WebService
Axis2與CXF的區別
目前java開發WebService的框架主要包括Axis2和CXF,如果你需要多語言的支援,你應該選擇Axis2。如果你需要把你的實現側重java並希望和Spring整合,CXF就是更好的選擇,特別是把你的WebService嵌入其他的程式中。
區別 | Axis2 | CXF |
---|---|---|
簡述 | WebService引擎 | 簡易的SOA框架,可以作為ESB |
spring整合 | 不支援 | 支援 |
應用整合 | 困難 | 簡單 |
是否跨語言 | 是 | 否 |
部署方式 | web應用 | 嵌入式 |
服務的管控和治理 | 支援 | 不支援 |
SpringBoot使用CXF整合WebService
1.向pom.xml中新增整合WebService的相關依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web-services</artifactId>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxws</artifactId>
<version>3.1.6</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
<version>3.1.6</version>
</dependency>
2.建立服務端介面
package com.primeton.mq.service;
import javax.jws.WebService;
@WebService(name = "DemoService", // 暴露服務名稱
targetNamespace = "http://service.mq.primeton.com"// 名稱空間,一般是介面的包名倒序
)
public interface DemoService {
public String sayHello(String user);
}
3.建立服務端介面實現類
package com.primeton.mq.service.impl;
import com.primeton.mq.service.DemoService;
import javax.jws.WebService;
import java.util.Date;
@WebService(serviceName = "DemoService", // 與介面中指定的name一致
targetNamespace = "http://service.mq.primeton.com", // 與介面中的名稱空間一致,一般是介面的包名倒
endpointInterface = "com.primeton.mq.service.DemoService"// 介面地址
)
public class DemoServiceImpl implements DemoService {
@Override
public String sayHello(String user) {
return user+",現在時間:"+"("+new Date()+")";
}
}
4.建立CXF配置類
package com.primeton.mq.webServiceConfig;
import com.primeton.mq.service.DemoService;
import com.primeton.mq.service.impl.DemoServiceImpl;
import org.apache.cxf.Bus;
import org.apache.cxf.bus.spring.SpringBus;
import org.apache.cxf.jaxws.EndpointImpl;
import org.apache.cxf.transport.servlet.CXFServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.xml.ws.Endpoint;
@Configuration
public class CxfConfig {
@Bean
public ServletRegistrationBean dispatcherServlet() {
return new ServletRegistrationBean(new CXFServlet(),"/demo/*");
}
@Bean(name = Bus.DEFAULT_BUS_ID)
public SpringBus springBus() {
return new SpringBus();
}
@Bean
public DemoService demoService() {
return new DemoServiceImpl();
}
@Bean
public Endpoint endpoint() {
EndpointImpl endpoint = new EndpointImpl(springBus(), demoService());
endpoint.publish("/api");
return endpoint;
}
}
5.啟動SpringBoot服務
輸入http://localhost:8090/demo/api?wsdl即可,注意我設定的埠是8090,視情況而定。
6.建立客戶端
在idea中進入File > New Project…選單開啟新建專案視窗,依次選擇Java、WebServices,Version項選擇Apache Axis,Libraries項選擇 Download。然後點選Next按鈕進入下一頁。
在下一頁中輸入專案名稱,然後點選Finish
按鈕開始下載依賴包。依賴包下載完成後進入新建的專案。
選WebServices > Generate Wsdl From Java Code,生成wsdl
然後選擇服務地址
確定之後,建立一個測試類,程式碼如下:
package test;
import example.DemoServiceImplService;
public class demo {
public static void main(String[] args) {
DemoServiceImplService webServiceImpl = new DemoServiceImplService();
String result = webServiceImpl.getDemoServiceImplPort().sayHello("沒有說");
System.out.println("===========================================");
System.out.println(result);
System.out.println("===========================================");
}
}
注意:實現WebService客戶端不一定要生成客戶端的程式碼,可以通過地址動態呼叫。
package com.primeton.mq.test;
import com.primeton.mq.service.DemoService;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
public class demo {
public static void main(String[] args) {
//建立動態客戶端
JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
Client client = factory.createClient("http://localhost:8090/demo/api?wsdl");
// 需要密碼的情況需要加上使用者名稱和密碼
//client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME,PASS_WORD));
HTTPConduit conduit = (HTTPConduit) client.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setConnectionTimeout(2000); //連線超時
httpClientPolicy.setAllowChunking(false); //取消塊編碼
httpClientPolicy.setReceiveTimeout(120000); //響應超時
conduit.setClient(httpClientPolicy);
//client.getOutInterceptors().addAll(interceptors);//設定攔截器
try{
Object[] objects = new Object[0];
// invoke("方法名",引數1,引數2,引數3....);
objects = client.invoke("sayHello", "sujin");
System.out.println("返回資料:" + objects[0]);
}catch (Exception e){
e.printStackTrace();
}
}
-------------------------------------------------不怕你懷才不遇,只怕你的才華配不上野心。-------------------------------------------------