新浪支付接口对接的总结

　

新浪支付

最近需要对接新浪支付，看到一篇文章感觉不错，先转载参考。

原文：http://blog.csdn.net/lzlovez/article/details/51167286

1.接口介入方式

这种接口介入的方式，各大平台都差不多的，支付宝啊，微信支付啊，融宝支付啊，银盈通啊。都是系统必要的参数，和接口需要的参数，拼一起然互加密。

新浪支付生成 sign 的方式，签名的方式可以是 RSA 的加密方式和 MD5 的加密的方式，不过新浪推荐的是MD5的加密方式，但是给的demo里面是RSA的方式，所有自己用的也会是RSA的加密方式。

简单的例子 创建激活会员

[java]view plaincopy

1. publicstaticSinaPayresponsecreateActivateMember(Map<String,Object>data)throwsException{
3. SinaPayResponseresponse=newSinaPayResponse();
5. if(data==null||data.size()==0){
6. response.setCode(ResponceCodeEnum.Missingparameter.getCode());
7. response.setERRORMsg("传入的参数为空");
8. returnresponse;
10. }
12. //用户标识信息
13. if(data.get("identity_id")==null||data.get("identity_id").equals("")){
14. response.setCode(ResponceCodeEnum.MissingParameter.getCode());
15. response.setErrorMsg("传入的参数:用户标识信息(identity_id)为空");
16. returnresponse;
17. }
19. Map<String,Object>map=newHashMap<String,Object>();
21. map.put("identity_id",data.get("identity_id"));
23. //用户标识类型,目前只支持UID
24. map.put("identity_type",SinaPayConfig.IDENTITY_TYPE);
26. //1:个人会员;2:企业会员。默认是1
27. if(data.get("member_type")!=null&&!data.get("member_type").equals("")){
28. map.put("member_type",data.get("member_type"));
29. }
31. //系统参数
32. map.put("service",SinaPayConfig.CREATE_ACTIVATE_MEMBER);
34. Stringstr=SinaUtils.createLinkString(map,true);
36. Stringres="";
38. try{
39. res=CallServiceUtil.sendPost(SinaPayConfig.MEMBER_TSET_URL,str);
40. }catch(Exceptione){
41. response.setCode(ResponceCodeEnum.connectionTimedOut.getCode());
42. response.setErrorMsg("请求超时");
43. returnresponse;
44. }
46. Stringresult=URLDecoder.decode(res,SinaUtils.CHARSET);
48. Map<String,String>resultMap=GsonUtil.fronJson2Map(result);
50. if(SinaPayConfig.APPLY_SUCCESS.equals(resultMap.get("response_code"))){//成功
51. response.setCode(ResponceCodeEnum.success.getCode());
52. response.setErrorMsg("请求成功");
53. response.setResponseMap(resultMap);
54. returnresponse;
55. }else{
56. response.setCode(ResponceCodeEnum.requestFails.getCode());
57. response.setErrorMsg(resultMap.get("response_message"));
58. response.setResponseMap(resultMap);
59. returnresponse;
60. }
61. }

String str = SinaUtils.createLinkString(map, true);这一步是在吧我们需要的参数，包括 系统的参数，也包括接口需要的参数，生成 待签名的 字符串

[java]view plaincopy

1. /**
2. *把参数重新排序下
3. *
4. *@parammap
5. *@paramb
6. *@return
7. *@throwsException
8. */
9. publicstaticStringcreateLinkString(Map<String,Object>map,booleanencode)throwsException{
11. map.put("version",SinaPayConfig.VERSION);
12. map.put("request_time",SinaTimeUtils.getTime());
13. map.put("partner_id",SinaPayConfig.PARTNER_ID);
14. map.put("_input_charset",SinaUtils.CHARSET);
15. Stringcontent=SinaUtils.getContent(map);
16. map.put("sign",SinaUtils.getSign(content));
17. map.put("sign_type",SinaPayConfig.SIGN_TYPE);
19. List<String>keys=newArrayList<String>(map.keySet());
20. collections.sort(keys);
21. Stringprestr="";
22. Stringcharset=(String)map.get("_input_charset");
23. for(inti=0;i<keys.size();i++){
24. Stringkey=keys.get(i);
25. Stringvalue=(String)map.get(key);
26. if(encode){
27. try{
28. value=URLEncoder.encode(URLEncoder.encode(value,charset),charset);
29. }catch(UnsupportedEncodingExceptione){
30. e.printstacktrace();
31. }
32. }
33. if(i==keys.size()-1){
34. prestr=prestr+key+"="+value;
35. }else{
36. prestr=prestr+key+"="+value+"&";
37. }
38. }
40. returnprestr;
41. }

res = CallServiceUtil.sendPost(SinaPayConfig.MEMBER_TSET_URL, str); 这一步是在请求接口，返回结果

[java]view plaincopy

1. publicstaticStringsendPost(Stringurl,Stringparam){
2. printwriterout=null;
3. BufferedReaderin=null;
4. Stringresult="";
5. try{
6. URLrealUrl=newURL(url);
7. URLConnectionconn=realUrl.openConnection();
8. conn.setrequestproperty("accept","*/*");
9. conn.setRequestProperty("connection","Keep-Alive");
10. conn.setRequestProperty("user-agent","Mozilla/4.0(compatible;MSIE6.0;windowsNT5.1;SV1)");
11. conn.setDoOutput(true);
12. conn.setDoInput(true);
13. out=newPrintWriter(conn.getoutputstream());
14. out.print(param);
15. out.flush();
16. in=newBufferedReader(newinputstreamreader(conn.getInputStream()));
17. Stringline;
18. while((line=in.readLine())!=null){
19. result+=line;
20. }
21. }catch(Exceptione){
22. System.out.println("POST请求异常:"+e);
23. e.printStackTrace();
24. }finally{
25. try{
26. if(out!=null){
27. out.close();
28. }
29. if(in!=null){
30. in.close();
31. }
32. }catch(IOExceptionex){
33. ex.printStackTrace();
34. }
35. }
36. returnresult;
37. }

这个时候返回的结果是经过URLencode的代码，所以需要 处理下

String result = URLDecoder.decode(res, SinaUtils.CHARSET);

Map<String, String> resultMap = GsonUtil.fronJson2Map(result); 这一步是在把得到的结果的传，转成Map

[java]view plaincopy

1. publicstatic<T>TfronJson2Map(Stringjson){
2. returngson.fromJson(json,newTypeToken<Map<String,String>>(){
3. }.getType());
4. }

大部分的接口都是这样的调用的方式，有些接口需要的一些参数涉及用户的隐私，所以需要对参数进行RSA加密

[java]view plaincopy

1. /**
2. *比如一些参数需要加密的话
3. *
4. *@paramstring待加密的信息
5. *@throwsException
6. *@throws
7. */
8. publicstaticStringgetRSAEncodeDoc(Stringdata)throwsException{
9. byte[]data_byte=RSA.encryptByPublicKey(data.getBytes(CHARSET),SinaPayConfig.ENCRYPT);
10. returnbase64.encode(data_byte);
11. }

这个是 RSA 的类

[java]view plaincopy

1. packagecom.sinapay.util;
3. importjava.io.ByteArrayOutputStream;
4. importjava.io.UnsupportedEncodingException;
5. importjava.security.InvalidKeyException;
6. importjava.security.Key;
7. importjava.security.KeyFactory;
8. importjava.security.KeyPair;
9. importjava.security.KeyPairGenerator;
10. importjava.security.NoSuchAlgorithmException;
11. importjava.security.PrivateKey;
12. importjava.security.PublicKey;
13. importjava.security.Signature;
14. importjava.security.SignatureException;
15. importjava.security.cert.Certificate;
16. importjava.security.interfaces.RSAPrivateKey;
17. importjava.security.interfaces.RSAPublicKey;
18. importjava.security.spec.PKCS8EncodedKeySpec;
19. importjava.security.spec.X509EncodedKeySpec;
20. importjava.util.HashMap;
21. importjava.util.Map;
23. importjavax.crypto.Cipher;
25. importorg.apache.commons.codec.binary.Base64;
27. /**
28. *
29. *<p>RSA签名,加解密处理核心文件，注意：密钥长度1024</p>
30. *@authorleelun
31. *@version$Id:RSA.java,v0.12013-11-15下午2:33:53lilunExp$
32. */
33. publicclassRSA{
35. /**
36. *签名算法
37. */
38. publicstaticfinalStringSIGNATURE_ALGORITHM="SHA1withRSA";
39. /**
40. *加密算法RSA
41. */
42. publicstaticfinalStringKEY_ALGORITHM="RSA";
43. /**
44. *RSA最大加密明文大小
45. */
46. privatestaticfinalintMAX_ENCRYPT_BLOCK=117;
48. /**
49. *RSA最大解密密文大小
50. */
51. privatestaticfinalintMAX_DECRYPT_BLOCK=128;
53. /**
54. *获取公钥的key
55. */
56. privatestaticfinalStringPUBLIC_KEY="RSAPublicKey";
58. /**
59. *获取私钥的key
60. */
61. privatestaticfinalStringPRIVATE_KEY="RSAPrivateKey";
63. /**
64. *<p>
65. *生成密钥对(公钥和私钥)
66. *</p>
67. *
68. *@return
69. *@throwsException
70. */
71. publicstaticMap<String,Object>genKeyPair()throwsException{
72. KeyPairGeneratorkeyPairGen=KeyPairGenerator.getinstance(KEY_ALGORITHM);
73. keyPairGen.initialize(1024);
74. KeyPairkeyPair=keyPairGen.generateKeyPair();
75. RSAPublicKeypublicKey=(RSAPublicKey)keyPair.getPublic();
76. RSAPrivateKeyprivateKey=(RSAPrivateKey)keyPair.getPrivate();
77. Map<String,Object>keyMap=newHashMap<String,Object>(2);
78. keyMap.put(PUBLIC_KEY,publicKey);
79. keyMap.put(PRIVATE_KEY,privateKey);
80. returnkeyMap;
82. }
84. publicstaticvoidmain(String[]args)throwsException{
85. Map<String,Object>genKeyPair=genKeyPair();
87. Stringbase64publicKey=getPublicKey(genKeyPair);
88. System.out.println("公钥\n"+base64publicKey);
89. Stringbase64privateKey=getPrivateKey(genKeyPair);
90. System.out.println("私钥\n"+base64privateKey);
92. Stringpasswd="cat123113";
93. StringcharsetName="utf-8";
95. StringencryptByPublicKey=Base64.encodeBase64String((encryptByPublicKey(
96. passwd.getBytes(charsetName),base64publicKey)));
97. System.out.println("加密\n"+encryptByPublicKey);
99. byte[]decryptByPrivateKey=decryptByPrivateKey(Base64.decodeBase64(encryptByPublicKey),
100. base64privateKey);
101. Stringstring=newString(decryptByPrivateKey,"utf-8");
102. System.out.println("解密后\n"+string);
104. }
106. /**
107. *签名字符串
108. *
109. *@paramtext
110. *需要签名的字符串
111. *@paramprivateKey私钥(BASE64编码)
112. *
113. *@paramcharset
114. *编码格式
115. *@return签名结果(BASE64编码)
116. */
117. publicstaticStringsign(Stringtext,StringprivateKey,Stringcharset)throwsException{
119. byte[]keyBytes=Base64.decodeBase64(privateKey);
120. PKCS8EncodedKeySpecpkcs8KeySpec=newPKCS8EncodedKeySpec(keyBytes);
121. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
122. PrivateKeyprivateK=keyFactory.generatePrivate(pkcs8KeySpec);
123. Signaturesignature=Signature.getInstance(SIGNATURE_ALGORITHM);
124. signature.initSign(privateK);
125. signature.update(getContentBytes(text,charset));
126. byte[]result=signature.sign();
127. returnBase64.encodeBase64String(result);
129. }
131. publicstaticStringsign(Stringtext,PrivateKeyprivateKey,Stringcharset)
132. throwsSignatureException,
133. InvalidKeyException{
134. try{
135. Signaturesignature=Signature.getInstance(SIGNATURE_ALGORITHM);
136. signature.initSign(privateKey);
137. signature.update(getContentBytes(text,charset));
138. byte[]result=signature.sign();
139. returnBase64.encodeBase64String(result);
140. }catch(NoSuchAlgorithmExceptione){
141. //不可能发生，
142. returnnull;
143. }
144. }
146. /**
147. *签名字符串
148. *
149. *@paramtext
150. *需要签名的字符串
151. *@paramsign
152. *客户签名结果
153. *@parampublicKey
154. *公钥(BASE64编码)
155. *@paramcharset
156. *编码格式
157. *@return验签结果
158. */
159. publicstaticbooleanverify(Stringtext,Stringsign,StringpublicKey,Stringcharset)
160. throwsException{
161. byte[]keyBytes=Base64.decodeBase64(publicKey);
162. X509EncodedKeySpeckeySpec=newX509EncodedKeySpec(keyBytes);
163. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
164. PublicKeypublicK=keyFactory.generatePublic(keySpec);
165. Signaturesignature=Signature.getInstance(SIGNATURE_ALGORITHM);
166. signature.initVerify(publicK);
167. signature.update(getContentBytes(text,charset));
168. returnsignature.verify(Base64.decodeBase64(sign));
170. }
172. /**
173. *<P>
174. *私钥解密
175. *</p>
176. *
177. *@paramencryptedData已加密数据
178. *@paramprivateKey私钥(BASE64编码)
179. *@return
180. *@throwsException
181. */
182. publicstaticbyte[]decryptByPrivateKey(byte[]encryptedData,StringprivateKey)
183. throwsException{
184. byte[]keyBytes=Base64.decodeBase64(privateKey);
185. PKCS8EncodedKeySpecpkcs8KeySpec=newPKCS8EncodedKeySpec(keyBytes);
186. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
187. KeyprivateK=keyFactory.generatePrivate(pkcs8KeySpec);
188. Ciphercipher=Cipher.getInstance(keyFactory.getAlgorithm());
189. cipher.init(Cipher.DECRYPT_MODE,privateK);
190. intinputLen=encryptedData.length;
191. ByteArrayOutputStreamout=newByteArrayOutputStream();
192. intoffset=0;
193. byte[]cache;
194. inti=0;
195. //对数据分段解密
196. while(inputLen-offSet>0){
197. if(inputLen-offSet>MAX_DECRYPT_BLOCK){
198. cache=cipher.doFinal(encryptedData,offSet,MAX_DECRYPT_BLOCK);
199. }else{
200. cache=cipher.doFinal(encryptedData,offSet,inputLen-offSet);
201. }
202. out.write(cache,0,cache.length);
203. i++;
204. offSet=i*MAX_DECRYPT_BLOCK;
205. }
206. byte[]decryptedData=out.toByteArray();
207. out.close();
208. returndecryptedData;
210. }
212. /**
213. *<p>
214. *公钥解密
215. *</p>
216. *
217. *@paramencryptedData已加密数据
218. *@parampublicKey公钥(BASE64编码)
219. *@return
220. *@throwsException
221. */
222. publicstaticbyte[]decryptByPublicKey(byte[]encryptedData,StringpublicKey)
223. throwsException{
224. byte[]keyBytes=Base64.decodeBase64(publicKey);
225. X509EncodedKeySpecx509KeySpec=newX509EncodedKeySpec(keyBytes);
226. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
227. KeypublicK=keyFactory.generatePublic(x509KeySpec);
228. Ciphercipher=Cipher.getInstance(keyFactory.getAlgorithm());
229. cipher.init(Cipher.DECRYPT_MODE,publicK);
230. intinputLen=encryptedData.length;
231. ByteArrayOutputStreamout=newByteArrayOutputStream();
232. intoffSet=0;
233. byte[]cache;
234. inti=0;
235. //对数据分段解密
236. while(inputLen-offSet>0){
237. if(inputLen-offSet>MAX_DECRYPT_BLOCK){
238. cache=cipher.doFinal(encryptedData,offSet,MAX_DECRYPT_BLOCK);
239. }else{
240. cache=cipher.doFinal(encryptedData,offSet,inputLen-offSet);
241. }
242. out.write(cache,0,cache.length);
243. i++;
244. offSet=i*MAX_DECRYPT_BLOCK;
245. }
246. byte[]decryptedData=out.toByteArray();
247. out.close();
248. returndecryptedData;
250. }
252. /**
253. *<p>
254. *公钥加密
255. *</p>
256. *
257. *@parAMData源数据
258. *@parampublicKey公钥(BASE64编码)
259. *@return
260. *@throwsException
261. */
262. publicstaticbyte[]encryptByPublicKey(byte[]data,StringpublicKey)throwsException{
263. byte[]keyBytes=Base64.decodeBase64(publicKey);
264. X509EncodedKeySpecx509KeySpec=newX509EncodedKeySpec(keyBytes);
265. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
266. KeypublicK=keyFactory.generatePublic(x509KeySpec);
267. //对数据加密
268. Ciphercipher=Cipher.getInstance(keyFactory.getAlgorithm());
269. cipher.init(Cipher.ENCRYPT_MODE,publicK);
270. intinputLen=data.length;
271. ByteArrayOutputStreamout=newByteArrayOutputStream();
272. intoffSet=0;
273. byte[]cache;
274. inti=0;
275. //对数据分段加密
276. while(inputLen-offSet>0){
277. if(inputLen-offSet>MAX_ENCRYPT_BLOCK){
278. cache=cipher.doFinal(data,offSet,MAX_ENCRYPT_BLOCK);
279. }else{
280. cache=cipher.doFinal(data,offSet,inputLen-offSet);
281. }
282. out.write(cache,0,cache.length);
283. i++;
284. offSet=i*MAX_ENCRYPT_BLOCK;
285. }
286. byte[]encryptedData=out.toByteArray();
287. out.close();
288. returnencryptedData;
290. }
292. /**
293. *<p>
294. *公钥加密
295. *</p>
296. *
297. *@paramdata源数据
298. *@paramcert证书
299. *@return
300. *@throwsException
301. */
302. publicstaticbyte[]encryptByPublicKey(byte[]data,Certificatecert)throwsException{
304. //对数据加密
305. PublicKeyuk=cert.getPublicKey();
306. Ciphercipher=Cipher.getInstance(uk.getAlgorithm());
307. cipher.init(Cipher.ENCRYPT_MODE,uk);
308. intinputLen=data.length;
309. ByteArrayOutputStreamout=newByteArrayOutputStream();
310. intoffSet=0;
311. byte[]cache;
312. inti=0;
313. //对数据分段加密
314. while(inputLen-offSet>0){
315. if(inputLen-offSet>MAX_ENCRYPT_BLOCK){
316. cache=cipher.doFinal(data,offSet,MAX_ENCRYPT_BLOCK);
317. }else{
318. cache=cipher.doFinal(data,offSet,inputLen-offSet);
319. }
320. out.write(cache,0,cache.length);
321. i++;
322. offSet=i*MAX_ENCRYPT_BLOCK;
323. }
324. byte[]encryptedData=out.toByteArray();
325. out.close();
326. returnencryptedData;
328. }
330. /**
331. *<p>
332. *私钥加密
333. *</p>
334. *
335. *@paramdata源数据
336. *@paramprivateKey私钥(BASE64编码)
337. *@return
338. *@throwsException
339. */
340. publicstaticbyte[]encryptByPrivateKey(byte[]data,StringprivateKey)throwsException{
341. byte[]keyBytes=Base64.decodeBase64(privateKey);
342. PKCS8EncodedKeySpecpkcs8KeySpec=newPKCS8EncodedKeySpec(keyBytes);
343. KeyFactorykeyFactory=KeyFactory.getInstance(KEY_ALGORITHM);
344. KeyprivateK=keyFactory.generatePrivate(pkcs8KeySpec);
345. Ciphercipher=Cipher.getInstance(keyFactory.getAlgorithm());
346. cipher.init(Cipher.ENCRYPT_MODE,privateK);
347. intinputLen=data.length;
348. ByteArrayOutputStreamout=newByteArrayOutputStream();
349. intoffSet=0;
350. byte[]cache;
351. inti=0;
352. //对数据分段加密
353. while(inputLen-offSet>0){
354. if(inputLen-offSet>MAX_ENCRYPT_BLOCK){
355. cache=cipher.doFinal(data,offSet,MAX_ENCRYPT_BLOCK);
356. }else{
357. cache=cipher.doFinal(data,offSet,inputLen-offSet);
358. }
359. out.write(cache,0,cache.length);
360. i++;
361. offSet=i*MAX_ENCRYPT_BLOCK;
362. }
363. byte[]encryptedData=out.toByteArray();
364. out.close();
365. returnencryptedData;
367. }
369. /**
370. *@paramcontent
371. *@paramcharset
372. *@return
373. *@throwsSignatureException
374. *@throwsUnsupportedEncodingException
375. */
376. privatestaticbyte[]getContentBytes(Stringcontent,Stringcharset){
377. if(charset==null||"".equals(charset)){
378. returncontent.getBytes();
379. }
380. try{
381. returncontent.getBytes(charset);
382. }catch(UnsupportedEncodingExceptione){
383. thrownewruntimeexception("签名过程中出现错误,指定的编码集不对,您目前指定的编码集是:"+charset);
384. }
385. }
387. /**
388. *<p>
389. *获取私钥
390. *</p>
391. *
392. *@paramkeyMap密钥对
393. *@return
394. *@throwsException
395. */
396. publicstaticStringgetPrivateKey(Map<String,Object>keyMap)throwsException{
397. Keykey=(Key)keyMap.get(PRIVATE_KEY);
398. returnBase64.encodeBase64String(key.getEncoded());
399. }
401. /**
402. *<p>
403. *获取公钥
404. *</p>
405. *
406. *@paramkeyMap密钥对
407. *@return
408. *@throwsException
409. */
410. publicstaticStringgetPublicKey(Map<String,Object>keyMap)throwsException{
411. Keykey=(Key)keyMap.get(PUBLIC_KEY);
412. returnBase64.encodeBase64String(key.getEncoded());
413. }
414. }

大概就是这么多了，可能还有些要注意的地方

1.在请求审核企业会员资质（audit_member_infos）中需要上传 一个zip的压缩包，里面需要的内容都是定好了的，比如上传了8个文件，每个文件都以名称和后缀的形式放在一起，然后压缩成zip包，zip包的命名和 这个接口需要的传的参数 fileName 要一样，然后，用工具类，对zip包进行 MD5 摘要计算，计算的代码

[java]view plaincopy

1. publicstaticStringgetFileMD5(Filefile){
2. if(!file.isFile()){
3. returnnull;
4. }
5. MessageDigestdigest=null;
6. fileinputstreamin=null;
7. bytebuffer[]=newbyte[1024];
8. intlen;
9. try{
10. digest=MessageDigest.getInstance("MD5");
11. in=newFileInputStream(file);
12. while((len=in.read(buffer,0,1024))!=-1){
13. digest.update(buffer,0,len);
14. }
15. in.close();
16. }catch(Exceptione){
17. e.printStackTrace();
18. returnnull;
19. }

然后调用它给的一个上传文件的工具类，上传的代码

[java]view plaincopy

1. Stringfile_path=data.get("file_path").toString();
2. Filefile=newFile(file_path);
3. Stringfilemd5=Tools.getFileMD5(file);
5. System.out.println(filemd5);
6. System.out.println("-------------------------start------------------------------");
7. System.out.println("链接sftp");
8. sftps=newsftp();
9. try{
10. s.upload("/upload/",file_path,s.connectSFTP());
11. System.out.print("sftp文件上传成功！");
12. s.ls("/upload/",s.connectSFTP());
13. }catch(SftpExceptione){
14. e.printStackTrace();
15. System.out.print("sftp文件上传失败！");
16. response.setCode(ResponceCodeEnum.fileUploadFail.getCode());
17. response.setErrorMsg("sftp文件上传失败！");
18. returnresponse;
19. }
20. System.out.println("sftp关闭");
21. System.out.println("-------------------------end------------------------------");

sftp 类

[java]view plaincopy

1. packagecom.sinapay.util;
3. importjava.io.File;
4. importjava.io.FileInputStream;
5. importjava.util.Properties;
6. importjava.util.vector;
8. importcom.jcraft.jsch.Channel;
9. importcom.jcraft.jsch.ChannelSftp;
10. importcom.jcraft.jsch.JSch;
11. importcom.jcraft.jsch.JSchException;
12. importcom.jcraft.jsch.session;
13. importcom.jcraft.jsch.SftpException;
15. publicclasssftp{
16. protectedStringhost="";//新浪的给的服务器地址
17. protectedStringusername="";//用户名
18. protectedStringpassword;
19. protectedStringprivateKey="c:\\data\\id_rsa";//秘钥的位置
20. protectedStringpassphrase;
21. protectedintport=50022;//端口
23. publicChannelSftpconnectSFTP(){
24. JSchjsch=newJSch();
25. Channelchannel=null;
26. try{
27. if(privateKey!=null&&!"".equals(privateKey)){
28. if(passphrase!=null&&"".equals(passphrase)){
29. jsch.addIdentity(privateKey,passphrase);
30. }else{
31. jsch.addIdentity(privateKey);
32. }
33. }
34. Sessionsession=jsch.getSession(username,host,port);
35. if(password!=null&&!"".equals(password)){
36. session.setPassword(password);
37. }
38. PropertiessshConfig=newProperties();
39. sshConfig.put("StrictHostKeyChecking","no");//donotverifyhostkey
40. session.setConfig(sshConfig);
41. session.setServerAliveInterval(92000);
42. session.connect();
43. channel=session.openChannel("sftp");
44. channel.connect();
45. }catch(JSchExceptione){
46. e.printStackTrace();
47. }
48. return(ChannelSftp)channel;
49. }
51. publicvoidupload(Stringdirectory,StringuploadFile,ChannelSftpsftp){
52. try{
53. sftp.cd(directory);
54. Filefile=newFile(uploadFile);
55. sftp.put(newFileInputStream(file),file.getName());
56. }catch(Exceptione){
57. e.printStackTrace();
58. }
59. }
61. @SuppressWarnings("rawtypes")
62. publicvoidls(Stringdirectory,ChannelSftpsftp)throwsSftpException{
63. sftp.cd(directory);
64. Vectorv=sftp.ls("*.*");
65. for(inti=0;i<v.size();i++){
66. System.out.println(v.get(i));
67. }
68. }
70. publicvoiddownload(Stringdirectory,StringdownloadFile,StringsaveFile,ChannelSftpsftp){
71. try{
72. sftp.cd(directory);
73. sftp.get(downloadFile,saveFile);
74. }catch(Exceptione){
75. e.printStackTrace();
76. }
77. }
79. publicvoiddelete(Stringdirectory,StringdeleteFile,ChannelSftpsftp){
80. try{
81. sftp.cd(directory);
82. sftp.rm(deleteFile);
83. }catch(Exceptione){
84. e.printStackTrace();
85. }
86. }
88. publicvoiddisconnected(ChannelSftpsftp){
89. if(sftp!=null){
90. try{
91. sftp.getSession().disconnect();
92. }catch(JSchExceptione){
93. e.printStackTrace();
94. }
95. sftp.disconnect();
96. }
97. }
99. }

其他的都是接口调用了，都没啥了。

相关阅读

和第三方接口对接总结

接口对接分为两种形式： 我方A公司提供接口给B公司，B公司进行一些操作时调用我们的接口进行实现。 例：A开发会员等级同步接口，供B同步

防踩坑指南：对接支付渠道二三事

今天要分享的内容，会以商家的视角去分析对接渠道过程中需要关注的问题。一. 支付渠道业务规则这部分内容主要介绍常见支付渠道的业

对接企业支付宝的流程（电脑和手机）

因为项目的需求，所以对于支付这块，对接的企业支付宝的电脑网站支付和手机支付。写这篇博客的主要目的就是想把支付这块的对接给详细

天猫如何转型做好数据化运营和消费者对接

一直以来天猫能提供的只有买卖行为缺乏品牌建设，当商品在不同平台都能买到的时候，天猫的差异化在哪?除了价格战天猫还能做什么?未来

机顶盒遥控器和电视机遥控器怎么对接?

在使用机顶盒遥控器的操作电视机时电视机遥控器和机顶盒遥控器不通用，这样用起来十分不方便，我们可能要一手拿电视机遥控器一手拿机