- 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
相关推荐
在服务端,你需要创建一个支持SOAP的Web Service,比如使用Java的JAX-WS或CXF框架。定义方法,接受参数,返回自定义类。确保服务端的WSDL(Web Service描述语言)文档正确地描述了自定义类的结构。 五、注意事项 1....
1. **线程管理**:由于Android主线程不能进行耗时操作,如网络请求,因此通常需要在子线程中进行网络通信,然后通过Handler或AsyncTask更新UI。 2. **错误处理**:处理网络连接失败、超时、数据解析错误等各种异常...
消费者端设置优先级更高,可以灵活控制服务调用的超时,超时时,服务端线程不会被占用,但会产生警告。 【Dubbo注册中心】 - **Multicast注册中心**:无中心节点,通过组播地址实现服务注册和发现。 - **Zookeeper...
3. WebService 协议:基于 WebService 的远程调用协议,集成 CXF 实现,提供和原生 WebService 的互操作。多个短连接,基于 HTTP 传输,同步传输,适用系统集成和跨语言调用。 4. HTTP 协议:基于 Http 表单提交的...
3. **webservice**:基于WebService的远程调用协议,集成CXF库,支持与原生WebService的互操作。它使用HTTP传输,适用于系统集成和跨语言调用,多采用短连接,同步传输。 4. **http**:使用Spring的HttpInvoke实现...
Dubbo超时设置能保证服务调用的稳定性,避免因服务延迟导致的线程阻塞和资源浪费。 Dubbo支持的注册中心有多种,包括Multicast注册中心、Zookeeper注册中心、redis注册中心等。Multicast注册中心不需要中心节点,...
- **特点**:基于WebService的远程调用协议,集成CXF实现,提供和原生WebService的互操作。 - **传输协议**:HTTP - **序列化方式**:XML/JSON - **应用场景**:适用于系统集成和跨语言调用。 - **优点**:良好的跨...
这样,当`shutdownNow`发出中断请求时,线程可以在适当的位置安全地退出,实现优雅关闭。 在实际开发中,我们还需要注意,即使调用了`shutdownNow`,仍需要对可能出现的InterruptedException进行处理,因为`...