CXF设置连接超时时间

下面的代码希望对CXF开发的朋友有用。

   Object obj = getCxfConn(sAddress, clazz);
   recieveTimeOutWrapper(obj);
   
   private static Object getCxfConn(String sAddress, Class< ? > clazz)
        throws Exception
    {
        if (null == sAddress || null == clazz)
        {
            return null;
        }

        Object obj = null;

        // 连接服务器端的URL地址
        String sURL = getServerCxfUrl(sAddress); // 该方法为自己写的，可以忽略，下面是本地调试地址，该方法就是获取类似下面的地址。

        // 本地jetty调试的URL地址
        // String sURL = "http://localhost:9000/" + sAddress;

        try
        {
            ClientProxyFactoryBean factory = new ClientProxyFactoryBean();
            factory.setServiceClass(clazz);
            factory.setAddress(sURL);

            obj = factory.create();
        }
        catch (Exception e)
        {
            throw new Exception(e.toString());
        }

        return obj;

    }

    private static void recieveTimeOutWrapper(Object o)
    {
        Conduit conduit = (ClientProxy.getClient(o).getConduit());
        HTTPConduit hc = (HTTPConduit)conduit;
        HTTPClientPolicy client = new HTTPClientPolicy();
        client.setReceiveTimeout(1000 * 60 * 5); // 5分钟超时时间。 该时间为响应超时。
         // client.setConnectionTimeout(1000 * 45); // 45秒的连接超时。
        hc.setClient(client);
    }

评论

2 楼 markzy 2013-01-21  

很好，很有用

1 楼 paladin1988 2013-01-08  

really nice work..