problem in concurrent web services

Posted by user548750 on Stack Overflow See other posts from Stack Overflow or by user548750
Published on 2010-12-20T14:52:17Z Indexed on 2010/12/21 14:54 UTC
Read the original article Hit count: 407

Filed under:
|

Hi All I have developed a web services. I am getting problem when two different user are trying to access web services concurrently. In web services two methods are there

  1. setInputParameter
  2. getUserService

    suppose

              Time               User              Operation
              10:10 am           user1             setInputParameter
              10:15 am           user2             setInputParameter
              10:20 am           user1             getUserService 
    

User1 is getting result according to the input parameter seted by user2 not by ( him own )

I am using axis2 1.4 ,eclipse ant build, My services are goes here

  1. User class
  2. service class
  3. service.xml
  4. build file
  5. testclass

package com.jimmy.pojo;


public class User {
 private String firstName;
 private String lastName;
 private String[] addressCity;

 public String getFirstName() {
  return firstName;
 }

 public void setFirstName(String firstName) {
  this.firstName = firstName;
 }

 public String getLastName() {
  return lastName;
 }

 public void setLastName(String lastName) {
  this.lastName = lastName;
 }

 public String[] getAddressCity() {
  return addressCity;
 }

 public void setAddressCity(String[] addressCity) {
  this.addressCity = addressCity;
 }

}
[/code]


[code=java]package com.jimmy.service;

import com.jimmy.pojo.User;

public class UserService {
 private User user;

 public void setInputParameter(User userInput) {
  user = userInput;
 }

 public User getUserService() {
  user.setFirstName(user.getFirstName() + " changed ");
  if (user.getAddressCity() == null) {
   user.setAddressCity(new String[] { "New City Added" });
  } else {
   user.getAddressCity()[0] = "===========";
  }
  return user;
 }

}
[/code]


[code=java]<service name="MyWebServices" scope="application">
 <description>
  My Web Service
    </description>
 <messageReceivers>
  <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
   class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />
  <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
   class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
 </messageReceivers>
 <parameter name="ServiceClass">com.jimmy.service.UserService
 </parameter>

</service>[/code]




[code=java]
<project name="MyWebServices" basedir="." default="generate.service">
 <property name="service.name" value="UserService" />
 <property name="dest.dir" value="build" />
 <property name="dest.dir.classes" value="${dest.dir}/${service.name}" />
 <property name="dest.dir.lib" value="${dest.dir}/lib" /> 
 <property name="axis2.home" value="../../" />
 <property name="repository.path" value="${axis2.home}/repository" />
 <path id="build.class.path">
  <fileset dir="${axis2.home}/lib">
   <include name="*.jar" />
  </fileset>
 </path>
 <path id="client.class.path">
  <fileset dir="${axis2.home}/lib">
   <include name="*.jar" />
  </fileset>
  <fileset dir="${dest.dir.lib}">
   <include name="*.jar" />
  </fileset>
 </path>
 <target name="clean">
  <delete dir="${dest.dir}" />
  <delete dir="src" includes="com/jimmy/pojo/stub/**"/>
 </target>
 <target name="prepare">
  <mkdir dir="${dest.dir}" />
  <mkdir dir="${dest.dir}/lib" />
  <mkdir dir="${dest.dir.classes}" />
  <mkdir dir="${dest.dir.classes}/META-INF" />
 </target>
 <target name="generate.service" depends="clean,prepare">
  <copy file="src/META-INF/services.xml" tofile="${dest.dir.classes}/META-INF/services.xml" overwrite="true" />
  <javac srcdir="src" destdir="${dest.dir.classes}" includes="com/jimmy/service/**,com/jimmy/pojo/**">
   <classpath refid="build.class.path" />
  </javac>
  <jar basedir="${dest.dir.classes}" destfile="${dest.dir}/${service.name}.aar" />
  <copy file="${dest.dir}/${service.name}.aar" tofile="${repository.path}/services/${service.name}.aar" overwrite="true" />
 </target>
</project>

[/code]






[code=java]package com.jimmy.test;

import javax.xml.namespace.QName;

import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import com.jimmy.pojo.User;

public class MyWebServices {
 @SuppressWarnings("unchecked")
 public static void main(String[] args1) throws AxisFault {
  RPCServiceClient serviceClient = new RPCServiceClient();
  Options options = serviceClient.getOptions();
  EndpointReference targetEPR = new EndpointReference(
    "http://localhost:8080/axis2/services/MyWebServices");
  options.setTo(targetEPR);
  // Setting the Input Parameter
  QName opSetQName = new QName("http://service.jimmy.com",
    "setInputParameter");
  User user = new User();
  String[] cityList = new String[] { "Bangalore", "Mumbai" };
  /*       We need to set this for user 2 as user 2    */
  user.setFirstName("User 1  first name");
  user.setLastName("User 1 Last name");
  user.setAddressCity(cityList);
  Object[] opSetInptArgs = new Object[] { user };
  serviceClient.invokeRobust(opSetQName, opSetInptArgs);

  // Getting the weather
  QName opGetWeather = new QName("http://service.jimmy.com",
    "getUserService");

  Object[] opGetWeatherArgs = new Object[] {};
  Class[] returnTypes = new Class[] { User.class };

  Object[] response = serviceClient.invokeBlocking(opGetWeather,
    opGetWeatherArgs, returnTypes);

  System.out.println("Context :"+serviceClient.getServiceContext());

  User result = (User) response[0];

  if (result == null) {
   System.out.println("User is not initialized!");
   return;
  } else {
   System.out.println("*********printing result********");
   String[] list =result.getAddressCity();
   System.out.println(result.getFirstName());
   System.out.println(result.getLastName());
   for (int indx = 0; indx < list.length ; indx++) {
    String string = result.getAddressCity()[indx];
    System.out.println(string);
   }
  }

 }
}

© Stack Overflow or respective owner

Related posts about java

Related posts about axis2