Apache CXF 与 JAX-WS



在这个 JAX-WS 应用中,我们将像之前的 POJO 应用一样使用 Apache CXF 优先的方法。所以首先我们将为我们的 Web 服务创建一个接口。

声明服务接口

和之前一样,我们将创建一个只有名为 greetings 的一个接口方法的简单服务。服务接口的代码如下所示:

//HelloWorld.java
package com.tutorialspoint.cxf.jaxws.helloworld;
import javax.jws.WebService;

@WebService
public interface HelloWorld {
   String greetings(String text);
}

我们使用@WebService标签注释接口。接下来,我们将实现这个接口。

实现 Web 接口

Web 接口的实现如下所示:

//HelloWorldImpl.java
package com.tutorialspoint.cxf.jaxws.helloworld;
public class HelloWorldImpl implements HelloWorld {
   @Override
   public String greetings(String name) {
      return ("hi " + name);
   }
}

greetings 方法使用@Override标签进行注释。该方法向调用者返回“hi”消息。

接下来,我们将编写开发服务器的代码。

开发服务器

与 POJO 应用不同,我们现在将使用 CXF 提供的 Endpoint 类来发布我们的服务,从而解耦接口。这是通过以下两行代码完成的:

HelloWorld implementor = new HelloWorldImpl();
Endpoint.publish(
   "https://127.0.0.1:9090/HelloServerPort",
   implementor,
   new LoggingFeature()
);

publish 方法的第一个参数指定我们的服务将向客户端提供的 URL。第二个参数指定我们服务的实现类。服务器的完整代码如下所示:

//Server.java
package com.tutorialspoint.cxf.jaxws.helloworld;
import javax.xml.ws.Endpoint;
import org.apache.cxf.ext.logging.LoggingFeature;
public class Server {
   public static void main(String[] args) throws Exception {
      HelloWorld implementor = new HelloWorldImpl();
      Endpoint.publish("https://127.0.0.1:9090/HelloServerPort",
      implementor,
      new LoggingFeature());
      System.out.println("Server ready...");
      Thread.sleep(5 * 60 * 1000);
      System.out.println("Server exiting ...");
      System.exit(0);
   }
}

要部署我们的服务器,您需要对您的项目进行一些修改,如下所示。

部署服务器

最后,要部署服务器应用程序,您需要在 pom.xml 中进行一次修改,以将您的应用程序设置为 Web 应用程序。需要添加到您的pom.xml中的代码如下:

<profiles>
   <profile>
      <id>server</id>
      <build>
         <defaultGoal>test</defaultGoal>
         <plugins>
            <plugin>
               <groupId>org.codehaus.mojo</groupId>
               <artifactId>exec-maven-plugin</artifactId>
               <version>1.6.0</version>
               <executions>
                  <execution>
                     <phase>test</phase>
                     <goals>
                        <goal>java</goal>
                     </goals>
                     <configuration>
                        <mainClass>
                           com.tutorialspoint.cxf.jaxws.helloworld.Server
                        </mainClass>
                     </configuration>
                  </execution>
               </executions>
            </plugin>
         </plugins>
      </build>
   </profile>
</profiles>

在部署应用程序之前,您需要向您的项目添加两个文件。如下面的屏幕截图所示:

Before Deploy JAXWS Aplication

这些文件是 CXF 标准文件,它们定义了CXFServlet的映射。为了方便您快速参考,这里显示了web.xml文件中的代码:

//Web.xml
<?xml version = "1.0" encoding = "UTF-8"??>
<web-app xmlns = "http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.5"
xsi:schemaLocation = "http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
   <display-name>cxf</display-name>
   <servlet>
      <description>Apache CXF Endpoint</description>
      <display-name>cxf</display-name>
      <servlet-name>cxf</servlet-name>
      <servlet-class>
         org.apache.cxf.transport.servlet.CXFServlet
      </servlet-class>
      <load-on-startup>
         1
      </load-on-startup>
   </servlet>
   <servlet-mapping>
      <servlet-name>
         cxf
      </servlet-name>
      <url-pattern>
         /services/*
      </url-pattern>
   </servlet-mapping>
   <session-config>
      <session-timeout>60</session-timeout>
   </session-config>
</web-app>

cxf-servlet.xml中,您声明服务端点的属性。这在下面的代码片段中显示:

<beans ...>
   <jaxws:endpoint xmlns:helloworld = "https://tutorialspoint.com/"
      id = "helloHTTP"
      address = "https://127.0.0.1:9090/HelloServerPort"
      serviceName = "helloworld:HelloServiceService"
      endpointName = "helloworld:HelloServicePort">
   </jaxws:endpoint>
</beans>

在这里,我们定义了服务端点的 ID、服务可用的地址、服务名称和端点名称。现在,您了解了您的服务如何由 CXF servlet 路由和处理。

最终的 pom.xml

pom.xml包含更多依赖项。我们没有描述所有依赖项,而是包含了 pom.xml 的最终版本:

<?xml version = "1.0" encoding = "UTF-8"??>
<project xmlns = "http://maven.apache.org/POM/4.0.0"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0
   http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.tutorialspoint</groupId>
   <artifactId>cxf-jaxws</artifactId>
   <version>1.0</version>
   <packaging>jar</packaging>
   <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <maven.compiler.source>1.8</maven.compiler.source>
      <maven.compiler.target>1.8</maven.compiler.target>
   </properties>
   <profiles>
      <profile>
         <id>server</id>
         <build>
            <defaultGoal>test</defaultGoal>
            <plugins>
               <plugin>
                  <groupId>org.codehaus.mojo</groupId>
                  <artifactId>exec-maven-plugin</artifactId>
                  <version>1.6.0</version>
                  <executions>
                     <execution>
                        <phase>test</phase>
                        <goals>
                           <goal>java</goal>
                        </goals>
                        <configuration>
                           <mainClass>
                              com.tutorialspoint.cxf.jaxws.helloworld.Server
                           </mainClass>
                        </configuration>
                     </execution>
                  </executions>
               </plugin>
            </plugins>
         </build>
      </profile>
      <profile>
         <id>client</id>
         <build>
            <defaultGoal>test</defaultGoal>
            <plugins>
               <plugin>
                  <groupId>org.codehaus.mojo</groupId>
                  <artifactId>exec-maven-plugin</artifactId>
                  <executions>
                     <execution>
                        <phase>test</phase>
                        <goals>
                           <goal>java</goal>
                        <goals>
                        <configuration>
                           <mainClass>
                              com.tutorialspoint.cxf.jaxws.helloworld.Client
                           </mainClass>
                        </configuration>
                     </execution>
                  </executions>
               </plugin>
            </plugins>
         </build>
      </profile>
   </profiles>
   <dependencies>
      <dependency>
         <groupId>org.apache.cxf</groupId>
         <artifactId>cxf-rt-frontend-jaxws</artifactId>
         <version>3.3.0</version>
      </dependency>
      <dependency>
         <groupId>org.apache.cxf</groupId>
         <artifactId>cxf-rt-transports-http</artifactId>
         <version>3.3.0</version>
      </dependency>
      <dependency>
         <groupId>org.apache.cxf</groupId>
         <artifactId>cxf-rt-features-logging</artifactId>
         <version>3.3.0</version>
      </dependency>
      <dependency>
         <groupId>org.apache.cxf</groupId>
         <artifactId>cxf-rt-transports-http-jetty</artifactId>
         <version>3.3.0</version>
      </dependency>
   </dependencies>
</project>

请注意,它还包含一个用于构建客户端的配置文件,我们将在本教程的后面部分学习。

运行 HelloWorld 服务

现在,您可以运行 Web 应用了。在命令窗口中,使用以下命令运行构建脚本。

mvn clean install
mvn -Pserver

您将在控制台中看到以下消息:

INFO: Setting the server's publish address to be https://127.0.0.1:9090/HelloServerPort
Server ready…

和之前一样,您可以通过在浏览器中打开服务器 URL 来测试服务器。

Opening Server URL

由于我们没有指定任何操作,我们的应用程序只向浏览器返回错误消息。

现在,尝试将?wsdl添加到您的 URL,您将看到以下输出:

所以我们的服务器应用程序按预期运行。您可以使用前面描述的 SOAP 客户端(例如Postman)进一步测试您的服务。

在下一节中,我们将学习如何编写使用我们服务的客户端。

开发客户端

在 CXF 应用程序中编写客户端与编写服务器一样简单。以下是客户端的完整代码:

//Client.java
package com.tutorialspoint.cxf.jaxws.helloworld;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import javax.xml.ws.soap.SOAPBinding;
public final class Client {
   private static final QName SERVICE_NAME
   = new QName("http://helloworld.jaxws.cxf.tutorialspoint.com/",
   "HelloWorld");
   private static final QName PORT_NAME
   = new QName("http://helloworld.jaxws.cxf.tutorialspoint.com/",
   "HelloWorldPort");
   private Client() {
   }
   public static void main(String[] args) throws Exception {
      Service service = Service.create(SERVICE_NAME);
      System.out.println("service created");
      String endpointAddress = "https://127.0.0.1:9090/HelloServerPort";
      service.addPort(PORT_NAME, SOAPBinding.SOAP11HTTP_BINDING,
      endpointAddress);
      HelloWorld hw = service.getPort(HelloWorld.class);
      System.out.println(hw.greetings("World"));
   }
}

在这里,我们使用 CXF 提供的Service类绑定到已知服务。我们在Service类上调用create方法以获取服务的实例。我们通过在service实例上调用addPort方法来设置已知端口。

现在,我们可以使用该服务了,我们首先通过在service实例上调用getPort方法来获取服务接口。最后,我们调用我们的greetings方法以在控制台中打印问候消息。

现在,您已经学习了使用 Apache CXF 优先方法的 CXF 基础知识,您将在下一章学习如何在我们的 WSDL 优先方法中使用 CXF。

广告