Asynchronous invoke web serivce by AXIS2

Submitted by neoqing on June 30, 2008 - 18:41

Hi guys: Recently, I test asynchronous web service with axis2,the service has been deployed as a asynchronous service and the client do a non-blocking invoke.client code shows below

Options options = new Options(); options.setTo(targetEPR); options.setTransportInProtocol(Constants.TRANSPORT_HTTP); options.setUseSeparateListener(true); options.setAction("urn:test"); ConfigurationContext configurationContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem( "E:\\axis2-1.4\\repository", "E:\\axis2-1.4\\conf\\axis2.xml"); //Non-Blocking Invocation AxisService service= new AxisService("AsynchService"); service.addOperation(createOperation()); ServiceClient sender = new ServiceClient(configurationContext,service); sender.setOptions(options); sender.engageModule("addressing"); sender.sendReceiveNonBlocking(new QName("http://asych.neo.net", "test"),payload, callBack); the first invoke is ok,after that I send two consecutive non-blocking invokings,get the error message below [WARN] Attempt number 1 of 10 to reestalish connection listener org.apache.axis2.transport.http.server.DefaultConnectionListener@10849bc due to failure java.net.BindException: Address already in use: JVM_Bind at java.net.PlainSocketImpl.socketBind(Native Method) at java.net.PlainSocketImpl.bind(Unknown Source) at java.net.ServerSocket.bind(Unknown Source) at java.net.ServerSocket.(Unknown Source) at java.net.ServerSocket.(Unknown Source) at org.apache.axis2.transport.http.server.DefaultConnectionListener.run(DefaultConnectionListener.java:72) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690) at java.lang.Thread.run(Unknown Source) So, is there anyboby can help me? thanks in advance! Neo

Change the port using the axis2.xml

Submitted by keith on June 30, 2008 - 20:19.

When your using a separate Listener to invoke a service in a async manner the client starts a separate server (Simple HTTP Server) to listen to the response. So In this case it looks like your server is running on 6060 (The default port the simple HTTP server uses). So you will either have to change the port that the server or clients run. You can do this by editing your axis2.xml. Thanks, Keith. http://www.keith-chapman.org

Maybe tow same listeners running

Submitted by neoqing on July 1, 2008 - 01:34.

Hi keith,thanks for your quick reley,I do not try your approach,because my app use 8080,I think maybe just because two same listeners running,the 2nd request has been sent when the 1st does not close(waiting the response because it is async),it should cause the error? could you please explain the axis2 how to creat the two listener? thanks a lot!

Change the source code

Submitted by neoqing on July 2, 2008 - 00:23.

How about changing the source code(org.apache.axis2.transport.http.server.SimpleHttpServer.java) public SimpleHttpServer(HttpFactory httpFactory, int port) throws IOException { this.httpFactory = httpFactory; this.port = Util.getAvaliblePort(port);//add my code at here this.workerFactory = httpFactory.newRequestWorkerFactory(); this.params = httpFactory.newRequestConnectionParams(); this.params.setIntParameter(AxisParams.LISTENER_PORT, port); }

the listener does not close

Submitted by neoqing on July 3, 2008 - 18:47.

After I tested the async invoking, I found that the listenner which monitor the callback does not close after receive the response. the condition is we do not use System.exit(0),after reading the code regarding org.apache.axis2.transport.http.SimpleHttpServer.there is a line of code shows below Runtime.getRuntime().addShutdownHook(new ShutdownThread(receiver)); so if the user does not exit,the listener should not be closed. Through our testing it costs 20M memory per simpleHttpServer,if axis2 engine always does not close the listernes,the application server will OOM soon or later. So I think this is a bug.

Our solution

Submitted by neoqing on July 3, 2008 - 19:06.

Once we create the stub instance, add the code below ConfigurationContext configurationContext=ConfigurationContextFactory.createConfigurationContextFromFileSystem("C:\\axis2-1.3\\repository","C:\\axis2-1.3\\conf\\axis2.xml"); AxisAsynStub stub = new AxisAsynStub(configurationContext); int availablePort=getAvailablePort();//get a available port TransportListener listener=new SimpleHTTPServer(configurationContext,avalibePort); stub._getServiceClient().getOptions().setListener(listener); stub._getServiceClient().engageModule("addressing"); stub._getServiceClient().getOptions().setUseSeparateListener(true); .....//invoke web service at here listener.destroy();//destroy it after recerive the response

WSO2 Stratos Services

WSO2 Stratos

WSO2 Carbon Studio

Enterprise Service Bus

Business Rules Server

Governance Registry

Identity Server

Business Activity Monitor

Message Broker

Gadget Server

Business Process Server

Mashup Server

Data Services Server

Application Server

Complex Event Processing Server

Web Services Framework for PHP

Web Services Framework for C++

Web Services Framework for C

Carbon