Jersey JSON 响应作为 HttpUrlConnector 而不是 JSON

Question

我正在尝试创建一个小型 REST 服务，以 Jersey 2.13 作为服务器，Vaadin 7.3.3 作为“客户端”，但想法是请求可以来自任何地方（不仅仅是 Vaadin，这就是为什么我不这样做）在请求时使用 bean）。假设用户已经注册，请求只是检查他是否存在，然后返回令牌。我有一个 POST URL，

https://localhost:8443/logins

，它接收

{ 
    "login-request": 
    { 
        "username":<insert username>,
        "password":<insert password> 
    }
}

并返回：

{ 
    "login-token": 
    { 
        "token":<insert token>
    }
}

我的客户请求代码是：

Client client = ClientBuilder.newClient();

    WebTarget target = client.target("https://127.0.0.1:8443/").path(appName + "/logins");

    //build JSON Object
    HashMap<String, String> userMap = new HashMap<>();
    userMap.put("username", user.getUsername());
    userMap.put("password", user.getPassword());

    //JSON logins request!
    JSONObject jsonLoginRequest = new JSONObject();
    try {
        jsonLoginRequest.put("login-request", userMap);
    } catch (JSONException e) {
        e.printStackTrace();
    }

    return target.request(MediaType.APPLICATION_JSON_TYPE).post(Entity.json(jsonLoginRequest.toString()));

服务器处理代码为：

    @POST
@Path("logins")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public Response generateToken(@Context HttpServletRequest request) {

    if (request != null) {
        User user;

        DBHandshaker handshaker = DBHandshaker.getInstance();
        user = handshaker.logUser(request.getParameter("username"), request.getParameter("password"));

        if (user != null) {
            StringUtil stringUtil = StringUtil.getInstance();
            String tokenString = stringUtil.encryptForToken(user.getUsername(), user.getPassword());

            HashMap<String, String> tokenMap = new HashMap<>();
            tokenMap.put("token", tokenString);

            JSONObject jsonLoginResponse = new JSONObject();
            try {
                jsonLoginResponse.put("login-token", tokenMap);
            } catch (JSONException e) {
                e.printStackTrace();
            }

            return Response.ok(jsonLoginResponse.toString(), MediaType.APPLICATION_JSON).build();

        } else {
            return Response.status(Response.Status.UNAUTHORIZED).build();
        }

    } else {
        return Response.status(Response.Status.NO_CONTENT).build();
    }

}

我的客户回应“捕手”是：

            LoginParser loginParser = new LoginParser();
        Response response = loginParser.parseRequest(username, password);

        boolean isValidLogin = Response.Status.OK.getStatusCode() == response.getStatusInfo().getStatusCode();

        if (isValidLogin) {

            // Store the current username in the service session
            getSession().setAttribute("user", username);

            HttpEntity entity = (HttpEntity) response.getEntity();
            try {
                String retSRc = EntityUtils.toString(entity);
                JSONObject jsonObject = new JSONObject(retSRc);

                System.out.println(jsonObject);

            } catch (IOException | JSONException e) {
                e.printStackTrace();
            }

            // Navigate to main view
            getUI().getNavigator().navigateTo(LoginMainView.NAME);//

        }

我在

response.getEntity()

上遇到问题，因为它既不是 JSON 也不是 HttpEntity，而是

org.glassfish.jersey.client.HttpUrlConnector

。我的错误在哪里？

Answer 1

不要使用

response.getEntity()

，而使用

response.readEntity(String.class)

或

response.readEntity(HttpEntity.class)

。

Answer 2

客户端处理代码

package net.test;

import java.util.HashMap;

import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject;

import com.sun.jersey.api.client.Client;
import com.sun.jersey.api.client.ClientResponse;
import com.sun.jersey.api.client.WebResource;

public class Consumer {
    public static void main(String[] args) {
        Client client = Client.create();
        ClientResponse clientResponse = null;

        User u = new User();
        u.setUsername("hello");
        u.setPassword("hello");
        WebResource webResource = client
            .resource("http://localhost:8080/"+appName"+/logins");
        HashMap<String, String> userMap = new HashMap<String, String>();
        userMap.put("username", u.getUsername());
        userMap.put("password", u.getPassword());
        // JSON logins request!
        JSONObject jsonLoginRequest = new JSONObject();
        try {
            jsonLoginRequest.put("login-request", userMap);
            System.out.println(jsonLoginRequest.get("login-request"));
            System.out.println(jsonLoginRequest.getJSONObject("login-request")
                .get("username"));
        } catch (JSONException e) {
            e.printStackTrace();
        }
       // POST Operation
       clientResponse = webResource.post(ClientResponse.class,
            jsonLoginRequest);
       System.out.println(jsonLoginRequest);
    // Send the return value in object
       String result = clientResponse.getEntity(String.class);
       System.out.println(result);
 }
}

服务器处理代码

package net.test;
//Server Processing code
import java.util.HashMap;
import java.util.Random;

import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject;

@Path("/")
public class Producer {
   @POST
   @Path("logins")
   @Consumes(MediaType.APPLICATION_JSON)
   @Produces(MediaType.APPLICATION_JSON)
   public Response generateToken(String objInputData) {

    JSONObject jsonObject = null;
    User user = null;
    String username = null;
    String password = null;
    try {
        jsonObject = new JSONObject(objInputData);
        user = new User();
        username = jsonObject.getJSONObject("login-request")
                .get("username").toString();
        password = jsonObject.getJSONObject("login-request")
                .get("password").toString();
        // Your business logic goes here
        // DBHandshaker handshaker = DBHandshaker.getInstance();
        // user = handshaker.logUser(username, password);
        System.out.println(username+password);
        if (user != null) {
            // write your logic to generate token
            // StringUtil stringUtil = StringUtil.getInstance();
            // String tokenString =
            // stringUtil.encryptForToken(user.getUsername(),
            // user.getPassword());
            // dummy string to test
            String tokenString = "Helllllllllgjdkg";

            HashMap<String, String> tokenMap = new HashMap<String, String>();
            tokenMap.put("token", tokenString);

            JSONObject jsonLoginResponse = new JSONObject();
            try {
                jsonLoginResponse.put("login-token", tokenMap);
            } catch (JSONException e) {
                e.printStackTrace();
            }

            return Response.ok(jsonLoginResponse.toString(),
                    MediaType.APPLICATION_JSON).build();

        } else {
            return Response.status(Response.Status.UNAUTHORIZED).build();
        }
    } catch (Exception e1) {
        return Response.status(Response.Status.NO_CONTENT).build();
    }
}
}

收到响应后编写捕手逻辑

希望这个答案对你有帮助