com.jeesuite.common.json.JsonUtils.toJson()方法的使用及代码示例
本文整理了Java中com.jeesuite.common.json.JsonUtils.toJson()方法的一些代码示例，展示了JsonUtils.toJson()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JsonUtils.toJson()方法的具体详情如下：
包路径：com.jeesuite.common.json.JsonUtils
类名称：JsonUtils
方法名：toJson
JsonUtils.toJson介绍
[英]不含值为null的属性
[中]不含值为无效的的属性
代码示例
代码示例来源：origin: vakinge/jeesuite-libs
@Override
public String toString() {
return JsonUtils.toJson(this);
}
}代码示例来源：origin: vakinge/jeesuite-passport
public String toJsonString(){
return JsonUtils.toJson(this);
}代码示例来源：origin: vakinge/jeesuite-libs
public String serialize() {
return JsonUtils.toJson(this);
}代码示例来源：origin: vakinge/oneplatform
public String toJsonString(){
return JsonUtils.toJson(this);
}代码示例来源：origin: vakinge/jeesuite-libs
public static void main(String[] args) {
List<Object> list = new ArrayList<>();
list.add(new Date());
System.out.println(toJson(list));
}
}代码示例来源：origin: vakinge/jeesuite-libs
public void processResponse(ContainerRequestContext requestContext, ContainerResponseContext responseContext,
ResourceInfo resourceInfo) {
Object responseData = responseContext.getEntity();
logger.info("response:\n",JsonUtils.toJson(responseData));
}代码示例来源：origin: vakinge/jeesuite-libs
public static void responseOutJsonp(HttpServletResponse response,String callbackFunName,Object jsonObject) {
//将实体对象转换为JSON Object转换
response.setCharacterEncoding("UTF-8");
response.setContentType("text/plain; charset=utf-8");
PrintWriter out = null;
String json = (jsonObject instanceof String) ? jsonObject.toString() : JsonUtils.toJson(jsonObject);
String content = callbackFunName + "("+json+")";
try {
out = response.getWriter();
out.append(content);
} catch (IOException e) {
e.printStackTrace();
} finally {
if (out != null) {
out.close();
}
}
}代码示例来源：origin: vakinge/jeesuite-libs
public String getCallbackRuleAsJson(){
if(StringUtils.isAnyBlank(callbackBody,callbackHost,callbackUrl))return null;
Map<String, String> map = new HashMap<>(4);
map.put("callbackBody", callbackBody);
map.put("callbackHost", callbackHost);
map.put("callbackUrl", callbackUrl);
map.put("callbackBodyType", getCallbackBodyType());
return JsonUtils.toJson(map);
}代码示例来源：origin: vakinge/jeesuite-libs
private void commitToZK(){
if(commited.get())return;
Set<Entry<String, AtomicLong[]>> entrySet = producerStats.entrySet();
for (Entry<String, AtomicLong[]> entry : entrySet) {
AtomicLong[] nums = entry.getValue();
ProducerStat stat = new ProducerStat(entry.getKey(), producerGroup, nums[0], nums[1], nums[2], nums[3]);
zkClient.writeData(statPaths.get(entry.getKey()), JsonUtils.toJson(stat));
}
commited.set(true);
}代码示例来源：origin: vakinge/oneplatform
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String act = req.getPathInfo().substring(1);
Map<String, String> map = new LinkedHashMap<>();
if(HEALTH.equals(act)){
map.put(STATUS, "UP");
}else if(INFO.equals(act)){
map.put("app", ResourceUtils.getProperty("jeesuite.configcenter.appName"));
}
map.put("startupTime", startupTime);
map.put("lastHeartbeatTime", DateUtils.format(lastHeartbeatTime));
lastHeartbeatTime = new Date();
WebUtils.responseOutJson(resp, JsonUtils.toJson(map));
}代码示例来源：origin: vakinge/jeesuite-libs
/**
* serialize
*
* @param topic topic associated with data
* @param data typed data
* @return serialized bytes
*/
@Override
public byte[] serialize(String topic, Serializable data) {
try {
if (data == null)
return null;
else{
String toString = isSimpleDataType(data) ? data.toString() : JsonUtils.toJson(data);
return toString.getBytes(StandardCharsets.UTF_8.name());
}
} catch (UnsupportedEncodingException e) {
throw new SerializationException("Error when serializing string to byte[] due to unsupported encoding UTF-8");
}
}代码示例来源：origin: vakinge/jeesuite-libs
@Override
public void updateJobConfig(JobConfig config) {
config.setModifyTime(Calendar.getInstance().getTimeInMillis());
zkClient.writeData(getPath(config), JsonUtils.toJson(config));
schedulerConfgs.put(config.getJobName(), config);
}代码示例来源：origin: vakinge/jeesuite-libs
public static void main(String[] args) throws IOException {
SchedulerMonitor monitor = new SchedulerMonitor("zookeeper", "127.0.0.1:2181");
List<JobGroupInfo> groups = monitor.getAllJobGroups();
System.out.println(JsonUtils.toJson(groups));
monitor.close();
}代码示例来源：origin: vakinge/jeesuite-libs
public static void main(String[] args) {
KafkaConsumerCommand command = new KafkaConsumerCommand("127.0.0.1:9092");
System.out.println(command.group());
List<ConsumerGroupInfo> list = command.getAllConsumerGroups();
System.out.println(JsonUtils.toJson(list));
command.close();
}
}代码示例来源：origin: vakinge/jeesuite-passport
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
//String header = req.getHeader(BaseConstants.HEADER_AUTH_USER);
String sessionId = AuthSessionHelper.getSessionId(req);
String act = req.getPathInfo().substring(1);
try {
if("status".equals(act)){
ResponseEntity<WrapperResponseEntity> entity = restTemplate.getForEntity(getStatusUrl+sessionId, WrapperResponseEntity.class);
WebUtils.responseOutJson(resp, JsonUtils.toJson(entity.getBody()));
}else if("info".equals(act)){
ParameterizedTypeReference<WrapperResponse<LoginUserInfo>> arearesponseType = new ParameterizedTypeReference<WrapperResponse<LoginUserInfo>>() {
};
WrapperResponse<LoginUserInfo> response = restTemplate.exchange(getInfoUrl+sessionId,HttpMethod.GET, null, arearesponseType).getBody();
WebUtils.responseOutJson(resp, JsonUtils.toJson(response.getData()));
}
} catch (JeesuiteBaseException e) {
WebUtils.responseOutJson(resp, JsonUtils.toJson(new WrapperResponseEntity(e.getCode(), e.getMessage())));
}
}代码示例来源：origin: vakinge/jeesuite-libs
@Override
public void setStoping(String jobName, Date nextFireTime,Exception e) {
updatingStatus = false;
try {
JobConfig config = getConf(jobName,false);
config.setRunning(false);
config.setNextFireTime(nextFireTime);
config.setModifyTime(Calendar.getInstance().getTimeInMillis());
config.setErrorMsg(e == null ? null : e.getMessage());
//更新本地
schedulerConfgs.put(jobName, config);
try {
if(zkAvailabled)zkClient.writeData(getPath(config), JsonUtils.toJson(config));
} catch (Exception ex) {
checkZkAvailabled();
logger.warn(String.format("Job[{}] setStoping error...", jobName),ex);
}
} finally {
updatingStatus = false;
}
}代码示例来源：origin: vakinge/jeesuite-passport
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain)
throws ServletException, IOException {
try {
checker.process(request,response);
filterChain.doFilter(request, response);
} catch (JeesuiteBaseException e) {
if(WebUtils.isAjax(request)){
WebUtils.responseOutJson(response, JsonUtils.toJson(new WrapperResponseEntity(e.getCode(), e.getMessage())));
}else{
String returnUrl = request.getRequestURL().toString();
String loginUrl = String.format(ClientConfig.authServerBasePath() + "/login?client_id=%s&return_url=%s",
ClientConfig.clientId(),returnUrl);
response.sendRedirect(loginUrl);
}
}
}代码示例来源：origin: vakinge/jeesuite-libs
private void retry(){
if(retryCount == maxReties){
if(retryErrorHandler != null){
try {
retryErrorHandler.process(ConsumerContext.getInstance().getGroupId(),message.topic(), message);
} catch (Exception e) {
logger.warn("persistHandler error,topic["+message.topic()+"]",e);
}
}else{
logger.warn("retry_skip process message[{}] maxReties over {} time error!!!",JsonUtils.toJson(message),maxReties);
}
return;
}
nextFireTime = nextFireTime + retryCount * retryPeriodUnit;
//重新放入任务队列
taskQueue.add(this);
logger.debug("retry_resubmit mssageId[{}] task to queue,next fireTime:{}",this.message.getMsgId(),nextFireTime);
}代码示例来源：origin: vakinge/jeesuite-libs
@Override
public void setRuning(String jobName, Date fireTime) {
updatingStatus = false;
try {
JobConfig config = getConf(jobName,false);
config.setRunning(true);
config.setLastFireTime(fireTime);
config.setModifyTime(Calendar.getInstance().getTimeInMillis());
config.setErrorMsg(null);
//更新本地
schedulerConfgs.put(jobName, config);
try {
if(zkAvailabled)zkClient.writeData(getPath(config), JsonUtils.toJson(config));
} catch (Exception e) {
checkZkAvailabled();
logger.warn(String.format("Job[{}] setRuning error...", jobName),e);
}
} finally {
updatingStatus = false;
}
}代码示例来源：origin: vakinge/jeesuite-passport
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain)
throws ServletException, IOException {
String sessionId = AuthSessionHelper.getSessionId(request);
LoginSession session = AuthSessionHelper.getLoginSession(sessionId);
if(session != null && !session.isAnonymous()){
LoginContext.setLoginSession(session);
}else{
if(request.getRequestURI().startsWith("/ucenter")){
if(WebUtils.isAjax(request)){
WebUtils.responseOutJson(response, JsonUtils.toJson(new WrapperResponseEntity(HttpStatus.UNAUTHORIZED.value(), HttpStatus.UNAUTHORIZED.name())));
}else{
String loginUrl = WebUtils.getBaseUrl(request) + "/login";
response.sendRedirect(loginUrl);
}
return;
}
}
filterChain.doFilter(request, response);
}内容来源于网络，如有侵权，请联系作者删除！
