import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.apache.cxf.endpoint.Client;
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 WSClient {
public static void main(String[] args)throws Exception {
String wsdlUrl = "http://172.16.11.11:8080/webws/CalculatorPort?wsdl";
//动态调用的客户端工厂类
JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
final Client client = factory.createClient(wsdlUrl);
//设置超时单位为毫秒
HTTPConduit http = (HTTPConduit) client.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setConnectionTimeout(3000); //连接超时
httpClientPolicy.setAllowChunking(false); //取消块编码
httpClientPolicy.setReceiveTimeout(3000); //响应超时
http.setClient(httpClientPolicy);
//用线程池试了下client对象线程安全性,发现是安全的
ThreadPoolExecutor pool = new ThreadPoolExecutor(5,50,1000,
TimeUnit.MICROSECONDS,new ArrayBlockingQueue<Runnable>(50));
for (int i=0;i<100;i++){
pool.execute(new Runnable() {
@Override
public void run() {
try {
String threadName = Thread.currentThread().getName();
int a = new Random().nextInt(10);
int b = new Random().nextInt(10);
Object[] res = client.invoke("adD", a,b);
System.out.println(threadName+":"+a+"+"+b+"="+res[0]);
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
}
}
结果:
pool-1-thread-37:0+5=5
pool-1-thread-21:1+4=5
pool-1-thread-33:6+3=9
pool-1-thread-49:6+0=6
pool-1-thread-42:7+1=8
...
...
...
pool-1-thread-7:7+5=12
pool-1-thread-46:9+2=11
pool-1-thread-17:6+2=8
pool-1-thread-34:2+3=5
pool-1-thread-36:8+3=11
pool-1-thread-40:1+9=10
pool-1-thread-26:4+4=8
pool-1-thread-35:3+4=7
分享到:
相关推荐
cxf客户端调用webservice所需jar包
纯java调用ws-security+CXF实现的webservice安全接口
用camel-cxf调用webservice和发布一个webservice接口例子,首先启动QueryServiceMain主函数启动webservice接口,然后启动测试类TestWebservice。例子主要是实现java代码实现camel调用webservice接口
springboot整合CXF发布webservice和客户端调用 项目中每个类都有详细的注释,保证都能看懂,不失为一个学习springboot整合cxf来学习webservice发布调用的好例子
NULL 博文链接:https://liugang594.iteye.com/blog/2022626
现在主流的webService框架,一个是axis2,一个是cxf,本资源是基于cxf框架的简单例子
C#动态调用CXF WEBSERVICE框架共通类。
最近项目中遇到需要去掉老系统的webservice服务中的insert方法,找了很久,发现这样最简单,实测有效!!!
MyCXFService为WebService服务端,MyCXFClient为客户端调用 1、将MyCXFService.zip与MyCXFClient.zip解压 2、将cxf_jar包文件夹下所有包,拷至MyCXFService与MyCXFClient项目WebRoot\WEB-INF\lib\cxf_2.7.8 目录下...
使用CXF生成动态调用webservice接口的客户端,也比较简单。
cxf3.2.0作为服务端或客户端,发布webservice或者调用webservice所需的最少jar包。
webservice对外发布接口全部源码拿起来就能用。还有调用的包需的找我要
cxf技术连接webservice接口所需所有jar包,我自己做项目时自己用的。
用CXF作为客户端调用webService的demo:本人亲测可用,eclipse工程项目包含完整代码和完整jar包, 只要用eclipse导入项目即可,运行控制台显示success或者false字符串,说明OK。
Java 调用webservice cxf客户端调用demo和服务端,包含jar包,服务端发布后直接用客户端调用
这是一个关于cxf框架发布webservice的视频。,,,,,,
2.用cxf开发webservice 3.这个服务端和客户端的小demo 在服务端 对外开放接口服务,然后在客户端 调用服务端的方法, 实现客户端(一个javaweb项目)对服务端(javaweb项目)方法的调用, 实际上就是发送和接收消息...
cxf框架实现webservice调用demo,实现webservice发布,以及调用。
java CXF客户端请求ERP SAP webservice通过用户名和密码验证功能!
webservice天气预报例子cxf实例,