Jersey入门

Posted 2020-10-13 coshaho

 

package com.coshaho.learn.jersey;

import java.net.URI;

import javax.ws.rs.Consumes;
import javax.ws.rs.DefaultValue;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.HttpHeaders;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Request;
import javax.ws.rs.core.UriBuilder;
import javax.ws.rs.core.UriInfo;

import org.glassfish.grizzly.http.server.HttpServer;

import com.sun.jersey.api.container.grizzly2.GrizzlyServerFactory;
import com.sun.jersey.api.core.PackagesResourceConfig;
import com.sun.jersey.api.core.ResourceConfig;
import com.sun.jersey.spi.resource.Singleton;

@Singleton             //@Singleton表示单例模式，@PerRequest每个请求对应一个实例，默认为@PerRequest
@Path("helloWorld")    //服务名称，紧接port/
public class MyJerseyServer 
{
    @Path("{sub_path:[a-zA-Z]*}")       //服务子路径，可以使用正则表达式，表示响应子路径为任意字母的请求
    @GET                                //表示接受HTTP GET请求，@POST、@PUT和@DELETE同理
    @Consumes({MediaType.TEXT_PLAIN, MediaType.APPLICATION_JSON})         //接受请求的媒体类型（MIME），不指定则可以接受任务媒体类型
    @Produces(MediaType.TEXT_PLAIN)                                       //定义响应媒体类型（MIME），不指定则可以接受任务媒体类型
    public String sayHelloWorld(
            // 使用路径定义中的sub_path变量
            @PathParam("sub_path") String service,
            
            // @QueryParam表示接受请求中的参数，@DefaultValue为默认值
            @DefaultValue("coshaho") @QueryParam("name") String name,
            
            // @Context可以获取请求上下文，包括Application，UriInfo，Request，HttpHeaders，SecurityContext
            @Context Request request,
            @Context UriInfo uriInfo,
            @Context HttpHeaders httpHeader
            )
    {
        System.out.println("Sub path is " + service + ".");
        System.out.println("Name is " + name + ".");
        System.out.println("Request method is " + request.getMethod() + ", url is " + uriInfo.getRequestUri().toString() + ".");
        return "Hello, " + name + ". Service is " + service + ".";
    }
    
    public static void main(String[] args) 
    {
        URI uri = UriBuilder.fromUri("http://127.0.0.1").port(10000).build();
        ResourceConfig rc = new PackagesResourceConfig("com.coshaho.learn.jersey");
        try 
        {
            HttpServer server = GrizzlyServerFactory.createHttpServer(uri, rc);
            server.start();
        } 
        catch (Exception e) 
        {
            e.printStackTrace();
        }
        
        try 
        {
            Thread.sleep(1000*1000);
        } 
        catch (InterruptedException e) 
        {
            e.printStackTrace();
        }
    }

}

 

package com.coshaho.learn.jersey;

import java.util.Iterator;

import javax.ws.rs.core.MultivaluedMap;

import com.sun.jersey.api.client.Client;
import com.sun.jersey.api.client.ClientResponse;
import com.sun.jersey.api.client.WebResource;
import com.sun.jersey.api.client.config.ClientConfig;
import com.sun.jersey.api.client.config.DefaultClientConfig;

public class MyJerseyClient 
{
    public static void main(String[] args) 
    {
        // 创建Jersey Client实例,Client实例很消耗系统资源，需要重用
        ClientConfig cc = new DefaultClientConfig();
        cc.getProperties().put(ClientConfig.PROPERTY_CONNECT_TIMEOUT, 10*1000);
        Client client = Client.create(cc);
        
        // 创建web资源,是线程安全的，Client实例和WebResource实例可以在多个线程间安全的共享
        WebResource resource = client.resource("http://127.0.0.1:10000/helloWorld/sayHi?name=cauchy");
        
        /**
         * 另一种请求方法
        URI uri = UriBuilder.fromUri("http://127.0.0.1/helloWorld/sayHello").port(10000)
                .queryParam("name", "coshaho").build();
        resource = client.resource(uri);
        */
        
        ClientResponse response = resource.get(ClientResponse.class);
         //        将HTTP响应打印出来
        StringBuilder strBuilder = new StringBuilder();
        strBuilder.append("HTTP/1.1 ");
        strBuilder.append(response.getStatus() + " ");
        strBuilder.append(response.getStatusInfo());
        System.out.println(strBuilder.toString());
        System.out.println();
        
        MultivaluedMap<String, String> headers = response.getHeaders();
        Iterator<String> iterator = headers.keySet().iterator();
        while(iterator.hasNext())
        {
            String headName = iterator.next();
            System.out.println(headName + ":" + headers.get(headName));
        }
        System.out.println();
        
        System.out.println(response.getEntity(String.class));
    }

}