ToB企服应用市场:ToB评测及商务社交产业平台

标题: WebService使用 [打印本页]
作者: 干翻全岛蛙蛙    时间: 2024-6-18 18:06
标题: WebService使用
java发布WebService

   普通maven项目，使用原生jdk发布webservice
  1.pom

  1. <dependencies>
  2.     <dependency>
  3.       <groupId>junit</groupId>
  4.       <artifactId>junit</artifactId>
  5.       <version>3.8.1</version>
  6.       <scope>test</scope>
  7.     </dependency>
  9.     <dependency>
  10.     <groupId>com.alibaba</groupId>
  11.     <artifactId>fastjson</artifactId>
  12.     <version>1.2.76</version>
  13.         </dependency>
  14.        
  15.   </dependencies>
复制代码
2.接口

  1. import javax.jws.WebService;
  2. import javax.jws.WebParam;
  4. /**
  5. * 对外发布服务的接口       
  6. * */
  7. @WebService//(targetNamespace = "http://wsImpl.com/")
  8. public interface HelloWs {
  9.        
  10.         public String sayHello(@WebParam(name="arg0")String name);
  11. }
复制代码
3.实现类

  1. import java.util.HashMap;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.ws.HelloWs;
  6. public class HelloWsImpl implements HelloWs{
  8.         public String sayHello(String name) {
  9.             String jsonStr = json();
  10.                 System.out.print(name);
  11.                 return jsonStr;
  12.         }
  13.        
  14.        
  15.         //将map变成json并通过报文返回
  16.         public String mapJson(){
  17.                 HashMap<String, Object> zhangsan = new HashMap<String, Object>();
  18.         zhangsan.put("name", "张三");
  19.         zhangsan.put("age", 18.4);
  20.         zhangsan.put("birthday", "1900-20-03");
  21.         zhangsan.put("majar", new String[] {"哈哈","嘿嘿"});
  22.         zhangsan.put("null", null);
  23.         zhangsan.put("house", false);
  24.         //System.out.println(new JSONObject(zhangsan).toString());
  25.         String jsonStr = new JSONObject(zhangsan).toString();
  26.         // TODO Auto-generated method stub
  27.         return jsonStr;
  28.         }
  29.        
  30.         //原生json并通过报文返回
  31.         public String json(){
  32.                 JSONObject zhangsan = new JSONObject();
  33.                 zhangsan.put("name", "张三");
  34.             zhangsan.put("age", 18.4);
  35.             zhangsan.put("birthday", "1900-20-03");
  36.             zhangsan.put("majar", new String[] {"哈哈","嘿嘿"});
  37.             zhangsan.put("null", null);
  38.             zhangsan.put("house", false);
  39.             return zhangsan.toString();   
  40.         }
  42. }
复制代码
4.发布类

   主方法运行后，直接在浏览器访问http://ip:8080/ws/hello?wsdl
  1. import javax.xml.ws.Endpoint;
  2. import com.wsImpl.HelloWsImpl;
  5. public class Service {
  7.         public static void main(String[] args) {
  8.                 //设置服务地址，换成你的ip
  9.                 Endpoint.publish("http://10.10.150.20:8080/ws/hello",new HelloWsImpl());
  10.                
  11.                 System.out.println("发布WS服务成功");
  12.         }
  14. }
复制代码
5.调用方法

  1. import java.io.IOException;
  2. import java.net.URL;
  3. import javax.xml.namespace.QName;
  4. import javax.xml.ws.Service;
  5. import com.ws.HelloWs;
  8. public class ProtoCall {
  9.     public static void main(String[] args) throws IOException {
  10.         //创建WSDL地址,不是服务地址
  11.         URL url = new URL("http://10.10.150.20:8080/ws/hello?wsdl");
  13.         /**
  14.          * QName是XML元素的限定名称，是组成XML的最基本的要素
  15.          * */
  16.         //创建服务名称
  17.         //1.namespaceURI - 命名空间地址
  18.         //2.localPart - 服务名称,wsdl中的name,不是@WebService注解中的name
  19.         QName qname = new QName("http://wsImpl.com/", "HelloWsImplService");
  20.         //Service创建视图
  21.         //参数：
  22.         //1.wsdlDocumentLocation - 使用说明书地址
  23.         //2.serviceName - 服务名称
  24.         Service service = Service.create(url, qname);
  25.         //获取实现类
  26.         HelloWs mobileCodeWSSoap = service.getPort(HelloWs.class);
  27.         //调用查询方法
  28.         String result = mobileCodeWSSoap.sayHello("188888888");
  29.         System.out.println(result);
  30.     }
  31. }
复制代码

CXF发布WebService

   普通maven项目，使用apache.cxf发布webservice
  1.pom

  1. <dependencies>
  2.     <dependency>
  3.       <groupId>junit</groupId>
  4.       <artifactId>junit</artifactId>
  5.       <version>3.8.1</version>
  6.       <scope>test</scope>
  7.     </dependency>
  8.    
  9.       <dependency>
  10.             <groupId>org.apache.cxf</groupId>
  11.             <artifactId>cxf-rt-frontend-jaxws</artifactId>
  12.             <version>3.4.3</version>
  13.         </dependency>
  14.    
  15.     <dependency><!-- 内置jetty web服务器 -->
  16.             <groupId>org.apache.cxf</groupId>
  17.             <artifactId>cxf-rt-transports-http-jetty</artifactId>
  18.             <version>3.4.3</version>
  19.             <scope>test</scope>
  20.         </dependency>
  21.     <dependency>
  22.     <groupId>com.alibaba</groupId>
  23.     <artifactId>fastjson</artifactId>
  24.     <version>1.2.76</version>
  25. </dependency>
  26.   </dependencies>
复制代码
2.接口

  1. import javax.jws.WebService;
  2. import javax.jws.WebParam;
  4. /**
  5. * 对外发布服务的接口       
  6. * */
  7. @WebService//(targetNamespace = "http://wsImpl.com/")
  8. public interface HelloWs {
  9.        
  10.         public String sayHello(@WebParam(name="arg0")String name);
  11. }
复制代码
3.实现类

  1. import java.util.HashMap;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.ws.HelloWs;
  6. public class HelloWsImpl implements HelloWs{
  8.         public String sayHello(String name) {
  9.             String jsonStr = json();
  10.                 System.out.print(name);
  11.                 return jsonStr;
  12.         }
  13.        
  14.        
  15.         //将map变成json并通过电文返回
  16.         public String mapJson(){
  17.                 HashMap<String, Object> zhangsan = new HashMap<String, Object>();
  18.         zhangsan.put("name", "张三");
  19.         zhangsan.put("age", 18.4);
  20.         zhangsan.put("birthday", "1900-20-03");
  21.         zhangsan.put("majar", new String[] {"哈哈","嘿嘿"});
  22.         zhangsan.put("null", null);
  23.         zhangsan.put("house", false);
  24.         //System.out.println(new JSONObject(zhangsan).toString());
  25.         String jsonStr = new JSONObject(zhangsan).toString();
  26.         // TODO Auto-generated method stub
  27.         return jsonStr;
  28.         }
  29.        
  30.         //原生json并通过电文返回
  31.         public String json(){
  32.                 JSONObject zhangsan = new JSONObject();
  33.                 zhangsan.put("name", "张三");
  34.             zhangsan.put("age", 18.4);
  35.             zhangsan.put("birthday", "1900-20-03");
  36.             zhangsan.put("majar", new String[] {"哈哈","嘿嘿"});
  37.             zhangsan.put("null", null);
  38.             zhangsan.put("house", false);
  39.             return zhangsan.toString();   
  40.         }
  42. }
复制代码
4.发布类

   主方法运行后，直接在浏览器访问http://ip:8080/ws/hello?wsdl
  1. import org.apache.cxf.interceptor.LoggingInInterceptor;
  2. import org.apache.cxf.interceptor.LoggingOutInterceptor;
  3. import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
  6. import com.wsImpl.HelloWsImpl;
  8. public class Service {
  10.         public static void main(String[] args) {
  11.         
  12.          /**
  13.                 EndpointImpl发布方式
  14.         */
  15.                 //EndpointImpl publish = (EndpointImpl) Endpoint.publish("http://10.10.150.20:8080/ws/hello",new HelloWsImpl());
  16.                 //publish.getOutInterceptors().add(new LoggingOutInterceptor());
  17.                 //publish.getInInterceptors().add(new LoggingInInterceptor());
  19.                
  20.         /**
  21.                 工厂发布方式
  22.         */
  23.         //发布服务的工厂
  24.                 JaxWsServerFactoryBean factory = new JaxWsServerFactoryBean();
  25.                
  26.                 //设置服务地址，换成你的ip
  27.                 factory.setAddress("http://10.10.150.20:8080/ws/hello");
  28.                
  29.                 //设置服务类
  30.                 factory.setServiceBean(new HelloWsImpl());
  31.                
  32.                 //添加日志输入输出拦截器
  33.                 factory.getInInterceptors().add(new LoggingInInterceptor());  
  34.         factory.getOutInterceptors().add(new LoggingOutInterceptor());
  35.                
  36.                 //发布服务
  37.                 factory.create();
  38.                
  39.                 System.out.println("发布WS服务成功");
  40.         }
  42. }
复制代码
5.调用方法

  1. import java.io.IOException;
  2. import java.net.URL;
  3. import javax.xml.namespace.QName;
  4. import javax.xml.ws.Service;
  5. import com.ws.HelloWs;
  8. public class ProtoCall {
  9.     public static void main(String[] args) throws IOException {
  10.         //创建WSDL地址,不是服务地址
  11.         URL url = new URL("http://10.10.150.20:8080/ws/hello?wsdl");
  13.         /**
  14.          * QName是XML元素的限定名称，是组成XML的最基本的要素
  15.          * */
  16.         //创建服务名称
  17.         //1.namespaceURI - 命名空间地址
  18.         //2.localPart - 服务名称,wsdl中的name,不是@WebService注解中的name
  19.         QName qname = new QName("http://wsImpl.com/", "HelloWsImplService");
  20.         //Service创建视图
  21.         //参数：
  22.         //1.wsdlDocumentLocation - 使用说明书地址
  23.         //2.serviceName - 服务名称
  24.         Service service = Service.create(url, qname);
  25.         //获取实现类
  26.         HelloWs mobileCodeWSSoap = service.getPort(HelloWs.class);
  27.         //调用查询方法
  28.         String result = mobileCodeWSSoap.sayHello("188888888");
  29.         System.out.println(result);
  30.     }
  31. }
复制代码

整合SpringBoot发布及调用

1.pom依赖

  1. <dependencies>
  2.         <!-- 核心启动器 -->
  3.         <dependency>
  4.             <groupId>org.springframework.boot</groupId>
  5.             <artifactId>spring-boot-starter</artifactId>
  6.         </dependency>
  8.         <!-- web启动器 -->
  9.         <dependency>
  10.             <groupId>org.springframework.boot</groupId>
  11.             <artifactId>spring-boot-starter-web</artifactId>
  12.         </dependency>
  14.         <!-- webService-->
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-starter-web-services</artifactId>
  18.         </dependency>
  20.         <!-- CXF webservice -->
  21.         <dependency>
  22.             <groupId>org.apache.cxf</groupId>
  23.             <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
  24.             <version>3.2.1</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.apache.cxf</groupId>
  28.             <artifactId>cxf-rt-transports-http</artifactId>
  29.             <version>3.2.1</version>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.apache.cxf</groupId>
  33.             <artifactId>cxf-rt-ws-security</artifactId>
  34.             <version>3.2.1</version>
  35.         </dependency>
  36.         <!-- CXF webservice -->
  38.         <!-- https://mvnrepository.com/artifact/commons-discovery/commons-discovery -->
  39.         <dependency>
  40.             <groupId>wsdl4j</groupId>
  41.             <artifactId>wsdl4j</artifactId>
  42.             <version>1.6.3</version>
  43.         </dependency>
  45.         <!-- Restful接口依赖，用于rest风格接口 -->
  46.         <dependency>
  47.             <groupId>org.apache.cxf</groupId>
  48.             <artifactId>cxf-spring-boot-starter-jaxrs</artifactId>
  49.             <version>3.1.12</version>
  50.         </dependency>
  52.         <dependency>
  53.             <groupId>org.wso2.apache.httpcomponents</groupId>
  54.             <artifactId>httpclient</artifactId>
  55.             <version>4.3.1.wso2v1</version>
  56.         </dependency>
  58.         <!-- https://mvnrepository.com/artifact/org.apache.axis/axis -->
  59.         <dependency>
  60.             <groupId>org.apache.axis</groupId>
  61.             <artifactId>axis</artifactId>
  62.             <version>1.4</version>
  63.         </dependency>
  65.         <!-- https://mvnrepository.com/artifact/commons-httpclient/commons-httpclient -->
  66.         <dependency>
  67.             <groupId>commons-httpclient</groupId>
  68.             <artifactId>commons-httpclient</artifactId>
  69.             <version>3.1</version>
  70.         </dependency>
  73.         <!-- https://mvnrepository.com/artifact/javax.xml/jaxrpc -->
  74.         <dependency>
  75.             <groupId>javax.xml</groupId>
  76.             <artifactId>jaxrpc</artifactId>
  77.             <version>1.1</version>
  78.         </dependency>
  80.         <dependency>
  81.             <groupId>commons-logging</groupId>
  82.             <artifactId>commons-logging</artifactId>
  83.             <version>1.0.4</version>
  84.         </dependency>
  86.         <!-- https://mvnrepository.com/artifact/commons-discovery/commons-discovery -->
  87.         <dependency>
  88.             <groupId>commons-discovery</groupId>
  89.             <artifactId>commons-discovery</artifactId>
  90.             <version>0.5</version>
  91.         </dependency>
  94.         <!-- 阿里JSON解析器 -->
  95.         <dependency>
  96.             <groupId>com.alibaba</groupId>
  97.             <artifactId>fastjson</artifactId>
  98.             <version>1.2.47</version>
  99.         </dependency>
  100.         <dependency>
  101.             <groupId>org.hibernate</groupId>
  102.             <artifactId>hibernate-validator</artifactId>
  103.             <version>6.0.18.Final</version>
  104.         </dependency>
  105.         <dependency>
  106.             <groupId>junit</groupId>
  107.             <artifactId>junit</artifactId>
  108.             <scope>test</scope>
  109.         </dependency>
  112.     </dependencies>
复制代码
2.创建接口及实现类

   接口
  @WebService: 标记此接口为WebService接口；name为接口名称，targetNamespace为名称空间,可以自定义;
@WebMethod: 标记方法为WebService接口中的方法
@WebParam: 标记参数为WebService接口中方法参数,可限定名称(name = “abdc”)，不限定默以为方法参数变量名
  1. import javax.jws.WebMethod;
  2. import javax.jws.WebParam;
  3. import javax.jws.WebService;
  4. import javax.xml.ws.BindingType;
  5. import javax.xml.ws.soap.SOAPBinding;
  7. @WebService(name = "ServerServiceDemo", targetNamespace = "http://server.webservice.example.com")
  8. //@BindingType(value = SOAPBinding.SOAP12HTTP_BINDING)//将SOAP协议定义为1.2 Eclipse自带的WebService Brower只能解析soap1.1的协议,服务器端最好使用高版本的协议
  9. public interface ServerServiceDemo {
  10.     @WebMethod
  11.     String emrService(@WebParam String data);
  12. }
复制代码
  实现类
  @WebService: 标记此接口为WebService接口；name为接口名称，targetNamespace为名称空间,可以自定义；endpointInterface为此类实现接口的全路径
@WebParam: 标记参数为WebService接口中方法参数，可限定名称(name = “abdc”)，不限定默以为方法参数变量名
  1. import com.alibaba.fastjson.JSONObject;
  2. import com.demo.axisDemo.service.ServerServiceDemo;
  3. import org.springframework.stereotype.Component;
  4. import javax.jws.WebParam;
  5. import javax.jws.WebService;
  8. @Component
  9. @WebService(name = "ServerServiceDemo", targetNamespace = "http://server.webservice.example.com",
  10.         endpointInterface = "com.demo.axisDemo.service.ServerServiceDemo")
  11. public class ServerServiceDemoImpl implements ServerServiceDemo {
  13.     @Override
  14.     public String emrService(@WebParam String data) {
  15.         if (null == data || "".equals(data.trim())) {
  16.             return "传入的参数为空";
  17.         }
  18.         System.out.println(data + "     -------------------------");
  19.         return "服务端返回 调用成功:" + data;
  20.     }
  21. }
复制代码
3.编写配置类

  1. @Configuration
  2. public class WebServiceConfig {
  3.        
  4.         /**
  5.           引入接口类
  6.         */
  7.     @Autowired
  8.     private ServerServiceDemo serverServiceDemo;
  9.        
  10.        
  11.        
  12.         /**
  13.      * Apache CXF 核心架构是以BUS为核心，整合其他组件。
  14.      * Bus是CXF的主干, 为共享资源提供一个可配置的场所，作用类似于Spring的ApplicationContext，这些共享资源包括
  15.      * WSDl管理器、绑定工厂等。通过对BUS进行扩展，可以方便地容纳自己的资源，或者替换现有的资源。默认Bus实现基于Spring架构，
  16.      * 通过依赖注入，在运行时将组件串联起来。BusFactory负责Bus的创建。默认的BusFactory是SpringBusFactory，对应于默认
  17.      * 的Bus实现。在构造过程中，SpringBusFactory会搜索META-INF/cxf（包含在 CXF 的jar中）下的所有bean配置文件。
  18.      * 根据这些配置文件构建一个ApplicationContext。开发者也可以提供自己的配置文件来定制Bus。
  19.      */
  20.     @Bean(name = Bus.DEFAULT_BUS_ID)
  21.     public SpringBus springBus() {
  22.         return new SpringBus();
  23.     }
  24.    
  25.    
  26.     /*
  27.      * 此方法作用是改变项目中服务名的前缀名
  28.      * 此方法被注释后, 即不改变前缀名(默认是services), wsdl访问地址为 http://127.0.0.1:8080/services/ws/api?wsdl
  29.      * 去掉注释后wsdl访问地址为：http://127.0.0.1:8080/soap/ws/api?wsdl
  30.     //@Bean
  31.     //public ServletRegistrationBean dispatcherServlet() {
  32.     //    return new ServletRegistrationBean(new CXFServlet(), "/soap/*");
  33.     //}
  34.    
  35.    
  36.    
  37.     /**
  38.      * 此处的EndpointImpl构造方法源码调用了JaxWsServiceFactoryBean及WebServiceFeature，
  39.      * 即在bus中开启webservice功能，并通过JaxWsServiceFactoryBean获取一个具体服务
  40.      *
  41.      * EndpointImpl端点对象，可以将其作用理解为连接bus与java WS服务
  42.      * WebServiceFeature 用于表示可以为 Web 服务启用或禁用的功能。
  43.      * */
  44.     @Bean
  45.     public Endpoint endpoint() {
  46.         EndpointImpl endpoint = new EndpointImpl(springBus(), serverServiceDemo);//363
  47.         endpoint.publish("/ws/api");
  48.         return endpoint;   
  49.     }
  50.    
  51.    
  52. }
复制代码
4.客户端调用

   Axis调用
  1. import org.apache.axis.client.Call;
  2. import org.apache.axis.client.Service;
  3. import org.apache.axis.encoding.XMLType;
  4. import org.apache.axis.message.SOAPHeaderElement;
  5. import org.apache.cxf.configuration.security.AuthorizationPolicy;
  6. import org.apache.cxf.helpers.DOMUtils;
  7. import javax.xml.namespace.QName;
  8. import javax.xml.rpc.ParameterMode;
  9. import java.net.URL;
  12. public class CallUtiles {
  14.         //接口地址
  15.     private static String publishUrl = "http://localhost:8080/services/ws/api?wsdl";
  17.     //wsdl中的targetNamespace
  18.     private static String nameSpaceURI = "http://server.webservice.example.com";
  19.    
  21.     public static String get(String userStr) throws Exception {
  23.         Service service = new Service();
  24.         Call call = (Call) service.createCall();
  25.         call.setTargetEndpointAddress(new URL(publishUrl));
  26.         
  27.         //指定接口路径，要调用的方法名
  28.         call.setOperationName(new QName(nameSpaceURI, "emrService"));
  29.         
  30.         //如果没用@WebParam(name="name")来表明参数名，则方法的入参是啥，这边就必须传一样的参数名才行。不然报错。
  31.         call.addParameter("arg0", XMLType.XSD_STRING, ParameterMode.IN);
  32.         
  33.         call.setReturnType(XMLType.XSD_STRING);
  36.         Object[] obj = new Object[]{userStr};
  37.         String result = (String) call.invoke(obj);
  38.         return result;
  39.     }
  41. }
复制代码
  java原生调用
  1. import com.demo.axisDemo.service.ServerServiceDemo;
  2. import java.io.IOException;
  3. import java.net.URL;
  4. import javax.xml.namespace.QName;
  5. import javax.xml.ws.Service;
  8. public class ProtoCall {
  9.     public static void main(String[] args) throws IOException {
  10.         //创建WSDL地址,不是服务地址
  11.         URL url = new URL("http://127.0.0.1:9088/api/Domain/Xinda-ESB/esb-ec2erp?wsdl");
  13.         /**
  14.          * QName是XML元素的限定名称，是组成XML的最基本的要素
  15.          * */
  16.         //创建服务名称
  17.         //1.namespaceURI - 命名空间地址
  18.         //2.localPart - 服务名称,wsdl中的name,不是@WebService注解中的name
  19.         QName qname = new QName("http://service.erp.esb.xinda.com/IDTIWSReceEC", "IDTIWSReceEC");
  20.         //Service创建视图
  21.         //参数：
  22.         //1.wsdlDocumentLocation - 使用说明书地址
  23.         //2.serviceName - 服务名称
  24.         Service service = Service.create(url, qname);
  25.         //获取实现类
  26.         ServerServiceDemo mobileCodeWSSoap = service.getPort(ServerServiceDemo.class);
  27.         //调用查询方法
  28.         String result = mobileCodeWSSoap.emrService("188888888");
  29.         System.out.println(result);
  30.     }
  31. }
复制代码
  下令工具调用
  1. cmd输入命令：wsdl2java -p com -d ../src -client -encoding utf-8  http://localhost:8080/admin/cxfService?wsdl
  3. 注意：wsdl地址必须与发布publish中的相同，执行后会在../src生成代码，直接使用实现类get方法调用
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4