java跨系统调用esb接口，json形式，rest接口分析
访客
阅读：522
2020-07-05 13:01:51
评论：0
package com.ekingwin.bas.cloud.mobileErp.utils;
import java.util.HashMap;
import java.util.Map;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
/**
* 向esb发送post请求工具类
* @author yang
*
*/
public class HttpRestUtil {
public static JSONObject  sendPost(Map map1,Map map2,String url) {
//设置头信息
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("Content-Type", "application/json;charset=UTF-8");
headers.set("Accept", "application/json");
//封装请求参数
Map map=new HashMap();
map.put("commonHeader", map1);
map.put("LIST", map2);
String mapJsonStr = JSON.toJSONString(map,true);
JSONObject mapJson =  JSONObject.parseObject((String) JSON.toJSON(mapJsonStr));
System.out.println("请求报文--------->>>>>>"+mapJson.toString());
//发送请求
HttpEntity> he = new HttpEntity>(map, headers);
RestTemplate restTemplate = new RestTemplate();
JSONObject responseJson=new JSONObject();
try {
ResponseEntity result = restTemplate.exchange(url,
HttpMethod.POST, he, JSONObject.class);
JSONObject body = result.getBody();
Object object = body.get("LIST");
JSONObject jsonObject=(JSONObject)JSON.toJSON(object);
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("o"));
/*if(url.contains("Pipeline/querySaleTotalBySaler_PS")) {
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("o"));
}else {
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("DATA"));
}*/
System.out.println("响应报文***********************" + body.toString());
String code =responseJson.getString("code");
if ("1".equals(code)) {
System.out.println("接口调用成功" + responseJson.toString());
} else {
System.out.println("数据操作异常" + result.toString());
}
} catch (Exception e) {
e.printStackTrace();
System.out.println("接口调用失败"+e);
}
return responseJson;
}
/**
* CONSUMER这个参数还没有赋值
* @param BIZTRANSACTIONID 接口系统唯一标识
* @return
*/
public static Map setCommonHeaderMap(String BIZTRANSACTIONID) {
Map map =new HashMap();
map.put("BIZTRANSACTIONID", BIZTRANSACTIONID);
map.put("COUNT", "1");
map.put("SRVLEVEL", "");
map.put("ACCOUNT", "");
map.put("PASSWORD", "");
map.put("CONSUMER", "");
return map;
}
}
声明
1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，请转载时务必注明文章作者和来源，不尊重原创的行为我们将追究责任；3.作者投稿可能会经我们编辑修改或补充。
发表评论
提交评论

java在企业级项目开发中，无论是强制性的功能需要，还是为了简便java的实现，需要调用服务器命令脚本来执行。在java中，RunTime.getRuntime() .exec() 就实现了这个功能。

 用法：  

public Process exec(String command)//在单独的进程中执行指定的字符串命令。
 
public Process exec(String [] cmdArray)//在单独的进程中执行指定命令和变量
 
public Process exec(String command, String [] envp)//在指定环境的独立进程中执行指定命令和变量
 
public Process exec(String [] cmdArray, String [] envp)//在指定环境的独立进程中执行指定的命令和变量
 


 Linux下：

String[] envp = { "LANG=UTF-8" };
String[] comands = new String[] { "/bin/sh", "-c", args};
Process process = Runtime.getRuntime().exec(comands, envp);

Windows下：

String[] envp = { "LANG=UTF-8" };
String[] comands = new String[] { "cmd", "/c", args};
Process process = Runtime.getRuntime().exec(comands, envp);

进阶：

Process的几种方法：

 destroy()：杀掉子进程

exitValue()：返回子进程的出口值，值 0 表示正常终止

getErrorStream()：获取子进程的错误流

getInputStream()：获取子进程的输入流

getOutputStream()：获取子进程的输出流

waitFor()：导致当前线程等待，如有必要，一直要等到由该 Process 对象表示的进程终止。如果子进程结束，此方法立即返回。如果该子进程没结束，调用的线程将被阻塞，直到子进程退出，

笔者在用mysql和mysqldump指令进行智能和服时，遇到主键冲突没法正常返回，后来发现是因为没有读取错误流导致。

根据惯例，0 表示正常终止（即使比如mysql指令的主键冲突，只要是指令的返回也算是正常终止），

 注意：在java中，调用runtime线程执行脚本是非常消耗资源的，所以切忌不要频繁使用！        

 在调用runtime去执行脚本的时候，其实就是JVM开了一个子线程去调用JVM所在系统的命令，其中开了三个通道： 输入流、输出流、错误流，其中输出流就是子线程走调用的通道。

  process的阻塞：

 在runtime执行大点的命令中，输入流和错误流会不断有流进入存储在JVM的缓冲区中，如果缓冲区的流不被读取被填满时，就会造成runtime的阻塞。所以在进行比如：大文件复制等的操作时，我们还需要不断的去读取JVM中的缓冲区的流，来防止Runtime的死锁阻塞。

 

最后附上在linux 上封装的方法供参考：

	/**
	 * @param daemon true,后台执行，false,直接执行
	 * @param args 指令行
	 */
	public static Result sendCommand(boolean daemon,String args) {
		logger.info("args={}", args);
		StringBuilder builder = new StringBuilder();
	//	InputStreamReader ir = null;
	//	LineNumberReader input = null;
		try {
			String[] envp = { "LANG=UTF-8" };
			Process process=null;
			if(daemon) {
				String[] comands = new String[] { "/bin/sh", "-c", args};
				process = Runtime.getRuntime().exec(comands, envp);
				process.waitFor();
			}else {
				process = Runtime.getRuntime().exec(args, envp);
				process.waitFor(60,TimeUnit.SECONDS);
			}
			try (InputStreamReader ir =  new InputStreamReader(process.getInputStream(), Charset.forName("UTF-8"));LineNumberReader input = new LineNumberReader(ir)) {
				String tmp = "";
				while ((tmp = input.readLine()) != null) {
					builder.append(tmp).append("\n");
				}
				
			}catch (Exception e) {
				logger.error(e.getMessage(), e);
				return new Result(ErrorCode.EC_FAILED, e.getMessage());
			}
			
			try (InputStreamReader ir =  new InputStreamReader(process.getErrorStream(), Charset.forName("UTF-8"));LineNumberReader input = new LineNumberReader(ir)) {
				String tmp = "";
				while ((tmp = input.readLine()) != null) {
					builder.append(tmp).append("\n");
				}
			}catch (Exception e) {
				logger.error(e.getMessage(), e);
				return new Result(ErrorCode.EC_FAILED, e.getMessage());
			}
		} catch (Exception e) {
			logger.error(e.getMessage(), e);
			return new Result(ErrorCode.EC_FAILED, e.getMessage());
		}
		String result = builder.toString();
		if (StringUtils.isNotEmpty(result)&&StringUtils.containsIgnoreCase(result, "ERROR")) {
			logger.info("result={}", result);
			return new Result(ErrorCode.EC_FAILED, result);
		} else {
			return new Result(ErrorCode.EC_OK);
		}
	}

 

package com.ekingwin.bas.cloud.mobileErp.utils;
import java.util.HashMap;
import java.util.Map;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
/**
* 向esb发送post请求工具类
* @author yang
*
*/
public class HttpRestUtil {
public static JSONObject  sendPost(Map map1,Map map2,String url) {
//设置头信息
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("Content-Type", "application/json;charset=UTF-8");
headers.set("Accept", "application/json");
//封装请求参数
Map map=new HashMap();
map.put("commonHeader", map1);
map.put("LIST", map2);
String mapJsonStr = JSON.toJSONString(map,true);
JSONObject mapJson =  JSONObject.parseObject((String) JSON.toJSON(mapJsonStr));
System.out.println("请求报文--------->>>>>>"+mapJson.toString());
//发送请求
HttpEntity> he = new HttpEntity>(map, headers);
RestTemplate restTemplate = new RestTemplate();
JSONObject responseJson=new JSONObject();
try {
ResponseEntity result = restTemplate.exchange(url,
HttpMethod.POST, he, JSONObject.class);
JSONObject body = result.getBody();
Object object = body.get("LIST");
JSONObject jsonObject=(JSONObject)JSON.toJSON(object);
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("o"));
/*if(url.contains("Pipeline/querySaleTotalBySaler_PS")) {
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("o"));
}else {
responseJson= (JSONObject)JSON.toJSON(jsonObject.get("DATA"));
}*/
System.out.println("响应报文***********************" + body.toString());
String code =responseJson.getString("code");
if ("1".equals(code)) {
System.out.println("接口调用成功" + responseJson.toString());
} else {
System.out.println("数据操作异常" + result.toString());
}
} catch (Exception e) {
e.printStackTrace();
System.out.println("接口调用失败"+e);
}
return responseJson;
}
/**
* CONSUMER这个参数还没有赋值
* @param BIZTRANSACTIONID 接口系统唯一标识
* @return
*/
public static Map setCommonHeaderMap(String BIZTRANSACTIONID) {
Map map =new HashMap();
map.put("BIZTRANSACTIONID", BIZTRANSACTIONID);
map.put("COUNT", "1");
map.put("SRVLEVEL", "");
map.put("ACCOUNT", "");
map.put("PASSWORD", "");
map.put("CONSUMER", "");
return map;
}
}
分享到：

Java调用Tuxedo服务，有三种方式：

1.JNI

发布Tuxedo服务无需做额外限制，无需借助于任何J2EE容器。会影响系统移植和带来性能问题。

2.WTC

Weglogic为Tuxedo定制，存在一套和Tuxedo API相对应的Java API，发布Tuxedo服务无需做额外限制，双向调用。需要购买License，依赖于Weblogic容器，不能移植到其它J2EE容器。

3.Jolt

可用于但不依赖于J2EE容器，提供的API用WTC类似但不同。需要购买License，发布Tuxed服务有些额外的要求，不提供集成的Weblogic-server-tuxedo事务机制。

 

最后欢迎大家访问我的个人网站：1024s