import com.github.fge.jsonpatch.JsonPatchException; //导入依赖的package包/类
@PatchMapping("/{id}")
public ResponseEntity patchUser(@PathVariable Long id, @RequestBody JsonPatch jsonPatch) {
  return this.userService
      .getUserByID(id)
      .map(existing -> {
        try {
          JsonNode patched = jsonPatch.apply(objectMapper.convertValue(existing, JsonNode.class));

          UserDTO patchedUser = objectMapper.treeToValue(patched, UserDTO.class);
          // TODO add patched operations
          return ResponseEntity.ok(this.userService.update(patchedUser));
        } catch (JsonPatchException | JsonProcessingException e) {
          return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(e.getMessage());
        }
      })
      .orElse(ResponseEntity.notFound().build());
}
 

import com.github.fge.jsonpatch.JsonPatchException; //导入依赖的package包/类
@Override
public JsonNode transform(JsonNode patched) throws IOException {
    Iterator<Map.Entry<String, JsonNode>> nodeIterator = patched.get("message").fields();
    while (nodeIterator.hasNext()) {
        Map.Entry<String, JsonNode> entry = nodeIterator.next();

        if (!KNOWN_KEYS.contains(entry.getKey())) {
            String json = format(MOVE_OP, entry.getKey());
            try {
                patched = JsonPatch.fromJson(JacksonUtils.getReader().readTree(json)).apply(patched);
            } catch (JsonPatchException e) {
                throw new RuntimeException("move operation could not be applied", e);
            }
        }
    }

    return patched;
}
 

import com.github.fge.jsonpatch.JsonPatchException; //导入依赖的package包/类
@Override
public Object aroundReadFrom(ReaderInterceptorContext context) throws IOException {
    Optional<Object> optionalBean = getCurrentObject();

    if (optionalBean.isPresent()) {
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

        // Currently assume the bean is of type BuiltResponse, this may need to change in the future
        Object bean = ((BuiltResponse) optionalBean.get()).getEntity();

        MessageBodyWriter<? super Object> bodyWriter = providers.getMessageBodyWriter(Object.class, bean.getClass(), new Annotation[0], MediaType.APPLICATION_JSON_TYPE);
        bodyWriter.writeTo(bean, bean.getClass(), bean.getClass(), new Annotation[0], MediaType.APPLICATION_JSON_TYPE, new MultivaluedHashMap<>(), outputStream);

        // Use the Jackson 2.x classes to convert both the incoming patch and the current state of the object into a JsonNode / JsonPatch
        ObjectMapper mapper = new ObjectMapper();
        JsonNode serverState = mapper.readValue(outputStream.toByteArray(), JsonNode.class);
        JsonNode patchAsNode = mapper.readValue(context.getInputStream(), JsonNode.class);
        JsonPatch patch = JsonPatch.fromJson(patchAsNode);

        try {
            JsonNode result = patch.apply(serverState);
            // Stream the result & modify the stream on the readerInterceptor
            ByteArrayOutputStream resultAsByteArray = new ByteArrayOutputStream();
            mapper.writeValue(resultAsByteArray, result);
            context.setInputStream(new ByteArrayInputStream(resultAsByteArray.toByteArray()));

            return context.proceed();

        } catch (JsonPatchException | JsonMappingException e) {
            throw new WebApplicationException(e.getMessage(), e, Response.status(Response.Status.BAD_REQUEST).build());
        }

    } else {
        throw new IllegalArgumentException("No matching GET method on resource");
    }
}
 

import com.github.fge.jsonpatch.JsonPatchException; //导入依赖的package包/类
/**
 * SSE incoming message handler
 * @param event type of message
 * @param message message JSON content
 * @throws IOException if JSON syntax is not valid
 */
@Override
public void onMessage(String event, MessageEvent message) throws IOException {
    if ("data".equals(event)) {
        // SSE message is a snapshot
        data = mapper.readTree(message.data);

        // Refresh UI
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                listAdapter.getData().removeAll();
                listAdapter.getData().addAll((ArrayNode) data);
                listAdapter.notifyDataSetChanged();
            }
        });

    } else if ("patch".equals(event)) {
        // SSE message is a patch
        try {
            JsonNode patchNode = mapper.readTree(message.data);
            JsonPatch patch = JsonPatch.fromJson(patchNode);
            data = patch.apply(data);

            // Refresh UI
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    listAdapter.getData().removeAll();
                    listAdapter.getData().addAll((ArrayNode) data);
                    listAdapter.notifyDataSetChanged();
                }
            });
        } catch (JsonPatchException e) {
            e.printStackTrace();
        }
    } else {
        throw new RuntimeException("Unexpected SSE message: " + event);
    }
}
 

import com.github.fge.jsonpatch.JsonPatchException; //导入依赖的package包/类
/**
 * SSE incoming message handler
 *
 * @param event   type of message
 * @param message message JSON content
 * @throws IOException if JSON syntax is not valid
 */
@Override
public void onMessage(String event, MessageEvent message) throws IOException {

    if ("data".equals(event)) {
        // SSE message is a snapshot
        ownData = mapper.readTree(message.data);

        // Update commits array
        updateCommits();

    } else if ("patch".equals(event)) {
        // SSE message is a patch
        try {
            JsonNode patchNode = mapper.readTree(message.data);
            JsonPatch patch = JsonPatch.fromJson(patchNode);
            ownData = patch.apply(ownData);

            // Get the concerned repository name
            String commitMessage = ownData.get(0).path("commit").path("message").textValue();

            // Spawning an Android notification
            createNotification("New Commit: " + repoName.substring(repoName.indexOf("/") + 1), commitMessage);

            // Update commits array
            updateCommits();
        } catch (JsonPatchException e) {
            e.printStackTrace();
        }
    } else {
        Log.d("Debug", "Disconnecting : " + message.toString());

        if (message.data.contains("HTTP/1.1 401 Unauthorized")) {
            // GitHub api token may be out-of-date --> restart oauth procedure
            SharedPreferences settings = getSharedPreferences("SharedPreferences", Context.MODE_PRIVATE);
            settings.edit().clear().commit();
            startLoginActivity();
        }
        throw new RuntimeException("Wrong SSE message!");
    }
}