Jetty集成Resteasy发布rest服务Demo

谁借莪１个温暖的怀抱￠ 2022-07-14 10:27 188阅读 0赞

**一.开端：**

前段时间做Restful接口调用相关功能，找了几个方法，最终选用了Spring自带的rest服务请求的方法，但是也看到了另一种方式ResteasyClient，尝试着写了一个小的Demo：

这个东西是JBoss的，所以需要引入的jar有：

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

1 
     2         <dependency org="commons-codec" name="commons-codec" rev="1.10" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     3         <dependency org="commons-pool" name="commons-pool" rev="1.6" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     4         <dependency org="commons-io" name="commons-io" rev="2.4" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     5         
     6         <dependency org="javax.validation" name="validation-api" rev="1.1.0.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     7         <dependency org="org.hibernate" name="hibernate-validator" rev="5.1.3.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     8         <dependency org="com.fasterxml" name="classmate" rev="1.1.0" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
     9         
    10         <dependency org="com.fasterxml.jackson.core" name="jackson-core" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    11         <dependency org="com.fasterxml.jackson.core" name="jackson-annotations" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    12         <dependency org="com.fasterxml.jackson.core" name="jackson-databind" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    13         
    14         <dependency org="org.slf4j" name="slf4j-api" rev="1.7.10" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    15         <dependency org="org.slf4j" name="jcl-over-slf4j" rev="1.7.10" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    16         <dependency org="org.slf4j" name="jul-to-slf4j" rev="1.7.10" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    17         <dependency org="org.slf4j" name="log4j-over-slf4j" rev="1.7.10" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    18         <dependency org="ch.qos.logback" name="logback-classic" rev="1.1.2" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    19         <dependency org="ch.qos.logback" name="logback-core" rev="1.1.2" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    20         <dependency org="org.jboss.logging" name="jboss-logging" rev="3.2.1.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    21         
    22         
    23         <dependency org="org.apache.httpcomponents" name="httpclient" rev="4.4.1" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    24         <dependency org="org.apache.httpcomponents" name="httpcore" rev="4.4.1" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    25         <dependency org="org.jboss.resteasy" name="resteasy-jaxrs" rev="3.0.14.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    26         <dependency org="org.jboss.resteasy" name="resteasy-client" rev="3.0.14.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    27         <dependency org="org.jboss.resteasy" name="resteasy-jackson2-provider" rev="3.0.14.Final" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    28         <dependency org="org.jboss.resteasy" name="jaxrs-api" rev="3.0.12.Final" />
    29         <dependency org="com.fasterxml.jackson.jaxrs" name="jackson-jaxrs-json-provider" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    30         <dependency org="com.fasterxml.jackson.jaxrs" name="jackson-jaxrs-base" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    31         <dependency org="com.fasterxml.jackson.module" name="jackson-module-jaxb-annotations" rev="2.7.3" conf="compile->compile(*),master(*);runtime->runtime(*)" transitive="false"/>
    32

ivy.xml

新建一个java工程，写了一个测试类：

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

1 public class RestEasy {
     2     
     3     public static void main(String[] args) {
     4         
     5         LogonRequest lr = new LogonRequest();
     6         lr.setPrincipal("admin");
     7         lr.setPassword("123456");
     8         lr.setPrincipalType(PrincipalType.UniqueName);
     9         ResteasyClient _restClient =  (new ResteasyClientBuilder()).build();
    10         ResteasyWebTarget target = _restClient.target("http://127.0.0.1:9080/logon");
    11         Builder post = target.request().header("Content-Type", "application/json;charset=utf-8");
    12         post.accept(MediaType.APPLICATION_JSON);
    13         post.acceptEncoding("UTF-8");
    14         Response response =  post.post(Entity.entity(lr, MediaType.APPLICATION_JSON));
    15         LogonResponse logon = response.readEntity(LogonResponse.class);
    16         
    17         _restClient =  (new ResteasyClientBuilder()).build();
    18         UriBuilder builder = UriBuilder.fromPath("http://127.0.0.1:9080/byMoId")
    19                 .replaceQueryParam("sid", logon.getSessionId())
    20                 .replaceQueryParam("id", "1234566");
    21         target = _restClient.target(builder);
    22         target.queryParam("sid", logon.getSessionId());
    23         
    24         post = target.request().header("Content-Type", "application/json;charset=utf-8");
    25         post.accept(MediaType.APPLICATION_JSON);
    26         post.acceptEncoding("UTF-8");
    27         response =  post.get();
    28         System.out.println(response.getStatus());
    29     }

RestEasy.java

在去学习这个客户端时，了解到还要对应的服务端，是用于发布rest服务的：

![复制代码][copycode.gif]

RESTEasy是JBoss的开源项目之一，是一个RESTful Web Services框架。RESTEasy的开发者Bill Burke同时也是JAX-RS的J2EE标准制定者之一。JAX-RS是一个JCP制订的新标准，用于规范基于HTTP的RESTful Web Services的API。

RESTEasy 项目是 JAX-RS 的一个实现，集成的一些亮点：

*  不需要配置文件，只要把JARs文件放到类路径里面，添加 @Path 标注就可以了。
 *  完全的把 RESTEeasy 配置作为Seam 组件来看待。
 *  HTTP 请求由Seam来提供，不需要一个额外的Servlet。
 *  Resources 和providers可以作为 Seam components (JavaBean or EJB)，具有全面的Seam injection,lifecycle, interception, 等功能支持。
 *  支持在客户端与服务器端自动实现GZIP解压缩。

![复制代码][copycode.gif]

在上面新建的工程里面写一个服务端代码，Web容器用Jetty,因为这是可以内嵌的应用服务器，试着集成Resteasy；（与SpringBoot功能相似）

Jetty 是一个开源的servlet容器，它为基于Java的web容器，例如JSP和servlet提供运行环境。Jetty是使用Java语言编写的，它的API以一组JAR包的形式发布。开发人员可以将Jetty容器实例化成一个对象，可以迅速为一些独立运行（stand-alone）的Java应用提供网络和web连接。

**二、过程**

先上工程结构图：

![676383-20161206204804991-452370322.png][]

1、在原来的ivy.xml文件中添加jetty相关依赖：

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

<dependency org="org.eclipse.jetty" name="jetty-continuation" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-deploy" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-http" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-io" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-jmx" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-rewrite" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-security" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-server" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-servlet" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-servlets" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-util" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-webapp" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="org.eclipse.jetty" name="jetty-xml" rev="9.3.8.v20160314" transitive="false"/>
            <dependency org="javax.servlet" name="javax.servlet-api" rev="3.1.0" transitive="false"/>

2、启动Jetty的代码：

![复制代码][copycode.gif]

package com.jboss.rest.service;
    
    import org.eclipse.jetty.server.Server;
    import org.eclipse.jetty.webapp.WebAppContext;
    
    import com.jboss.rest.service.init.Initializer;
    
    public class JettyServer {
    
        
        public static void main(String[] args) throws Exception {
            String homedir = Initializer.getHomeDir(); //获取工程当前路径
            new Initializer().init(); //配置文件和日志配置
            Server server = new Server(8085);
            server.setStopAtShutdown(true);
            server.setStopTimeout(300000);
            WebAppContext context = new WebAppContext(homedir+"/webapps", "/test");
            context.setDefaultsDescriptor(homedir+"/jetty/webdefault.xml");
            context.setDescriptor(homedir+"/resteasy/web.xml");
            server.setHandler(context);
            server.start();
            server.join();
        }
    }

![复制代码][copycode.gif]

3、集成Resteasy的相关代码：

![复制代码][copycode.gif]

<?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
        version="3.1">
    
        <display-name>ResteasyJboss</display-name>
        <welcome-file-list>
            <welcome-file>index.html</welcome-file>
        </welcome-file-list>
    
        
        <servlet>
            <servlet-name>Resteasy</servlet-name>
            <servlet-class>org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher</servlet-class>
            
            <init-param>
                <param-name>javax.ws.rs.Application</param-name>
                <param-value>com.jboss.rest.service.RestApplication</param-value>
            </init-param>
        </servlet>
        <servlet-mapping>
            <servlet-name>Resteasy</servlet-name>
            <url-pattern>/rest/*</url-pattern>
        </servlet-mapping>
    
    </web-app>

![复制代码][copycode.gif]

实现了javax.ws.rs.core.Application接口的实现类和服务发布实现:

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

1 package com.jboss.rest.service.impl;
     2 
     3 import javax.ws.rs.GET;
     4 import javax.ws.rs.Path;
     5 import javax.ws.rs.core.Response;
     6 
     7 
     8 @Path("/rest")
     9 public class RestServiceImpl extends RestService{
    10 
    11     @GET
    12     @Path("/test")
    13     public Response test()
    14     {
    15         String result = "ok you get it";
    16 
    17         return Response.status(200).entity(result).build();
    18     }
    19     
    20     
    21     
    22 }

RestServiceImpl.java

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

package com.jboss.rest.service;
    
    import java.util.HashSet;
    import java.util.Set;
    
    import javax.ws.rs.core.Application;
    
    import com.jboss.rest.service.impl.PostRestImpl;
    import com.jboss.rest.service.impl.RestServiceImpl;
    
    public class RestApplication extends Application
    {
        private Set<Object> singletons = new HashSet<Object>();
    
        public RestApplication()
        {
            // 构造方法中注册REST服务类
            this.singletons.add(new RestServiceImpl());
            this.singletons.add(new PostRestImpl());
        }
    
        @Override
        public Set<Object> getSingletons()
        {
            return this.singletons;
        }
    }

RestApplication.java

![复制代码][copycode.gif]

package com.jboss.rest.service.impl;
    
    import javax.ws.rs.POST;
    import javax.ws.rs.Path;
    import javax.ws.rs.Produces;
    import javax.ws.rs.core.MediaType;
    
    
    import com.jboss.test.rest.MyUser;
    
    @Path("/rest")
    public class PostRestImpl {
        
        @POST
        @Path("/post")
        @Produces({MediaType.APPLICATION_JSON})
        public MyUser getUser( MyUser user){
            return new MyUser(user.age, user.name);
        }
    }

![复制代码][copycode.gif]

4、运行JettyServer.java即可启动服务，访问Resteasy发布的接口；

三、最后：

Jetty可以模拟实现Comet技术，还基于Jetty实现了一个Comted框架，打算试着实现以下：

![复制代码][copycode.gif]

package com.jboss.comet;
    
    
    import java.io.IOException;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import org.eclipse.jetty.continuation.ContinuationSupport;
    import org.eclipse.jetty.continuation.Continuation; 
    
    @WebServlet(asyncSupported = true)
    public class CometServlet extends HttpServlet {
    
        private static final long serialVersionUID = -5813841480549331019L;
    
        private static final long TIME_OUT = 30000;
        
        @Override
        protected void doGet(HttpServletRequest req, HttpServletResponse response) throws ServletException, IOException {
            
            Continuation continuation = ContinuationSupport.getContinuation(req); 
    
                if (continuation.isInitial()) {
                    continuation.setTimeout(TIME_OUT);
                    continuation.suspend();
                }
                else {
                  response.setContentType("text/html");
                  response.setStatus(HttpServletResponse.SC_OK);
                  response.getWriter().println("<h1>Hello World!</h1>");
                }
              }
    }

![复制代码][copycode.gif]

看了根据，试着写了一些代码，但还需要更进一步学习一下；

[ContractedBlock.gif]: http://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif
[ExpandedBlockStart.gif]: /images/20220714/ad55b48589b1455a82f9335980b07425.png
[copycode.gif]: /images/20220714/5071a1847624420f951200255052457e.png
[676383-20161206204804991-452370322.png]: /images/20220714/fd4336d1c97e474c8c6712f24e1e1043.png