Java學習不走彎路教程（4.用SQL查詢遠程伺服器的文件）

来源:https://www.cnblogs.com/java123vip/archive/2018/10/01/9732445.html
-Advertisement-
Play Games

一. 前言在前上一章教程中，介紹了用SQL查詢本地文件。程式代碼請從這裡下載。 本章將在上一章的基礎上，進一步擴展程式。實際的生產環境中，一般查詢的文件都放在遠程的文件或數據伺服器上，下麵我將帶大家一步一步實現遠程查詢的程式。 註：1.本文針對初學Java的同學訓練學習思路，請不要太糾結於細節問題。 ...


 一. 前言
在前上一章教程中，介紹了用SQL查詢本地文件。
程式代碼請從這裡下載。

本章將在上一章的基礎上，進一步擴展程式。
實際的生產環境中，一般查詢的文件都放在遠程的文件或數據伺服器上，
下麵我將帶大家一步一步實現遠程查詢的程式。

註：
1.本文針對初學Java的同學訓練學習思路，請不要太糾結於細節問題。
2.本文旨在達到拋磚引玉的效果，希望大家擴展本例子，以學到更多知識的精髓。

二. 寫給初學Java的同學
在介紹本章內容之前，首先介紹一下Java的學習方法。
相信大家在看本文的時候已經已經拿到了各種Java學習路徑，大體都是一樣。
我想說的是，不要讓知識的學習成為負擔，Java技術種類繁多，是無論如何也學不完的。
正確的學習方法是興趣驅動，實例驅動。
即通過一個簡單的實例，不斷加入所學知識進行擴展，最終擴展為一個大項目，達到系統學習，學以致用的效果。

三. 步入正題
話不多說，大家自己理解，下麵步入正題：

 本章系統的流程如下：

【客戶端】
1.連接遠程伺服器。
2.向遠程伺服器發送查詢SQL。
3.將遠程伺服器反饋的查詢結果輸出。

【伺服器】
1.在指定埠監聽，等待客戶端連接。
2.有客戶端連接後，讀取客戶端傳來的SQL。
3.調用文件查詢模塊，查詢數據。
4.將查詢的數據反饋給客戶端。
5.轉到步驟1。

工程的結構如下：


其中文件查詢模塊復用上一章的代碼，在此不做講解。
我們著重介紹客戶端與伺服器通訊的過程。

要想與網路中的一臺機器的某個程式進行通訊，首先我們需要定位這台機器的某個程式。
IP地址標識了網路中唯一的機器，這台機器的不同的埠則標示了不同的程式。

所以，客戶端要知道連接伺服器的IP地址和埠號，來完成於伺服器的連接。
而伺服器程式之需要在特定的埠監聽，等待客戶端的連接。

伺服器連接成功後，即可通過輸入輸出流進行通訊。
通訊協議分為兩種TCP/IP協議和UDP協議：
前者能維持穩定的通訊，確保每一個發送的信息對方都收到。
後者只負責發送信息而不管對方有沒有收到。

比如文字通訊的軟體一般採用TCP/IP協議，因為要確保發送的每條消息對方都能收到。
音頻視頻通訊軟體一般採用UDP協議，因為缺了一點信息也不影響對聲音圖像的識別。

本項目我們採用TCP/IP協議，在Java中用ServerSocket和Socket封裝了TCP/IP協議，所以我們直接拿來用即可，感興趣的同學可以研究一下底層的實現。

四. 服務端程式
我們首先看單個客戶端與伺服器的通訊流程，如下圖所示：

多個客戶端連接後，如下圖所示：

所以，我們首先做一個類ClientThread，用來負責伺服器與客戶端通訊的線程，代碼如下：

 1 /**
 2  * 
 3  * @author http://www.java123.vip
 4  *
 5  */
 6 public class ClientThread implements Runnable{
 7 
 8     private Socket socket;
 9     private BufferedReader br;
10     private PrintWriter pw;
11     
12     public ClientThread(Socket socket) {
13         try {
14             
15             // 創建輸入輸出流
16             InputStream is = socket.getInputStream();
17             InputStreamReader isr = new InputStreamReader(is);
18             br = new BufferedReader(isr);
19             
20             OutputStream os = socket.getOutputStream();
21             OutputStreamWriter osw = new OutputStreamWriter(os);
22             pw = new PrintWriter(osw,true);
23             
24         } catch (IOException e) {
25             e.printStackTrace();
26         }
27     }
28     
29     public void run() {
30         
31         GetFile gf = new GetFile("c:/temp/");
32         
33         while(true) {
34             try {
35                 
36                 // 讀取客戶端的一行信息
37                 String message = br.readLine();
38                 System.out.println("get message:"+message);
39                 
40                 // 用冒號(:)來分隔信息的頭與內容
41                 String header = message.split(":")[0];
42                 String body = message.substring(message.indexOf(":")+1);
43                 
44                 // 查詢請求
45                 if(header.equals("query")) {
46                     String result = gf.queryFile(body);
47                     pw.println(result);
48                     
49                 // 斷開連接請求
50                 }else if(header.equals("bye")) {
51                     if(socket != null) {
52                         socket.close();
53                     }
54                     break;
55                 }
56                 
57             } catch(IOException e) {
58                 e.printStackTrace();
59             } catch (Exception e) {
60                 e.printStackTrace();
61             }
62         }
63     }
64     
65 }

 

伺服器實現代碼如下：

 1 /**
 2  * 
 3  * @author http://www.java123.vip
 4  *
 5  */
 6 public class FileViewServer {
 7 
 8     private int port;
 9     
10     public FileViewServer(int port) {
11         this.port = port;
12     }
13     
14     /**
15      * 啟動伺服器
16      */
17     public void startServer() {
18         try {
19             
20             ServerSocket ss = new ServerSocket(port);
21             System.out.println("listening at port:"+port);
22             
23             while(true) {
24                 Socket s = ss.accept();
25                 System.out.println("get connection:"+s.getInetAddress().toString());
26                 
27                 // 得到連接後，啟動新線程負責通訊
28                 ClientThread clientThread = new ClientThread(s);
29                 new Thread(clientThread).start();
30             }
31             
32         } catch (IOException e) {
33             e.printStackTrace();
34         }
35     }
36     
37     public static void main(String[] args) {
38         FileViewServer fvs = new FileViewServer(8000);
39         fvs.startServer();
40     }
41 }

 

五. 客戶端程式
我們需要做三個方法：
  ・連接伺服器方法
  ・斷開伺服器方法
  ・查詢遠程文件方法

代碼如下：
連接伺服器方法

 1     private Socket socket;
 2     private BufferedReader br;
 3     private PrintWriter pw;
 4     
 5     /**
 6      * 連接遠程伺服器
 7      * 
 8      * @param ip
 9      * @param port
10      */
11     public void connect(String ip, int port) {
12         try {
13             
14             // 連接伺服器
15             socket = new Socket(ip, port);
16             
17             // 創建輸入輸出流
18             InputStream is = socket.getInputStream();
19             InputStreamReader isr = new InputStreamReader(is);
20             br = new BufferedReader(isr);
21             
22             OutputStream os = socket.getOutputStream();
23             OutputStreamWriter osw = new OutputStreamWriter(os);
24             pw = new PrintWriter(osw,true);
25             
26         } catch (IOException e) {
27             e.printStackTrace();
28         }
29     }
30

 

斷開伺服器方法

 1     
 2     /**
 3      * 斷開連接
 4      */
 5     public void disConnect() {
 6         try {
 7             
 8             // 發送斷開連接請求
 9             pw.println("bye:bye");
10             socket.close();
11         } catch (IOException e) {
12             e.printStackTrace();
13         }
14     }
15

 

查詢遠程文件方法

 1     /**
 2      * 查詢
 3      * 
 4      * @param sql
 5      * @return
 6      */
 7     public String query(String sql) {
 8         
 9         StringBuffer result = new StringBuffer("");
10         
11         try {
12             
13             // 發送查詢請求
14             pw.println("query:"+sql);
15             
16             while(true) {
17                 
18                 // 讀取查詢結果的每一行
19                 String queryResultLine = br.readLine();
20                 
21                 // 讀到空字元串表示結果讀取完畢
22                 if("".equals(queryResultLine)) {
23                     break;
24                     
25                 // 否則，把讀到的內容存起來
26                 }else {
27                     result.append(queryResultLine);
28                     result.append("\n");
29                 }
30             }
31         } catch (IOException e) {
32             e.printStackTrace();
33         }
34         
35         // 返回查詢結果
36         return result.toString();
37     }
38

 

六. 測試
最後我們來測試這個程式，測試代碼如下：

 1     
 2     /**
 3      * 測試
 4      * @param args
 5      */
 6     public static void main(String[] args) {
 7         FileViewClient fvc = new FileViewClient();
 8         fvc.connect("127.0.0.1",8000);
 9         
10         String sql1 = "select * from abc.csv ";
11         String sql2 = "select id from abc.csv ";
12         String sql3 = "select id,username from abc.csv where id=2 ";
13         String sql4 = "select id,username from abc.csv where username=abc and password=aaa ";
14         String sql5 = "select id,username from abc.csv where username=abc and password=bbb ";
15         
16         System.out.println("Execute:"+sql1);
17         System.out.println(fvc.query(sql1));
18         
19         System.out.println("Execute:"+sql2);
20         System.out.println(fvc.query(sql2));
21         
22         System.out.println("Execute:"+sql3);
23         System.out.println(fvc.query(sql3));
24         
25         System.out.println("Execute:"+sql4);
26         System.out.println(fvc.query(sql4));
27         
28         System.out.println("Execute:"+sql5);
29         System.out.println(fvc.query(sql5));
30         
31         fvc.disConnect();
32     }

 

首先啟動伺服器，輸出如下：

listening at port:8000

 

啟動客戶端測試程式：
客戶端輸出如下：

Execute:select * from abc.csv 
1,abc,aaa
2,def,bbb
3,xyz,ccc

Execute:select id from abc.csv 
1
2
3

Execute:select id,username from abc.csv where id=2 
2,def

Execute:select id,username from abc.csv where username=abc and password=aaa 
1,abc

Execute:select id,username from abc.csv where username=abc and password=bbb

 

伺服器輸出如下：

listening at port:8000
get connection:/127.0.0.1
get message:query:select * from abc.csv 
get message:query:select id from abc.csv 
get message:query:select id,username from abc.csv where id=2 
get message:query:select id,username from abc.csv where username=abc and password=aaa 
get message:query:select id,username from abc.csv where username=abc and password=bbb 
get message:bye:bye

 

完整代碼請在這裡下載

如有問題，大家來我的網站進行提問。
https://www.java123.vip/qa

七. 後續
本例為通過簡單的SQL語句查詢遠程存在的文件，大家可以擴展此程式，比如用線程池來管理線程，對於異常信息的處理等。
後續章節我將在此程式的基礎上，其支持JDBC介面，然後換成資料庫，並且一步一步實現ORM，Service，HTTP查詢等功能。

版權聲明：本教程版權歸java123.vip所有，禁止任何形式的轉載與引用。

原帖發表於：https://www.cnblogs.com/java123vip/p/9732445.html


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • BZOJ4653: [Noi2016]區間(線段樹 雙指針)
    題意 "題目鏈接" Sol 按照dls的說法，一般這一類的題有兩種思路，一種是枚舉一個點$M$，然後check它能否成為答案。但是對於此題來說好像不好搞 另一種思路是枚舉最小的區間長度是多少，這樣我們把所有區間按長度排序後可以二分出滿足條件的最短的區間長度 觀察後不難發現，較長區間的長度一定是隨著短 ...
  • 圖像去模糊演算法 循序漸進 附完整代碼
    關於圖像模糊演算法的實現， 我相信大多數學習圖像演算法的朋友都很熟悉。 例如常見的毛玻璃效果，高斯模糊等等。 而圖像模糊最簡單的實現就是 在一定區域 對像素做平均值計算。 術語描述，捲積。 1.認識捲積 而平均值計算可以，是一種常見的捲積計算，捲積核權重都為1。 OpenCV中與之對應的演算法是BoxBl ...
  • Eclipse安裝SpringBoot插件以及Eclipse無法連接到Eclipse Marketplace的解決方法
    1.Eclipse無法連接到Eclipse Marketplace的解決方法 （1）在eclipse文件夾下的eclipse.ini文件末尾添加 -Djava.net.preferIPv4Stack=true （2）點擊Add進行添加 （3）在help–install new software–ad ...
  • JAVA的三個版本EE，SE，ME
    1998年 SUN發佈三個不同版本JAVA，分別是： Java J2EE（Java Platform，Enterprise Edition) JAVA企業版，應用為開發和部署可移植、健壯、可伸縮且安全的伺服器端Java應用程式。 Java J2SE（Java Platform，Standard Ed ...
  • 洛谷P3372 【模板】線段樹 1(樹狀數組)
    題意 "題目鏈接" Sol Get到了這題樹狀數組的做法，感覺非常nice 區間加：直接差分 區間求和：考慮每一位的貢獻 $sum_{i = 1}^x (x+1 i) d_i$ $= sum_{i = 1}^x (x+1)d_i \sum_{i = 1}^x id_i$ $= (x+1) sum_{ ...
  • 理解PHP數組的序列化和反序列化
    當我們想要將數組值存儲到資料庫時，就可以對數組進行序列化操作，然後將序列化後的值存儲到資料庫中。其實PHP序列化數組就是將複雜的數組數據類型轉換為字元串，方便數組存庫操作。對PHP數組進行序列化和反序列化操作，主要就用到兩個函數，serialize和unserialize。 一、PHP數組序列化：s ...
  • JAVA初識，JAVA是什麼？
    一、什麼是JAVA 二、JAVA發展歷史 1991年 SUN公司為搶占電腦單片機嵌入式領域市場，成立GReen項目小組，專攻家電嵌入式應用。由於C++程式複雜龐大，且跨平臺是個問題，所以對C++進行改造，去除了留在C++的一些不太實用及影響安全的成分，並結合嵌入式系統的實時性要求，開發了一種稱為O ...
  • IntelliJ IDEA（二、常用設置）
    一、如何進入設置界面 1. File -- Settings 2. 小圖標 二、常用設置 註意： IDEA中的這些設置，一次就好，因為設置信息是配置在C盤根目錄下，所有創建的工程共用這一套設置。 區別於Eclipse，每建一個workspace，就要從新設置一邊。 1. 更換主題 2. 顯示常用工具 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類