- 浏览: 1121559 次
- 性别:
- 来自: 上海
文章分类
- 全部博客 (1055)
- quartz定时任务 (1)
- json (9)
- 接口 (1)
- http (1)
- sccket (2)
- xmlbean (1)
- webservice (1)
- flex (1)
- sitemesh (2)
- json组装 (2)
- 存储过程 (6)
- ajax后台返回前台上下问 (3)
- flect反射机制 (1)
- 页面列表 (1)
- oracal结果集合并 (1)
- lucene (1)
- 读取配置文件工具 (1)
- 框架整合 (1)
- jms (3)
- 断点续传 (1)
- 页面之间的传值 (1)
- jpa (6)
- sql (8)
- jsp跳转 (1)
- jsp (6)
- jquery (2)
- ui (1)
- js与jsp之间的值的交互应用 (1)
- js空值判断 (1)
- Ajax (9)
- web-inf 编译目录 (1)
- 多线程 (9)
- 资料 (0)
- oracal (4)
- 多线程webservice (1)
- ztree (1)
- 加载与内容的变化 (1)
- 页面的公用变量 (1)
- web-inf目录结构 (1)
- 登陆系列 (1)
- jass应用于webservice认证 (2)
- 路径问题 (1)
- list合并 (1)
- list map中的value获取 (2)
- 标签tag (4)
- 方法 (1)
- 树形数据及其渲染 (1)
- require js 回调 (1)
- tab 页面切换 (2)
- 计时获取验证码 (1)
- 模式 (6)
- easyui (3)
- dialog (2)
- 乱码问题 (1)
- spring (29)
- sqlserver (1)
- iis,netframework (0)
- iis (1)
- netframework (1)
- 处理乱码问题 (1)
- struts-ajax (0)
- ,理论,了;,; (0)
- 排错方法 (1)
- hibernate (1)
- 二级缓存 (1)
- portal (1)
- date类型 (0)
- jvm out of memery StackOverflowError (1)
- echart数据填充 (0)
- echart (1)
- jmv (1)
- 学习 (0)
- java基础 (1)
- oracle性能优化 (1)
- 数据库三范式 (1)
- easy UI (1)
- oracle11g (1)
- form (3)
- servlet (2)
- spring mvc (1)
- htm5 (0)
- ibatise (1)
- 序列化 (1)
- tomcat双认证 (1)
- maven Lib (1)
- tomcat eclipse (2)
- ehcache (1)
- http 代替 ajax (2)
- rest (6)
- script脚本占位模板 (1)
- strust 标签 el表达式 (1)
- js bo (1)
- 公司资料 (0)
- js return (1)
- spring 第三方插件的工具类 (1)
- linux (10)
- linux 克隆 (1)
- linux xshell连接 (1)
- yum expect (1)
- linux 应用命令 (1)
- yum 缓存rmp包 (1)
- yum 本地库离线安装 (2)
- yum错误 (1)
- jsp页面用定时调用 (1)
- ajax setup (2)
- Exception,RuntimeException (1)
- 对话框 dialog (1)
- maven (17)
- PropertyPlaceholderConfigurer properties文件 (1)
- 错误集 (1)
- mybatise (0)
- 拦截器filter (1)
- http get post 区别 (1)
- rest 客户端两种返回的数据处理方式 (1)
- listener (2)
- maven工程 (1)
- ContainerResponseFilter (1)
- ajax action 打印任意实体类jsp (1)
- yum svn mvn (1)
- 分页 (1)
- angularjs (1)
- memcached (1)
- git (12)
- yyyyyyyy (0)
- oracal安装 (4)
- jaxwswebservice (1)
- spring bean (1)
- 排方法 (0)
- java 生成pdf (2)
- 创建目录 (1)
- 下载与生产pdf文件 (1)
- base64 (2)
- 配置文件 (2)
- blob (1)
- pdf (1)
- yum linux 安装Oracle (1)
- excl 插入数据库 (1)
- 搭建框架 (1)
- .classpath和jdk jre (1)
- mybatise 配置文件通配 (1)
- 用Maven插件生成Mybatis代码 (2)
- springmvc值的传递 (1)
- js jsp html (1)
- ajax跨域 (1)
- javamail (0)
- 提交复杂格式json数据 (1)
- get中文乱码/post (1)
- 弹出框,承载弹出链接----页面,显示大图 (1)
- @RequestBody list bean (1)
- 隐藏域 (1)
- 多页保存 (1)
- form 校验 (1)
- 注册,上传图片 (1)
- 登录验证 (1)
- 全局的异常处理 (0)
- 异常捕获,显示在页面 (0)
- mybatise事物配置 (1)
- maven compile (1)
- 时间格式 (1)
- js 跳转页面 (1)
- pringsecurity 角色授资源要重启服务 (0)
- Retrofi restfull (1)
- session过期推出,直接点击退出,退出 (0)
- 参数放于requestbody (1)
- maven本地仓库jar包 (1)
- 编译环境出错jdk1.6 1,7 (1)
- jsonarray ---json数组格式 (1)
- java后台文件上传,接受的2种方式 (0)
- 生成保存图片 (1)
- 权限mysql数据库Md5加密sql (1)
- mysql一对多关联查询 (1)
- mysql批量更新 (0)
- oracle in exists 区别 (1)
- https (1)
- linux发布脚本 (1)
- dubbo zookeepr (1)
- request.getParameter() (1)
- request.setAttribute() (1)
- @RequestMapping @ResponseBody (1)
- @RequestMapping @responsebody src控件 后台如何写入src值 (1)
- dwz (8)
- lib jar maven (1)
- web服务访问名称 (1)
- mvc返回内容设置,拦截 (1)
- @ResponseBody 返回json处理 (1)
- 视图,函数,存储过程 (1)
- <context:annotation-config/> (1)
- <context:component-scan/> (1)
- xml路劲通配 (2)
- 杂项 (1)
- dubbo (34)
- redis (25)
- mybatis (34)
- springmvc (15)
- js (7)
- sprinvmvc (1)
- 设计理念 (1)
- 工程 (1)
- 其他 (149)
- 导出,下载 (1)
- session (4)
- token (1)
- Exception处理 (2)
- 注解 (2)
- 框架 (3)
- shrio (1)
- login (1)
- 项目结构设计 (1)
- mybatis两种关联查询 (1)
- mybaits (2)
- 迭代模式 (1)
- oralce树形数据结构构建 (2)
- 树形结构的jsp展现 (1)
- filter intecept(Struts) (1)
- 树形结构数据的提交 (1)
- @RequestBody @RequestParam (1)
- div (1)
- equals重写 (1)
- 程序设计 (1)
- f多层for循环跳出 (1)
- 看源码 (0)
- 权限系统普遍通性 (1)
- 设计程序 (1)
- 动态拼接元素样式问题 (1)
- sql迭代 (1)
- debug断点 (1)
- spring mvc 扫描注解(ioc (1)
- di) (1)
- jdk (2)
- cglib (1)
- mybatis 多层括号(超过三层)解析不了 (1)
- tiles (2)
- cacheManager缓存的切换 (1)
- jsp,xml中el表达式等占位符中的数据操作 (1)
- jpa 及spring data jpa开发 (1)
- compareTo equals toString (1)
- 子页面用父页面js (1)
- jsp相对路径自加问题 (1)
- bean之间的相互拷贝 (1)
- DECODE (2)
- 泛型 (2)
- NVL (1)
- jsp jstl函数 用标签声明页面变量,供jstl使用,时间格式问题 (1)
- form表单切换action值 (1)
- response.getWriter().write()功能优于springMvc的返回 (1)
- 快速复制构建项目 (1)
- activeMq (15)
- cache (2)
- sql获取序列号 (1)
- 上传 (2)
- tfs (1)
- jsp标签 (2)
- qita (1)
- 触发器 (1)
- Exception (1)
- mybais (1)
- 标签 (1)
- connect by (1)
- for ... in (1)
- map转化为list (1)
- 树形结构list构建(树形实体) (1)
- 左侧菜单的设计 (1)
- response.getWriter().write() (1)
- eclipse打断点之后断无效 (1)
- 直接访问/web-inf/下的页面 (1)
- clob (1)
- freemark (1)
- 框架的设计 (1)
- get方式处理乱码 (1)
- Request的getParameter和getAttribute方法的区别 (1)
- cas (9)
- 时间格式问题 (1)
- ResponseUtil.writeToResponse (1)
- 树形数据的反选 (1)
- spring data jpa (1)
- jsp异常提示 (1)
- jquery js (1)
- eclipse (1)
- 乱码 (1)
- Json OBJETC (1)
- PROCEDURE (1)
- pl/sql oracle (1)
- 设计 (1)
- el表达式 (3)
- iframe (1)
- map (1)
- jsp中调用Java (1)
- response.getWriter().write() ajax (1)
- mybatis xml 传入参数 (0)
- response与request在返回时作用区别 (1)
- spring cache (1)
- 模型驱动 (1)
- 关于mybatis传空值的处理 (1)
- 日志配置 (1)
- mapper (1)
- mapper mybatis (1)
- mapper mybatis-spring spring-data-jpa (1)
- js插件 (1)
- spring-data-jpa (2)
- 字节流转化过程 (1)
- 数据库 (11)
- jsp页面 (1)
- 局域网络访问问题 (1)
- plsql (2)
- response (1)
- plsq (1)
- Proxool (1)
- cas security (1)
- 系统配置化 (1)
- 集群 (4)
- springboot (24)
- 设计模式 (5)
- 通知 (1)
- 架构 (48)
- zookeeper (5)
- mvc框架 (1)
- 事物隔离策略 (1)
- jvm (8)
- 调研 (1)
- Java工具类 (1)
- 并发容器 (3)
- 多线程管理器 (4)
- 简历 (0)
- 查询 (1)
- 集群工具 (1)
- springMcv (1)
- ConcurrentHashMap (1)
- hashtable (1)
- cac (1)
- 树形结构 (1)
- 定时任务 (1)
- tortoiseGit (2)
- struts (11)
- shiro (31)
- log4j (3)
- struts2 (2)
- 编码 (1)
- request (3)
- Nginx (14)
- tomcat (1)
- idea (12)
- mvc (2)
- BeanUtils (2)
- image (1)
- mino (1)
- httpClient (1)
- volecity (1)
- swagger (3)
- 调错 (0)
- data (1)
- log (1)
- shell (1)
- 事物 (3)
- junit (1)
- RestTemplate (2)
- 线程 (0)
- Exception异常处理 (1)
- Exception异常注解 (1)
- lock (1)
- HashMap (1)
- 面试 (0)
- rabbitMq (1)
- rainCat (1)
- 其它 (1)
- activemq消息传送机制以及ACK机制详解 (0)
- mysql (7)
- fildder (1)
- UML (1)
- 校验 (1)
- 反射 (1)
- 切面 (1)
- springioc (1)
- urule2 (0)
- skywalking (1)
- urule (2)
- docker (2)
- 前端 (1)
- bootstrap (1)
- eureka (2)
- springcloud (16)
- jenkins (2)
- springsecurity (1)
- 数据结构 (4)
- gradle (1)
- mycat (3)
- nacos (1)
- canary (1)
- 线程池 (1)
- solr (1)
- resteasy (2)
- BI (1)
- dfs (2)
- elasticsearch (1)
- ruby (1)
- logstash (1)
- clickhouse (2)
- davinci (15)
- java (1)
- davinvi (1)
- fastdfs (1)
- vue (1)
- 《将博客搬至CSDN》 (1)
最新评论
-
nizhipeng123:
private SessionFactory sessio ...
用map接收参数的几个注意的问题
//有参数rest,调用客户端 OperateLogServiceImpl.java
public ResultModel<List<OperateLogVO>> getOperateLogList(OperateLogFilter filter, int page, int rows, String sortName, String sortType) {
String requestUrl = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/operlogs/";
final List<OperateLogVO> voList = new ArrayList<OperateLogVO>();
// HttpClientGetRequest request = new HttpClientGetRequest(requestUrl);
HttpRestClientRequest request = new HttpRestClientRequest(requestUrl);
request.addParam("pageSize", rows);
request.addParam("pageNum", page);
if (StringUtils.isNotBlank(filter.getOperateType())) {
request.addParam("operateType", filter.getOperateType());
}
if (!"-1".equals(filter.getSubsystem())) {
request.addParam("subsystem", filter.getSubsystem());
}
if (StringUtils.isNotBlank(filter.getEventId())) {
request.addParam("eventId", filter.getEventId());
}
if (StringUtils.isNotBlank(filter.getsDate())) {
request.addParam("startTime", filter.getsDate());
}
if (StringUtils.isNotBlank(filter.geteDate())) {
request.addParam("endTime", filter.geteDate());
}
if ("eventIdSort".equals(sortName)) {
sortName = "event_id";
} else if ("operateTypeSort".equals(sortName)) {
sortName = "operate_type";
} else if ("timestampSort".equals(sortName)) {
sortName = "create_time";
}
if (StringUtils.isNotBlank(sortName)) {
request.addParam("orderField", sortName);
request.addParam("orderType", sortType);
} else {
request.addParam("orderField", "create_time");
request.addParam("orderType", "1");
}
String response = request.postRequest();
JSONObject resObj = JSONObject.parseObject(response);// .fromObject(response);
JSONObject jsonObj = resObj.getJSONObject("result");
JSONArray jsArray = jsonObj.getJSONArray("operationLogList");
int totalSize = DataType.getAsInt(jsonObj.get("size"));
OperateLogVO vo;
JSONObject jso;
for (int i = 0; i < jsArray.size(); i++) {
jso = jsArray.getJSONObject(i);
vo = new OperateLogVO();
vo.setId("1");
vo.setUserId(jso.getString("userId"));
vo.setEventId(jso.getString("eventId"));
vo.setOperateType(jso.getString("operateType"));
vo.setRequestContent(jso.getString("requestContent"));
vo.setRequestStatus(jso.getString("responseStatus"));
vo.setSubsystem(jso.getString("subsystem"));
vo.setTimestamp(jso.getString("createTime"));
vo.setResponseContent(jso.getString("responseContent"));
voList.add(vo);
}
ResultModel<List<OperateLogVO>> result = null;
result = new ResultModel<List<OperateLogVO>>(voList);
result.setResult(Constants.RESULT_FLAG.SUCCESS.number());
result.setTotalSize(totalSize);
result.setCurrentPageNum(page);
result.setPageSize(rows);
result.setStartRowNo(CommonUtil.getStartRowNo(page, rows));
result.setTotalPageNum(totalSize % rows == 0 ? totalSize / rows : (totalSize / rows) + 1);
return result;
}
@POST
@Path("/operlogs")
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(ContentType.APPLICATION_JSON_UTF_8)
public OperationLogPageResult find(@QueryParam("userId") String userId,
////////////////////////////////直接将参数转化成变量
@QueryParam("eventId") String eventId,
@QueryParam("subsystem") String subsystem,
@QueryParam("operateType") String operateType,
@QueryParam("startTime") String startTime,
@QueryParam("endTime") String endTime,
@QueryParam("pageSize") String pageSize,
@QueryParam("pageNum") String pageNum,
@QueryParam("orderField") String orderField,
@QueryParam("orderType") String orderType) throws ManoException
{
try
{
OperLogQuery operlogQuery = new OperLogQuery();
operlogQuery.setStartTime(startTime);
operlogQuery.setEndTime(endTime);
operlogQuery.setEventId(eventId);
operlogQuery.setOperateType(operateType);
operlogQuery.setOrderField(orderField);
operlogQuery.setOrderType(orderType);
operlogQuery.setSubsystem(subsystem);
operlogQuery.setUserId(userId);
OperationLogPageResult result = new OperationLogPageResult();
int size = operationLogLS.countAll(operlogQuery);
result.setSize(size);
if(!StringUtils.isEmpty(pageSize))
{
int pageSizeInt = Integer.parseInt(pageSize);
operlogQuery.setStartNum((Integer.parseInt(pageNum) - 1) * pageSizeInt);
operlogQuery.setPageSize(pageSizeInt);
}
List<OperationLog> operationLogList = operationLogLS.selectPage(operlogQuery);
result.setOperationLogList(operationLogList);
return result;
}
catch (Exception ex)
{
LOG.error(ex.getMessage(), ex);
throw new ManoException(ex);
}
}
========================================================
//有参数二======================:
OperateLogServiceImpl.java
@Override
public String saveOperateLog(String operateType, String requestContent, String responstatus, String responseContent) {
String ret = "";
try {
logger.info("开始记录日志");
String url = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/logs/generation";
// url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
HttpRestClientRequest hr = new HttpRestClientRequest(url);
hr.addParam("Event-Id", UUID.randomUUID().toString());
hr.addParam("User-Id", formatStr(CommonUtil.getUserId()));
hr.addParam("Operate-Type", formatStr(operateType));
hr.addParam("Request-Content", formatStr(requestContent));
hr.addParam("Response-Status", formatStr(responstatus));
hr.addParam("Response-Content", formatStr(responseContent));
hr.addParam("Subsystem", "GUI");
ret = hr.postRequest();
} catch (Exception e) {
logger.info("记录日志失败" + ret);
e.printStackTrace();
}
return ret;
}
@Service("NsdService")
public class NsdServiceImpl implements INsdService {
private static void addOperateLog() {
String url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
HttpRestClientRequest hr = new HttpRestClientRequest(url);
OperationLogRest
///上文的带参数的接口调动,mybatise的应用
@POST
@Path("logs/generation")
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(ContentType.APPLICATION_JSON_UTF_8)
public long saveOperationLog(@Context HttpServletRequest request) throws ManoException
{
try
{
OperationLog operationLog = new OperationLog();
operationLog.setEventId(request.getParameter("Event-Id"));
operationLog.setOperateType(request.getParameter("Operate-Type"));
operationLog.setRequestContent(request.getParameter("Request-Content"));
operationLog.setSubsystem(request.getParameter("Subsystem"));
operationLog.setUserId(request.getParameter("User-Id"));
operationLog.setResponseContent(request.getParameter("Response-Content"));
operationLog.setResponseStatus(request.getParameter("Response-Status"));
operationLogLS.insertOne(operationLog);
return operationLog.getId();
}
catch (Exception ex)
{
LOG.error(ex.getMessage(), ex);
throw new ManoException(ex);
}
}
================================================
有参数调用三
//一个path一段 WebTarget webTarget = client.target(vimRestRootUrl).path(VDU_URL).path(vduUUID).path("detail");
@Override
public TenantNetwork queryTenantNetwork(String uuid) {
if(StringUtils.isEmpty(uuid))
{
return null;
}
Client client = getClient();
WebTarget webTarget = client.target(vimRestRootUrl)
.path("vlinks_internal/" + uuid + "/detail");
Invocation.Builder invocationBuilder = webTarget.request(ContentType.APPLICATION_JSON_UTF_8);
TenantNetworkQueryResp resp = invocationBuilder.get(TenantNetworkQueryResp.class);
if(!resp.getRetCode().equals("ok"))
{
if(RestResultCode.ITEM_NOT_FOUND.equals(resp.getRetCode()))
{
logger.error(resp.getRetCode() + ":" + resp.getMsg());
return null;
}
else
{
throw new ManoException(resp.getRetCode(), resp.getMsg());
}
}
return resp.getResult();
}
@GET
@Path("vlinks_internal/{vlink_uuid}/detail")//{vlink_uuid}
这个变量直接通过前方传过的地址位置对应接收
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(MediaType.TEXT_PLAIN)
//这里的这个之所以会设置成变量有path中决定生成
public Network findNetworkById(
@PathParam("vlink_uuid") String vlinkUUID(直接用),@HeaderParam("X-Auth-Token") String token) throws ManoException {
logger.info("findNetworkById-X-Auth-Token="+token);
logger.info("findNetworkById-vlinkUUID="+vlinkUUID);
if ((null == vlinkUUID) || (vlinkUUID.trim().equalsIgnoreCase(""))) {
throw new ManoException(ExceptionCode.PARAM_NEEDED_IS_NULL);
}
try {
return networkService.findNetworkById(vlinkUUID,token);
} catch (ManoException ex) {
throw ex;
} catch (Exception ex)
{
logger.error("findNetworkById-ex = " + ex);
throw new ManoException(ExceptionCode.FIND_VLINK_INTERNAL_FAILED, ex);
}
}
public ResultModel<List<OperateLogVO>> getOperateLogList(OperateLogFilter filter, int page, int rows, String sortName, String sortType) {
String requestUrl = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/operlogs/";
final List<OperateLogVO> voList = new ArrayList<OperateLogVO>();
// HttpClientGetRequest request = new HttpClientGetRequest(requestUrl);
HttpRestClientRequest request = new HttpRestClientRequest(requestUrl);
request.addParam("pageSize", rows);
request.addParam("pageNum", page);
if (StringUtils.isNotBlank(filter.getOperateType())) {
request.addParam("operateType", filter.getOperateType());
}
if (!"-1".equals(filter.getSubsystem())) {
request.addParam("subsystem", filter.getSubsystem());
}
if (StringUtils.isNotBlank(filter.getEventId())) {
request.addParam("eventId", filter.getEventId());
}
if (StringUtils.isNotBlank(filter.getsDate())) {
request.addParam("startTime", filter.getsDate());
}
if (StringUtils.isNotBlank(filter.geteDate())) {
request.addParam("endTime", filter.geteDate());
}
if ("eventIdSort".equals(sortName)) {
sortName = "event_id";
} else if ("operateTypeSort".equals(sortName)) {
sortName = "operate_type";
} else if ("timestampSort".equals(sortName)) {
sortName = "create_time";
}
if (StringUtils.isNotBlank(sortName)) {
request.addParam("orderField", sortName);
request.addParam("orderType", sortType);
} else {
request.addParam("orderField", "create_time");
request.addParam("orderType", "1");
}
String response = request.postRequest();
JSONObject resObj = JSONObject.parseObject(response);// .fromObject(response);
JSONObject jsonObj = resObj.getJSONObject("result");
JSONArray jsArray = jsonObj.getJSONArray("operationLogList");
int totalSize = DataType.getAsInt(jsonObj.get("size"));
OperateLogVO vo;
JSONObject jso;
for (int i = 0; i < jsArray.size(); i++) {
jso = jsArray.getJSONObject(i);
vo = new OperateLogVO();
vo.setId("1");
vo.setUserId(jso.getString("userId"));
vo.setEventId(jso.getString("eventId"));
vo.setOperateType(jso.getString("operateType"));
vo.setRequestContent(jso.getString("requestContent"));
vo.setRequestStatus(jso.getString("responseStatus"));
vo.setSubsystem(jso.getString("subsystem"));
vo.setTimestamp(jso.getString("createTime"));
vo.setResponseContent(jso.getString("responseContent"));
voList.add(vo);
}
ResultModel<List<OperateLogVO>> result = null;
result = new ResultModel<List<OperateLogVO>>(voList);
result.setResult(Constants.RESULT_FLAG.SUCCESS.number());
result.setTotalSize(totalSize);
result.setCurrentPageNum(page);
result.setPageSize(rows);
result.setStartRowNo(CommonUtil.getStartRowNo(page, rows));
result.setTotalPageNum(totalSize % rows == 0 ? totalSize / rows : (totalSize / rows) + 1);
return result;
}
@POST
@Path("/operlogs")
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(ContentType.APPLICATION_JSON_UTF_8)
public OperationLogPageResult find(@QueryParam("userId") String userId,
////////////////////////////////直接将参数转化成变量
@QueryParam("eventId") String eventId,
@QueryParam("subsystem") String subsystem,
@QueryParam("operateType") String operateType,
@QueryParam("startTime") String startTime,
@QueryParam("endTime") String endTime,
@QueryParam("pageSize") String pageSize,
@QueryParam("pageNum") String pageNum,
@QueryParam("orderField") String orderField,
@QueryParam("orderType") String orderType) throws ManoException
{
try
{
OperLogQuery operlogQuery = new OperLogQuery();
operlogQuery.setStartTime(startTime);
operlogQuery.setEndTime(endTime);
operlogQuery.setEventId(eventId);
operlogQuery.setOperateType(operateType);
operlogQuery.setOrderField(orderField);
operlogQuery.setOrderType(orderType);
operlogQuery.setSubsystem(subsystem);
operlogQuery.setUserId(userId);
OperationLogPageResult result = new OperationLogPageResult();
int size = operationLogLS.countAll(operlogQuery);
result.setSize(size);
if(!StringUtils.isEmpty(pageSize))
{
int pageSizeInt = Integer.parseInt(pageSize);
operlogQuery.setStartNum((Integer.parseInt(pageNum) - 1) * pageSizeInt);
operlogQuery.setPageSize(pageSizeInt);
}
List<OperationLog> operationLogList = operationLogLS.selectPage(operlogQuery);
result.setOperationLogList(operationLogList);
return result;
}
catch (Exception ex)
{
LOG.error(ex.getMessage(), ex);
throw new ManoException(ex);
}
}
========================================================
//有参数二======================:
OperateLogServiceImpl.java
@Override
public String saveOperateLog(String operateType, String requestContent, String responstatus, String responseContent) {
String ret = "";
try {
logger.info("开始记录日志");
String url = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/logs/generation";
// url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
HttpRestClientRequest hr = new HttpRestClientRequest(url);
hr.addParam("Event-Id", UUID.randomUUID().toString());
hr.addParam("User-Id", formatStr(CommonUtil.getUserId()));
hr.addParam("Operate-Type", formatStr(operateType));
hr.addParam("Request-Content", formatStr(requestContent));
hr.addParam("Response-Status", formatStr(responstatus));
hr.addParam("Response-Content", formatStr(responseContent));
hr.addParam("Subsystem", "GUI");
ret = hr.postRequest();
} catch (Exception e) {
logger.info("记录日志失败" + ret);
e.printStackTrace();
}
return ret;
}
@Service("NsdService")
public class NsdServiceImpl implements INsdService {
private static void addOperateLog() {
String url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
HttpRestClientRequest hr = new HttpRestClientRequest(url);
OperationLogRest
///上文的带参数的接口调动,mybatise的应用
@POST
@Path("logs/generation")
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(ContentType.APPLICATION_JSON_UTF_8)
public long saveOperationLog(@Context HttpServletRequest request) throws ManoException
{
try
{
OperationLog operationLog = new OperationLog();
operationLog.setEventId(request.getParameter("Event-Id"));
operationLog.setOperateType(request.getParameter("Operate-Type"));
operationLog.setRequestContent(request.getParameter("Request-Content"));
operationLog.setSubsystem(request.getParameter("Subsystem"));
operationLog.setUserId(request.getParameter("User-Id"));
operationLog.setResponseContent(request.getParameter("Response-Content"));
operationLog.setResponseStatus(request.getParameter("Response-Status"));
operationLogLS.insertOne(operationLog);
return operationLog.getId();
}
catch (Exception ex)
{
LOG.error(ex.getMessage(), ex);
throw new ManoException(ex);
}
}
================================================
有参数调用三
//一个path一段 WebTarget webTarget = client.target(vimRestRootUrl).path(VDU_URL).path(vduUUID).path("detail");
@Override
public TenantNetwork queryTenantNetwork(String uuid) {
if(StringUtils.isEmpty(uuid))
{
return null;
}
Client client = getClient();
WebTarget webTarget = client.target(vimRestRootUrl)
.path("vlinks_internal/" + uuid + "/detail");
Invocation.Builder invocationBuilder = webTarget.request(ContentType.APPLICATION_JSON_UTF_8);
TenantNetworkQueryResp resp = invocationBuilder.get(TenantNetworkQueryResp.class);
if(!resp.getRetCode().equals("ok"))
{
if(RestResultCode.ITEM_NOT_FOUND.equals(resp.getRetCode()))
{
logger.error(resp.getRetCode() + ":" + resp.getMsg());
return null;
}
else
{
throw new ManoException(resp.getRetCode(), resp.getMsg());
}
}
return resp.getResult();
}
@GET
@Path("vlinks_internal/{vlink_uuid}/detail")//{vlink_uuid}
这个变量直接通过前方传过的地址位置对应接收
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(MediaType.TEXT_PLAIN)
//这里的这个之所以会设置成变量有path中决定生成
public Network findNetworkById(
@PathParam("vlink_uuid") String vlinkUUID(直接用),@HeaderParam("X-Auth-Token") String token) throws ManoException {
logger.info("findNetworkById-X-Auth-Token="+token);
logger.info("findNetworkById-vlinkUUID="+vlinkUUID);
if ((null == vlinkUUID) || (vlinkUUID.trim().equalsIgnoreCase(""))) {
throw new ManoException(ExceptionCode.PARAM_NEEDED_IS_NULL);
}
try {
return networkService.findNetworkById(vlinkUUID,token);
} catch (ManoException ex) {
throw ex;
} catch (Exception ex)
{
logger.error("findNetworkById-ex = " + ex);
throw new ManoException(ExceptionCode.FIND_VLINK_INTERNAL_FAILED, ex);
}
}
- HttpRestClientRequest.zip (1.1 KB)
- 下载次数: 2
发表评论
-
rest路径形式相同的话,通过@GET @DELETE 区别
2015-05-18 14:17 1545通过位置对应接收参数,如果rest路径形式相同的话,通过@GE ... -
rest 应用demo 3 客户端的另一中方式
2015-04-30 14:53 932//rest接口访问地址特征 API_IP = http:// ... -
rest 应用demo 2
2015-04-30 14:48 1214web.xml <servlet> < ... -
rest 应用demo
2015-04-22 12:58 1274web.xml <servlet> < ... -
rest
2015-04-14 14:18 849http://blog.sina.com.cn/s/blog_ ...
相关推荐
#### 三、Java调用REST接口的方法 ##### 3.1 使用Apache HttpClient库 Apache HttpClient是一个用于Java开发者的高效、最新的HTTP客户端库,可以用来构建HTTP客户端应用,包括简单的GET请求以及复杂的POST请求。 ...
泛微9.0 REST接口调用是一个用于与泛微协同办公系统进行交互的重要技术,它允许开发者通过HTTP请求来执行各种操作,如注册、获取访问令牌、创建流程以及实现单点登录。下面是这些知识点的详细说明: 1. **注册接口*...
调用者根据REST接口的URL、HTTP方法和可能需要的参数,发送请求并接收响应。例如,使用Jersey的`Client`和`WebTarget`可以这样调用接口: ```java Client client = ClientBuilder.newClient(); WebTarget target = ...
动态参数调用HTTP、POST接口在各种场景下都有应用,如: - 实时数据同步:从API获取最新的数据。 - 事件触发的ETL:当某个事件发生时,通过POST发送数据到分析平台。 - 自动化报告:定期调用接口获取报告数据,然后...
#### 三、Java实现HTTP REST调用 本文提供的代码示例基于Apache HttpClient库实现,该库提供了丰富的API来处理HTTP请求和响应。 ##### 3.1 GET请求示例 ```java public static String getHttp(String url) { ...
然而,在技术支持过程中,仍然有很多用户需要在特定的场合下,通过调用Azure REST接口来实现某部分业务的需求。 二、Azure Storage Services REST API Reference Azure 官方文档中提供了Storage Services REST API...
在这个"java REST接口测试 测试小例子"中,我们将探讨如何在Java环境下进行REST接口的调用以及测试。 首先,`Test.java`文件很可能是包含测试代码的主类。在Java中,我们通常使用JUnit框架进行单元测试,不过这个...
这在需要多次调用同一接口获取大量分页数据时非常有用。 描述中提到的变量运用是Kettle中动态配置的重要组成部分。在处理HTTP分页接口时,我们可以设置全局变量来存储页码、每页大小等参数,然后在循环中动态更新...
保存token的方法有很多种,可以将其写入到Kettle的变量或参数中,也可以存储在一个单独的文件中。当需要进行API调用时,Kettle作业或转换可以从这些位置读取并使用该token。为了保持安全性,应当确保存储token的地方...
1. **API配置**:首先,你需要在致远OA的后台管理系统中配置REST接口,设定接口的URL、请求方法(POST、GET等)、参数类型等信息。这一步骤确保了外部系统可以通过这些接口与OA系统进行通信。 2. **构建请求参数**...
总之,调用WebService接口是Android开发中的重要环节,理解并熟练掌握SOAP和RESTful API的调用方法,以及相关的数据解析、错误处理、权限申请和性能优化,将有助于你构建高效、稳定的Android应用。随着技术的发展,...
在实际应用中,开发者应当仔细阅读接口文档,理解每个接口的功能和使用限制,以确保接口的正确调用,避免出现错误或冲突。 总之,NC65的RESTful接口为开发者提供了一种高效、标准的方式来访问和操作系统资源,...
H3C CAS的REST API设计简洁,易于理解和使用,使得开发者可以使用常见的编程语言如Python、Java、JavaScript等来调用这些接口,实现自动化管理任务。 在使用H3C CAS REST API时,首先需要了解API的基本结构和请求...
在上面的代码中,`url`参数指定了REST服务的地址,`type`参数设定了请求类型。`success`和`error`回调函数分别处理成功和失败的情况。 除了`$.ajax()`, jQuery还提供了更简单的`$.get()`和`$.post()`方法,它们是对...
2. **参数管理**:在请求构造器中,用户可以添加查询参数、路径参数、表单数据或JSON数据,方便测试接口的输入数据处理。 3. **集合**:Postman的集合功能允许将相关请求组织在一起,形成一个测试套件,便于管理和...
在ABAP中,你可以通过定义和实现特定的日志类来创建自定义的日志机制,这些类通常会记录接口调用的输入参数、返回值、异常以及执行时间等信息。 接下来,我们转向RESTful动态调用Function Module(FM)。REST...
本篇文章将详细介绍如何在Vue项目中调用RESTful风格的接口。 REST(Representational State Transfer)是一种软件架构风格,用于设计网络应用程序。它强调通过HTTP方法(GET、POST、PUT、DELETE)来对应不同的操作...
3. **调用服务方法**:通过生成的服务代理类实例,我们可以调用Axis2接口服务中的具体方法,传递参数并接收响应。 4. **处理结果**:收到服务响应后,根据业务需求进行数据解析和后续操作。 5. **异常处理**:添加...
### CAS Restful接口调用详解 #### 一、CAS简介 CAS(Central Authentication Service)是一种开源的单点登录协议和服务实现。它旨在减轻单一Web应用的登录流程,并为多个服务提供一个集中式的认证机制。CAS支持...