You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by "rnell (JIRA)" <ji...@apache.org> on 2006/04/12 14:05:28 UTC
[jira] Commented: (AXIS2-546) Multithreaded client dies with
JVM_BIND address already in use
[ http://issues.apache.org/jira/browse/AXIS2-546?page=comments#action_12374174 ]
rnell commented on AXIS2-546:
-----------------------------
Please close, threads trying to launch separate listeners on same port. I needed to configure a new Context for each thread or reuse an existing one as by default a new context is created for each thread all competing for the same port.
> Multithreaded client dies with JVM_BIND address already in use
> --------------------------------------------------------------
>
> Key: AXIS2-546
> URL: http://issues.apache.org/jira/browse/AXIS2-546
> Project: Apache Axis 2.0 (Axis2)
> Type: Bug
> Components: client-api
> Versions: 0.95
> Reporter: rnell
> Attachments: test.zip
>
> I created a multithreaded client using junitperf on the samples provided with axis2. I launch 10 copies of the client and each tries to bind to the same port. Seems each client (thread) should use the same listener. Self contained demonstration code is provided in attached zip.
> The blocking/single transport code works. The nonblocking/dual transport fails.
> Exception and code below. I'll try to attach zip of code as well.
> 16:12:58,311 DEBUG [SimpleHttpServer] Starting test HTTP server on port 6060
> 16:12:58,326 ERROR [SimpleHTTPServer] java.net.BindException: Address already in use: JVM_Bind
> org.apache.axis2.AxisFault: Address already in use: JVM_Bind; nested exception is:
> java.net.BindException: Address already in use: JVM_Bind
> at org.apache.axis2.transport.http.SimpleHTTPServer.start(SimpleHTTPServer.java:193)
> import com.clarkware.junitperf.LoadTest;
> import com.clarkware.junitperf.TestFactory;
> import junit.framework.Test;
> import junit.framework.TestCase;
> import junit.framework.TestSuite;
> public class EchoNonBlockingDualClientPerfTester extends TestCase {
> public static Test suite() {
> TestSuite suite = new TestSuite();
> suite.addTest( makeLoadTest( 10, 1 ) );
> return suite;
> }
> public static Test makeLoadTest( int users, int iterations ) {
> Test factory = new TestFactory( EchoNonBlockingDualClientTester.class );
> Test loadTest = new LoadTest( factory, users, iterations );
> return loadTest;
> }
> public static void main( String[] args ) {
> junit.textui.TestRunner.run( suite() );
> }
> }
> import com.sempra.client.ClientUtil;
> import org.apache.axis2.AxisFault;
> import org.apache.axis2.addressing.EndpointReference;
> import org.apache.axis2.client.Options;
> import org.apache.axis2.client.ServiceClient;
> import org.apache.axis2.client.async.AsyncResult;
> import org.apache.axis2.client.async.Callback;
> import org.apache.ws.commons.om.OMElement;
> import javax.xml.namespace.QName;
> import javax.xml.stream.XMLOutputFactory;
> import javax.xml.stream.XMLStreamException;
> import java.io.StringWriter;
> import java.net.URL;
> public class EchoNonBlockingDualClientTester extends junit.framework.TestCase {
> private static EndpointReference targetEPR = new EndpointReference( "http://localhost:8080/axis2/services/MyService" );
> static int seq = 0;
> static int getSequence() {
> return seq++;
> }
> public void test() throws Throwable {
> try {
> final OMElement payload = TestClientUtil.getEchoOMElement( getSequence() );
> Options options = new Options();
> options.setTo( targetEPR );
> options.setTransportInProtocol( new URL( targetEPR.getAddress() ).getProtocol() );
> options.setUseSeparateListener( true );
> options.setAction( "urn:echo" );
> //Callback to handle the response
> Callback callback = new Callback() {
> public void onComplete( AsyncResult result ) {
> try {
> StringWriter writer = new StringWriter();
> result.getResponseEnvelope().serialize( XMLOutputFactory.newInstance().createXMLStreamWriter( writer ) );
> writer.flush();
> System.out.println( writer.toString() );
> String request = payload.getFirstChildWithName( new QName( "Text" ) ).getText();
> OMElement body = result.getResponseEnvelope().getBody();
> OMElement echo = body.getFirstChildWithName( new QName( "echo" ) );
> OMElement text = echo.getFirstChildWithName( new QName( "Text" ) );
> String response = text.getText();
> assertEquals( request, response );
> }
> catch( XMLStreamException e ) {
> onError( e );
> }
> }
> public void onError( Exception e ) {
> e.printStackTrace();
> }
> };
> //Non-Blocking Invocation
> ServiceClient sender = new ServiceClient();
> sender.setOptions( options );
> sender.sendReceiveNonBlocking( payload, callback );
> ClientUtil.waitForCallback( callback, 30000 );
> assertTrue( callback.isComplete() );
> //Need to close the Client Side Listener.
> System.exit( 0 );
> }
> catch( AxisFault axisFault ) {
> axisFault.printStackTrace();
> }
> catch( Exception ex ) {
> ex.printStackTrace();
> }
> }
> public static void main( String[] args ) {
> junit.textui.TestRunner.run( EchoNonBlockingDualClientTester.class );
> }
> }
> import org.apache.ws.commons.om.OMElement;
> import org.apache.ws.commons.om.OMFactory;
> import org.apache.ws.commons.om.OMAbstractFactory;
> import org.apache.ws.commons.om.OMNamespace;
> public class TestClientUtil {
> public static OMElement getEchoOMElement( int clientId ) {
> OMFactory fac = OMAbstractFactory.getOMFactory();
> OMNamespace omNs = fac.createOMNamespace( "http://example1.org/example1", "example1" );
> OMElement method = fac.createOMElement( "echo", omNs );
> OMElement value = fac.createOMElement( "Text", omNs );
> value.addChild( fac.createText( value, "Axis2 Echo String clientId=" + clientId ) );
> method.addChild( value );
> return method;
> }
> }
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
http://issues.apache.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see:
http://www.atlassian.com/software/jira