2020.12.15

START or END? You start from the end of mine.

本文停更。四方之廣，唯三分地中可尋自在。

JAVA百度AI接口調用示例（植物識別）

1. HTTP請求服務類：主要用于發起請求與響應處理：

package com.sufe.service;import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.util.List; import java.util.Map;/*** http 工具類*/ public class HttpUtil {public static String post(String requestUrl, String accessToken, String params)throws Exception {String contentType = "application/x-www-form-urlencoded";return HttpUtil.post(requestUrl, accessToken, contentType, params);}public static String post(String requestUrl, String accessToken, String contentType, String params)throws Exception {String encoding = "UTF-8";if (requestUrl.contains("nlp")) {encoding = "GBK";}return HttpUtil.post(requestUrl, accessToken, contentType, params, encoding);}public static String post(String requestUrl, String accessToken, String contentType, String params, String encoding)throws Exception {String url = requestUrl + "?access_token=" + accessToken;return HttpUtil.postGeneralUrl(url, contentType, params, encoding);}public static String postGeneralUrl(String generalUrl, String contentType, String params, String encoding)throws Exception {URL url = new URL(generalUrl);// 打開和URL之間的連接HttpURLConnection connection = (HttpURLConnection) url.openConnection();connection.setRequestMethod("POST");// 設置通用的請求屬性connection.setRequestProperty("Content-Type", contentType);connection.setRequestProperty("Connection", "Keep-Alive");connection.setUseCaches(false);connection.setDoOutput(true);connection.setDoInput(true);// 得到請求的輸出流對象DataOutputStream out = new DataOutputStream(connection.getOutputStream());out.write(params.getBytes(encoding));out.flush();out.close();// 建立實際的連接connection.connect();// 獲取所有響應頭字段Map<String, List<String>> headers = connection.getHeaderFields();// 遍歷所有的響應頭字段for (String key : headers.keySet()) {System.err.println(key + "--->" + headers.get(key));}// 定義 BufferedReader輸入流來讀取URL的響應BufferedReader in = null;in = new BufferedReader(new InputStreamReader(connection.getInputStream(), encoding));String result = "";String getLine;while ((getLine = in.readLine()) != null) {result += getLine;}in.close();System.err.println("result:" + result);return result;} }

?2. FileUtil：文件工具類，用于讀取圖片文件

package com.sufe.service;import java.io.*;/*** 文件讀取工具類*/ public class FileUtil {/*** 讀取文件內容，作為字符串返回*/public static String readFileAsString(String filePath) throws IOException {File file = new File(filePath);if (!file.exists()) {throw new FileNotFoundException(filePath);} if (file.length() > 1024 * 1024 * 1024) {throw new IOException("File is too large");} StringBuilder sb = new StringBuilder((int) (file.length()));// 創建字節輸入流 FileInputStream fis = new FileInputStream(filePath); // 創建一個長度為10240的Bufferbyte[] bbuf = new byte[10240]; // 用于保存實際讀取的字節數 int hasRead = 0; while ( (hasRead = fis.read(bbuf)) > 0 ) { sb.append(new String(bbuf, 0, hasRead)); } fis.close(); return sb.toString();}/*** 根據文件路徑讀取byte[] 數組*/public static byte[] readFileByBytes(String filePath) throws IOException {File file = new File(filePath);if (!file.exists()) {throw new FileNotFoundException(filePath);} else {ByteArrayOutputStream bos = new ByteArrayOutputStream((int) file.length());BufferedInputStream in = null;try {in = new BufferedInputStream(new FileInputStream(file));short bufSize = 1024;byte[] buffer = new byte[bufSize];int len1;while (-1 != (len1 = in.read(buffer, 0, bufSize))) {bos.write(buffer, 0, len1);}byte[] var7 = bos.toByteArray();return var7;} finally {try {if (in != null) {in.close();}} catch (IOException var14) {var14.printStackTrace();}bos.close();}}} }

?3. Base64Util：base6編碼類，用于圖片編碼

package com.sufe.service;/*** Base64 工具類*/ public class Base64Util {private static final char last2byte = (char) Integer.parseInt("00000011", 2);private static final char last4byte = (char) Integer.parseInt("00001111", 2);private static final char last6byte = (char) Integer.parseInt("00111111", 2);private static final char lead6byte = (char) Integer.parseInt("11111100", 2);private static final char lead4byte = (char) Integer.parseInt("11110000", 2);private static final char lead2byte = (char) Integer.parseInt("11000000", 2);private static final char[] encodeTable = new char[]{'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', '+', '/'};public Base64Util() {}public static String encode(byte[] from) {StringBuilder to = new StringBuilder((int) ((double) from.length * 1.34D) + 3);int num = 0;char currentByte = 0;int i;for (i = 0; i < from.length; ++i) {for (num %= 8; num < 8; num += 6) {switch (num) {case 0:currentByte = (char) (from[i] & lead6byte);currentByte = (char) (currentByte >>> 2);case 1:case 3:case 5:default:break;case 2:currentByte = (char) (from[i] & last6byte);break;case 4:currentByte = (char) (from[i] & last4byte);currentByte = (char) (currentByte << 2);if (i + 1 < from.length) {currentByte = (char) (currentByte | (from[i + 1] & lead2byte) >>> 6);}break;case 6:currentByte = (char) (from[i] & last2byte);currentByte = (char) (currentByte << 4);if (i + 1 < from.length) {currentByte = (char) (currentByte | (from[i + 1] & lead4byte) >>> 4);}}to.append(encodeTable[currentByte]);}}if (to.length() % 4 != 0) {for (i = 4 - to.length() % 4; i > 0; --i) {to.append("=");}}return to.toString();} }

?4. 獲取認證TOKEN的服務：

package com.sufe.service;import com.alibaba.fastjson.JSONObject;import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.util.List; import java.util.Map;/*** 獲取token類*/ public class AuthService {/*** 獲取權限token* @return 返回示例：* {* "access_token": "24.460da4889caad24cccdb1fea17221975.2592000.1491995545.282335-1234567",* "expires_in": 2592000* }*/public static String getAuth() {// 官網獲取的 API Key 更新為你注冊的String clientId = "";// 官網獲取的 Secret Key 更新為你注冊的String clientSecret = "";return getAuth(clientId, clientSecret);}/*** 獲取API訪問token* 該token有一定的有效期，需要自行管理，當失效時需重新獲取.* @param ak - 百度云官網獲取的 API Key* @param sk - 百度云官網獲取的 Securet Key* @return assess_token 示例：* "24.460da4889caad24cccdb1fea17221975.2592000.1491995545.282335-1234567"*/public static String getAuth(String ak, String sk) {// 獲取token地址String authHost = "https://aip.baidubce.com/oauth/2.0/token?";String getAccessTokenUrl = authHost// 1. grant_type為固定參數+ "grant_type=client_credentials"// 2. 官網獲取的 API Key+ "&client_id=" + ak// 3. 官網獲取的 Secret Key+ "&client_secret=" + sk;try {URL realUrl = new URL(getAccessTokenUrl);// 打開和URL之間的連接HttpURLConnection connection = (HttpURLConnection) realUrl.openConnection();connection.setRequestMethod("GET");connection.connect();// 獲取所有響應頭字段Map<String, List<String>> map = connection.getHeaderFields();// 遍歷所有的響應頭字段for (String key : map.keySet()) {System.err.println(key + "--->" + map.get(key));}// 定義 BufferedReader輸入流來讀取URL的響應BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));String result = "";String line;while ((line = in.readLine()) != null) {result += line;}/*** 返回結果示例*/System.err.println("result:" + result);JSONObject jsonObject = new JSONObject();jsonObject = JSONObject.parseObject(result);String access_token = jsonObject.getString("access_token");return access_token;} catch (Exception e) {System.err.printf("獲取token失敗！");e.printStackTrace(System.err);}return null;}}

5. 調取API的類

package com.sufe.service;import com.sufe.service.Base64Util; import com.sufe.service.FileUtil; import com.sufe.service.HttpUtil;import java.net.URLEncoder;/** * 植物識別 */ public class OCRService {/*** 重要提示代碼中所需工具類* FileUtil,Base64Util,HttpUtil,GsonUtils請從* https://ai.baidu.com/file/658A35ABAB2D404FBF903F64D47C1F72* https://ai.baidu.com/file/C8D81F3301E24D2892968F09AE1AD6E2* https://ai.baidu.com/file/544D677F5D4E4F17B4122FBD60DB82B3* https://ai.baidu.com/file/470B3ACCA3FE43788B5A963BF0B625F3* 下載*/public static String plant(String filePath, String accessToken) {// 請求urlString url = "https://aip.baidubce.com/rest/2.0/image-classify/v1/plant";try {// 本地文件路徑byte[] imgData = FileUtil.readFileByBytes(filePath);String imgStr = Base64Util.encode(imgData);String imgParam = URLEncoder.encode(imgStr, "UTF-8");String param = "image=" + imgParam;// 注意這里僅為了簡化編碼每一次請求都去獲取access_token，線上環境access_token有過期時間， 客戶端可自行緩存，過期后重新獲取。String result = HttpUtil.post(url, accessToken, param);System.out.println(result);return result;} catch (Exception e) {e.printStackTrace();}return null;} }

---

2020.12.14

用于監測系統接口連接情況的腳本。

使用netstat -ano 可以查看詳細的接口連接情況：

os.system無法返回cmd命令的輸出結果，我們可以通過使用os.popen("netstat -ano").read()來獲取cmd命令的輸出結果；

事實上os.popen并非專門用于返回cmd命令的返回結果。與普通的open類似，popen帶有參數mode='r'，默認是只讀，可以改為'w'即表示開辟一個管道文件進行指令輸入，允許寫入指令后運行。

合理使用grep管道符可以獲取需要監測的端口連接情況，因為netstat -ano返回的信息是非常多的，如果頻繁記錄會產生非常大的日志文件。

每個ESTABLISHED的端口必然會對應一個進程PID，如果需要切斷端口連接，可以直接taskkill /pid <pid值>，pid值在netstat -ano輸出的最后一列。

一般重點監測22與21端口的連接情況，分別對應sftp與ftp，開啟ftp或sftp服務前必須制定嚴格的防火墻入棧規則，否則目前的網絡環境不設防的主機很容易遭到攻擊。

參考腳本如下：

# -*- coding: UTF-8 -*-import os import timeINTERVAL = 60states = ['"ESTABLISHED"', '"CLOSE_WAIT"'] # 需要記錄的states cmd1 = 'netstat -ano | find {}'.format # 列出當前所有連接情況 cmd2 = 'taskkill /pid {}'.format # 殺死進程(by pid) cmd3 = 'tasklist /fi "pid eq {}"'.format # 查詢指定pid的task詳細信息logname = 'log/established.log' logheader = '{}\t{}\t{}\t{}\t{}\t{}\n'.format('protocol', 'localhost', 'remotehost', 'state', 'pid', 'timestamp')try: # 判斷log文件是否存在with open(logname, "r") as f:passexcept: # 不存在則新建一個log文件with open(logname, "w") as f:f.write(logheader)def is_valid(protocol, localhost, remotehost, state, pid): # 根據連接情況判斷該連接是否合法""" NOT IMPLEMENTED目前不知道怎么寫邏輯, 所以默認都是合理的, 需要通過觀察規律才能發現非法侵入;目前感覺應該ESTABLISHED里的remotehost端口不是443的可能是比較少見的,另外localhost的21和22端口正常情況下應該是不會被占用的, 否則肯定是出問題了;"""return True # 返回值為Truewhile True:for state in states:reslist = os.popen(cmd1(state)).read().splitlines()timestamp = int(time.time())for res in reslist: # 遍歷每個連接行記錄splits = res.split() if len(splits)==5: # 只考慮有五個元素的行記錄protocol, localhost, remotehost, state, pid = splitsif is_valid(*splits): # 判斷是否合法: 目前默認都合法passelse: # 不合法就殺死進程print("殺死進程: {}".format(pid))print(" - 進程相關信息: \n")print("#"*64)print(os.popen(cmd1(pid)).read())print("#"*64)os.system(cmd2(pid))with open(logname, "a") as f: # 記錄f.write('{}\t{}\t{}\t{}\t{}\t{}\n'.format(protocol, localhost, remotehost, state, pid, timestamp))time.sleep(INTERVAL)

PS：

右膝這次傷得有點厲害，可能很長時間跑不了了。

---

2020.12.13

完蛋，右膝腫了，照例又給老媽臭罵了一通。

晚上霾還是有點重，但是準備好了是要上場的。

狀態其實特別好，5km用時不到23'30''，且體力明顯充沛，但是感覺右大腿隱隱作痛快要抽筋了；

以為是右腿壓得太厲害，于是刻意把重心壓到左邊，但還是疼。

15圈結束感覺右膝蓋開始抽筋，不得已只好停下，發現膝蓋紅腫，樓梯都走不動了。

最后是28'15''跑了15圈，一點力竭感都沒有，本來極有可能把10km刷新到46分半以內的，太遺憾了。

搞了個護膝，可惜不知道幾天才能恢復得過來。總之冬天千萬別光著膝蓋跑，真的是太傷了。

最近一個月不是在受傷，就是跑在即將受傷的路上，從右腿到左腳到右腳再到右膝，OMG。

---

2020.12.12

右膝確實傷了，一方面可能穿短褲跑沒有護膝給凍壞了，另一方面連續3天的高強度速耐給整廢了，休息一天，右腳也開始出現兩個小泡，還好不是血泡。最近霾太重，晚上又跑了一次上下六樓加兩個30米過道共計10次，耗時16'44''，平均1次上下樓加過道來回剛剛好100秒，爬樓太累了。

太冷了，之前一直都只在短袖外面套了一件衛衣，今天實在是頂不住了，不知道接下來還能否短袖短褲上場跑了。。。早八晚十，學點東西，困。

某人給我刷到10000訪問量咋還在刷呢？我在后臺是可以看到最頻繁訪問的幾個IP地址的，是誰我大致能猜得到，有空可以幫我刷刷其他幾篇還沒到10000的，還有您這個刷法太慢了，建議參考一下https://caoyang.blog.csdn.net/article/details/110791414最后一節內容，我看著都嫌累。

PS：

S換了個頭像，我翻列表時沒找到以為自己終于是被刪了..

列一點note，充實一下內容；

torch.Tensor 與 torch.tensor

實例對比:

• Example1: 接收整型參數; print(torch.Tensor(5)) print(torch.tensor(5))
  • 輸出結果: 前者生成以參數值為維度的隨機向量(隨機值非常小), 后者生成一個tensor標量;
  tensor([1.0561e-38, 1.0653e-38, 1.0469e-38, 9.5510e-39, 8.7245e-39]) tensor(5)
• Example2: 接收列表型或元組型參數; print(torch.Tensor([1, 2, 3, 4, 5])) print(torch.tensor([1, 2, 3, 4, 5])) print(torch.Tensor((3, 4))) print(torch.tensor((3, 4)))
  • 輸出結果: 兩者輸出結果基本類似, 前者會默認將數值類型從整型轉為浮點型, 后者則會保持輸入時的數值類型(整型), 且列表和元組本質上沒有區別;
  tensor([1., 2., 3., 4., 5.]) tensor([1, 2, 3, 4, 5]) tensor([3., 4.]) tensor([3, 4])
• Example3: 接收多個整型參數; print(torch.Tensor(3, 4)) #print(torch.tensor(3, 4))
  • 輸出結果: 前者生成以多個整型參數為shape的隨機張量(隨機值非常小), 后者會報錯, 因為后者只支持接收一個參數;
  tensor([[9.9184e-39, 9.0000e-39, 1.0561e-38, 1.0653e-38],[4.1327e-39, 8.9082e-39, 9.8265e-39, 9.4592e-39],[1.0561e-38, 1.0653e-38, 1.0469e-38, 9.5510e-39]]) Traceback (most recent call last): ... TypeError: tensor() takes 1 positional argument but 2 were given
• Example4: 接收numpy.ndarray類型的參數; print(torch.Tensor(numpy.array([[1, 2, 3], [4, 5, 6]]))) print(torch.tensor(numpy.array([[1., 2., 3.], [4., 5., 6.]]))) print(torch.tensor(numpy.array([[1, 2, 3], [4, 5, 6]])))
  • 輸出結果: 兩者都將numpy.ndarray數組轉為torch.Tensor, 前者默認轉為浮點型數值, 后者保持原有數據類型;
  tensor([[1., 2., 3.],[4., 5., 6.]]) tensor([[1., 2., 3.],[4., 5., 6.]], dtype=torch.float64) tensor([[1, 2, 3],[4, 5, 6]], dtype=torch.int32)
• Example5: 接收torch.Size類型的參數: print(torch.Tensor(torch.Tensor([[1, 2, 3], [4, 5, 6]]).shape)) print(torch.tensor(torch.Tensor([[1, 2, 3], [4, 5, 6]]).shape))
  • 輸出結果: 前者會生成以torch.Size類型參數為形狀的零張量, 后者則會將參數直接轉為torch.Tensor
  tensor([[0., 0., 0.],[0., 0., 0.]]) tensor([2, 3])

---

總結

以上是生活随笔為你收集整理的【置顶】囚生CYのPOST（NEW VERSION）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。