封装客户端方法clientUtil
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 17:46
*/
public class clientUtil {
public static String callWebSV(String wsdUrl, String operationName, String... params) throws Exception {
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
Client client = dcf.createClient(wsdUrl);
//client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME, PASS_WORD));
Object[] objects;
// invoke('方法名',参数1,参数2,参数3....);
objects = client.invoke(operationName, params);
return objects[0].toString();
}
}
接口类
import javax.jws.WebMethod;
import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;
import javax.xml.ws.WebServiceProvider;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 15:26
*/
@WebService(name = 'TestService', // 暴露服务名称
targetNamespace = 'http://server.webservice.Bag.admin.com'// 命名空间,一般是接口的包名倒序
)
public interface TestService {
@WebMethod
public String sendMessage(@WebParam(name = 'username') String username);
@WebMethod
public boolean getFlag(@WebParam(name = 'username') String username);
}
import javax.jws.WebMethod;
import javax.jws.WebParam;
import javax.jws.WebService;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 17:02
*/
@WebService(name = 'CatService', // 暴露服务名称
targetNamespace = 'http://server.webservice.Bag.admin.com'// 命名空间,一般是接口的包名倒序
)
public interface CatService {
@WebMethod
public String message(@WebParam(name = 'name') String name);
}
pom依赖
调用接口类
首先启动服务端。启动客户端。
使用定时调用webservice接口。
import com.admin.webAppoint.webservice.client.clientUtil;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RestController;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 17:50
*/
@RestController
@Component
public class TestController {
//在一个方法中连续调用多次WebService接口,每次调用前需要重置上下文。
ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
@Scheduled(cron='*/15 * * * * ?')
public String getMessage() {
Thread.currentThread().setContextClassLoader(classLoader);//在获取连接之前 还原上下文
System.out.println('======开始调用webservice接口=====');
String url = 'http://localhost:8082/webService/CatService?wsdl';
String methodName = 'message';
System.out.println('Calling' + url);
String result='';
try {
result=clientUtil.callWebSV(url, methodName, 'name');
} catch (Exception e) {
System.err.println('接口调用失败!!!!');
return '失败';
}
System.out.println('===Finished!===恭喜你啊!!!CatService接口调用成功!!!===获得的数据是:'+result);
return 'Finished!';
}
@Scheduled(cron='*/5 * * * * ?')
public String getMessage2() {
Thread.currentThread().setContextClassLoader(classLoader);//在获取连接之前 还原上下文
System.out.println('======开始调用webservice接口=====');
String url = 'http://localhost:8082/webService/TestService?wsdl';
String methodName = 'sendMessage';
System.out.println('Calling' + url);
String result='';
try {
result=clientUtil.callWebSV(url, methodName, 'username');
} catch (Exception e) {
System.err.println('接口调用失败!!!!');
return '失败';
}
System.out.println('===Finished!===恭喜你啊!!!TestService接口调用成功!!!===获得的数据是:'+result);
return 'Finished!';
}
}
接口实现类
import com.admin.Bag.webservice.server.TestService;
import org.springframework.stereotype.Component;
import javax.jws.WebService;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 15:31
*/
@WebService(serviceName = 'TestService', // 与接口中指定的name一致
targetNamespace = 'http://server.webservice.Bag.admin.com', // 与接口中的命名空间一致,一般是接口的包名倒
endpointInterface = 'com.admin.Bag.webservice.server.TestService'// 接口地址
)
@Component
public class TestServiceImpl implements TestService {
@Override
public String sendMessage(String username) {
return '=====Hello! ' + username + '=====';
}
@Override
public boolean getFlag(String username) {
//
return true;
}
}
import com.admin.Bag.webservice.server.CatService;
import org.springframework.stereotype.Component;
import javax.jws.WebService;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 17:05
*/
@WebService(serviceName = 'CatService', // 与接口中指定的name一致
targetNamespace = 'http://server.webservice.Bag.admin.com', // 与接口中的命名空间一致,一般是接口的包名倒
endpointInterface = 'com.admin.Bag.webservice.server.CatService'// 接口地址
)
@Component
public class CatServiceImpl implements CatService {
@Override
public String message(String name) {
//
return '一只小猫猫';
}
}
pom依赖
我们经常需要在两个系统之间进行一些数据的交互,这时候我们就需要开发数据交互接口。
启动项目。我的项目端口号是8080。浏览器访问地址:http://localhost:8082/webService可见接口信息CatService和TestService,点进链接可以看每个接口的wsdl文档。
客户端开发
服务端代码开发
webservice配置文件
import com.admin.Bag.webservice.server.impl.CatServiceImpl;
import com.admin.Bag.webservice.server.impl.TestServiceImpl;
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;
/**
* @author zll
* @version 1.0
* @date 2020/6/10 15:37
*/
@Configuration
public class cxfConfig {
@Bean
public ServletRegistrationBean disServlet() {
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new CXFServlet(), '/webService/*');
return servletRegistrationBean;
}
@Bean(name = Bus.DEFAULT_BUS_ID)
public SpringBus springBus() {
return new SpringBus();
}
@Bean
public Endpoint endpoint() {
EndpointImpl endpoint = new EndpointImpl(springBus(), new TestServiceImpl());
endpoint.publish('/TestService');
return endpoint;
}
@Bean
public Endpoint endpoint2() {
EndpointImpl endpoint = new EndpointImpl(springBus(), new CatServiceImpl());
endpoint.publish('/CatService');
return endpoint;
}
}
在网上跟着好多个教程做了好多遍,终于能走通。
客户端是一个单独的项目。
导入相关的依赖包。
org.springframework.boot
spring-boot-starter-web-services
org.apache.cxf
cxf-rt-frontend-jaxws
3.1.6
org.apache.cxf
cxf-rt-transports-http
3.1.6
不同的SpringBoot版本对应的依赖版本也不一样,我也是试了好久终于成了。我的SpringBoot版本号是0.RELEASE。
org.apache.cxf
cxf-rt-frontend-jaxws
3.0.1
org.apache.cxf
cxf-rt-transports-http-jetty
3.0.1
一般来说,遇到比较多的接口有HTTP接口、WebService接口、FTP文件传输。今天我要来学习一下在SpringBoot框架下进行简单的webservice接口的开发。
创建了两个wbservice接口TestService和CatService。
文章为作者独立观点,不代表股票交易接口观点