JAX-WSとJAX-RS

JAX-RS

Java API for RESTful Web Service

サンプル１

確認URL：http://localhost:8080/mavenTest/service/customer/all

import javax.ws.rs.DELETE;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.PUT;

import javax.ws.rs.Path;

import javax.ws.rs.PathParam;

import javax.ws.rs.Produces;

import javax.ws.rs.core.MediaType;

@Path("/customer")

@Produces({MediaType.APPLICATION_JSON}) // MediaType.APPLICATION_XML

public interface CustomerService {

@GET

@Path("/get/{id}")

Customer getCustomer(@PathParam("id") String id);

@GET

@Path("/all")

Customers getCustomers();

@POST

@Path("/create")

@Consumes(MediaType.APPLICATION_JSON)

Customer createCustomer(Customer customer);

@PUT

@Path("/update")

@Consumes(MediaType.APPLICATION_JSON)

void updateCustomer(Customer customer);

@DELETE

@Path("/delete/{id}")

void removeCustomer(@PathParam("id") String id);

@GET

@Path("/count")

int count(@QueryParam("field") String field);

}

public class CustomerServiceImpl implements CustomerService {

@Override

public Customer getCustomer(String id) {

// do something

}

@Override

public Customers getCustomers() {

// do something

}

@Override

public Customer createCustomer(Customer customer) {

// do something

}

@Override

public void updateCustomer(Customer customer) {

// do something

}

@Override

public void removeCustomer(String id) {

// do something

}

}

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement(name="customer")

public class Customer {

private String id;

private String name;

// getterとsetter

public Customer() {}

public Customer(String id, String name) {

this.id = id;

this.name = name;

}

}

import java.util.List;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement(name="customers")

public class Customers {

private List<Customer> customer;

// getterとsetter

public Customers() {}

public Customers(List<Customer> customer) {

this.customer = customer;

}

}

サンプル２

import org.json.JSONArray;

import java.util.Locale;

import javax.xml.bind.JAXBElement;

import java.net.URI;

import javax.ws.rs.core.Context;

import javax.servlet.ServletConfig;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.ws.rs.core.UriInfo;

import javax.ws.rs.core.Response;

import javax.ws.rs.core.MediaType;

import javax.ws.rs.WebApplicationException;

@Path("/books")

@Stateless

@Produces(MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON)

@Consumes(MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON)

public class BookResource {

@Context

private ServletConfig config;

@Context

private ServletContext context;

@Context

private HttpServletRequest request;

@Context

private HttpServletResponse response;

@Context

private UriInfo uriInfo;

@EJB

private BookEJB bookEJB;

@PersistenceContext(unitName = "testU")

private EntityManager em;

@GET

public List<Book> getAllBooks() {

Query query = em.createNamedQuery("findAllBooks");

return query.getResultList();

}

@GET

@Produces(MediaType.APPLICATION_JSON)

public JSONArray getAllBooks() {

JSONArray array = mew JSONArray();

for (Book book : bookEJB.findAll()) {

UriBuilder ub = uriInfo.getAbsolutePathBuilder();

URI uri = ub.path(book.getId().toString()).build();

array.put(uri.toASCIIString());

}

// http://www.example.com/app/books?author=andy

URI uri = UriBuilder.fromUri("http://www.example.com/")

.path("{a}/{b}")

.queryParam("author", "{value}")

.build("app", "books", "andy");

return array;

}

@GET

@Produces(MediaType.TEXT_PLAIN)

public String getHeader(@Context HttpHeaders headers) {

List<Locale> locales = headers.getAcceptableLanguages();

List<Locale> locales = headers.getRequestHeader("accept-language");

List<Locale> locales =

headers.getRequestHeader(HttpHeaders.ACCEPT_LANGUAGE);

}

@GET

@Path("/users/{id}")

@Produces(MediaType.APPLICATION_JSON)

public Response getUserById(@PathParam("id") int id) {

User user = new User();

user.setId(id);

...

return Response.status(200).entity(user).build();

}

@POST

public Response createNewBook(JAXBElement<Book> bookJaxb) {

Book book = bookJaxb.getValue();

em.persist(book);

URI uri = uriInfo.getAbsolutePathBuilder()

.path(book.getId().toString()).build();

return Response.created(uri).build();

}

@POST

@Consumes(MediaType.APPLICATION_XML)

public Response createNewBook(InputStream is) {

...

}

@PUT

@Path("{bookid}")

@Consumes(MediaType.APPLICATION_XML)

public Response updateBook(

@PathParam("bookid") String bookId, InputStream is) {

...

}

@POST

@Path("/product")

@Consumes(MediaType.APPLICATION_JSON)

public Response createProduct(Product product) {

String result = product.toString();

return Response.status(201).entity(result).build();

}

@DELETE

@Path("{bookid}")

public void deleteBook(@PathParam("bookid") String bookId) {

Book book = em.find(Book.class, bookId);

em.remove(book);

}

// http://localhost:8080/project/app/books/2345

@GET

@Path("{bookid}")

public Book getBook(@PathParam("bookid") String bookId) {

if (bookId < 1) {

throw new WebApplicationException(

Response.status(400).entity("custom message").build());

}

Book book = em.find(Book.class, bookId);

if (book == null) {

throw new WebApplicationException(Response.Status.NOT_FOUND);

}

return book;

}

// http://localhost:8080/javaee6x/app/books?bookid=2345

@GET

@Consumes("application/x-www-form-urlencoded")

@Produces("text/plain")

public Book getBook(

@DefaultValue("1001") @QueryParam("bookid") String bookId) {

...

}

@GET

public Book getBook(@CookieParam("sessionid") int sessionId) {

...

}

}

@Entity

@XmlRootElement

@NamedQuery(name="findAllBooks", query="SELECT b FROM book b")

public class Book implements Serializable {

@Id

@GeneratedValue

private Long id;

@Column(nullable=false)

private String title;

@Column(length=1000)

private String description;

// コンストラクタ、getter、setter

}

★ExceptionMapperについて

@Provider

public class OptimisticLockExceptionMapper implements ExceptionMapper<OptimisticLockException> {

@Override

public Response toResponse(OptimisticLockException exception) {

return Response.status(400).entity("Failure").type("text/plain").build();

}

}

上記のOptimisticLockExceptionMapperを再利用

@Provider

public class RollbackExceptionMapper implements ExceptionMapper<RollbackException> {

@Context

private Providers p;

@Override

public Response toResponse(RollbackException exception) {

Throwable cause = exception.getCause();

Class<Throwable> type = (Class<Throwable>) cause.getClass();

return p.getExceptionMapper(type).toResponse(cause);

}

}