io.jpom.controller.openapi

Class NodeInfoController

java.lang.Object

cn.jiangzeyin.common.interceptor.BaseCallbackController

cn.jiangzeyin.controller.base.AbstractController

io.jpom.controller.openapi.NodeInfoController

@RestController
public class NodeInfoController
extends cn.jiangzeyin.controller.base.AbstractController

节点管理

Since:

2019/8/5

Author:

bwcx_jzy

Constructor Summary

Constructors

Constructor and Description
NodeInfoController(NodeService nodeService, WorkspaceService workspaceService)

Method Summary

Modifier and Type	Method and Description
static com.alibaba.fastjson.JSONObject	getReceiveCache(String id)
static Collection<com.alibaba.fastjson.JSONObject>	listReceiveCache(String removeId) 查询所有缓存
String	receivePush(String token, String ips, String loginName, String loginPwd, String workspaceId, int port, String ping) 接收节点推送的信息
String	update() 添加或者更新节点信息

Methods inherited from class cn.jiangzeyin.controller.base.AbstractController

clearResources, createMultipart, getCookieValue, getHeader, getHeaders, getIp, getMultiRequest, getObject, getParameter, getParameter, getParameterInt, getParameterInt, getParameterLong, getParameterLong, getParameters, getParametersMap, getRefererParameter, getUnescapeParameter, getUnescapeParameter, getUnescapeParameters, getXssParameter, getXssParameter, getXssParameters, hasFile, resetInfo

Methods inherited from class cn.jiangzeyin.common.interceptor.BaseCallbackController

getApplication, getAttribute, getClientIP, getHeaderMapValues, getRequest, getRequestAttributes, getResponse, getSession, getSessionAttribute, getSessionAttributeObj, removeSessionAttribute, setAttribute, setSessionAttribute, tryGetRequestAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NodeInfoController

public NodeInfoController(NodeService nodeService,
                          WorkspaceService workspaceService)

Method Detail

update

@RequestMapping(value="/api/node/update",
                method=POST,
                produces="application/json")
public String update()

添加或者更新节点信息

Returns:

json

receivePush

@RequestMapping(value="/api/node/receive_push",
                method=GET,
                produces="application/json")
 @NotLogin
public String receivePush(@ValidatorItem(msg="token empty")
                                                                                                                                                              String token,
                                                                                                                                                              @ValidatorItem(msg="ips empty")
                                                                                                                                                              String ips,
                                                                                                                                                              @ValidatorItem(msg="loginName empty")
                                                                                                                                                              String loginName,
                                                                                                                                                              @ValidatorItem(msg="loginPwd empty")
                                                                                                                                                              String loginPwd,
                                                                                                                                                              @ValidatorItem(msg="workspaceId empty")
                                                                                                                                                              String workspaceId,
                                                                                                                                                              @ValidatorItem(value=NUMBERS,msg="port error")
                                                                                                                                                              int port,
                                                                                                                                                              String ping)

接收节点推送的信息

yum install -y wget && wget -O install.sh https://jpom.top/docs/install.sh && bash install.sh Agent jdk --auto-push-to-server http://127.0.0.1:3000/api/node/receive_push?token=462a47b8fba8da1f824370bb9fcdc01aa1a0fe20&workspaceId=DEFAULT

Returns:

json

listReceiveCache

public static Collection<com.alibaba.fastjson.JSONObject> listReceiveCache(String removeId)

查询所有缓存

Returns:

list

getReceiveCache

public static com.alibaba.fastjson.JSONObject getReceiveCache(String id)