java--網路編程

来源:https://www.cnblogs.com/shixiemayi/archive/2018/08/14/9478582.html
-Advertisement-
Play Games

1、Java支持基於流的通信和基於包的通信 基於流的通信使用TCP協議（傳輸控制協議）進行數據傳輸，傳輸是無損可靠的 基於包的通信使用UDP協議（用戶數據報協議）進行數據傳輸，不能保證傳輸沒有丟失 2、服務端和客戶端套接字--基於流的通信 客戶端代碼 如果服務端的埠服務沒有起來，運行客戶端的程式會 ...


1、Java支持基於流的通信和基於包的通信

基於流的通信使用TCP協議（傳輸控制協議）進行數據傳輸，傳輸是無損可靠的

基於包的通信使用UDP協議（用戶數據報協議）進行數據傳輸，不能保證傳輸沒有丟失

2、服務端和客戶端套接字--基於流的通信

  • 客戶端代碼
package com.wangluo;

import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

    public static void main(String[] args) {
        try {
            //1.創建客戶端Socket,指定伺服器端地址和埠
            Socket socket = new Socket("localhost",8888);
            //2.獲取輸出流，向伺服器端發送信息
            OutputStream os = socket.getOutputStream();//位元組輸出流
            PrintWriter pw = new PrintWriter(os);//將輸出流包裝為列印流
            pw.write("用戶名：admin;密碼：123");
            pw.write("用戶名：admin2;密碼：456");
            pw.flush();
            socket.shutdownOutput();//關閉輸出流，對於 TCP 套接字，任何以前寫入的數據都將被髮送
            //3.獲取輸入流，並讀取伺服器的響應信息
            InputStream is = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            String info = null;
            while((info = br.readLine()) != null) {
                System.out.println("我是客戶端，伺服器端說："+info);
            }
            //4.關閉資源
            br.close();
            is.close();
            pw.close();
            os.close();
            socket.close();

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

如果服務端的埠服務沒有起來，運行客戶端的程式會拋異常

java.net.ConnectException: Connection refused: connect
  • 服務端代碼--服務多個客戶
package com.wangluo;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) {

        try {
            //1.創建一個伺服器端Socket,即ServerSocket,指定綁定的埠
            ServerSocket serverSocket = new ServerSocket(8888);
            //2.調用accept()方法開始監聽，等待客戶端 的連接
            System.out.println("***伺服器即將啟動，等待客戶端的連接***");
            while (true) {
                //監聽埠
                Socket socket = serverSocket.accept();
                new MyThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    static class MyThread extends Thread{
        private Socket socket;
        public MyThread(Socket socket){
            this.socket=socket;
        }
        @Override
        public void run() {
            try {
                server(socket);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        private void server(Socket socket) throws IOException {
            //3.獲取輸入流，並讀取客戶端信息
            InputStream is = socket.getInputStream();//位元組輸入流
            InputStreamReader isr = new InputStreamReader(is);//將位元組輸入流轉換為字元流
            BufferedReader br = new BufferedReader(isr);//為輸入流添加緩衝
            String info = null;
            while((info=br.readLine())!=null) {//迴圈讀取客戶端的信息
                System.out.println("我是伺服器，客戶端說："+info);
            }
            OutputStream os = socket.getOutputStream();//位元組輸出流
            PrintWriter pw = new PrintWriter(os);//將輸出流包裝為列印流
            pw.write("我是服務端");
            pw.flush();
            socket.shutdownInput();//關閉輸入流
             //4.關閉資源
            br.close();
            isr.close();
            is.close();
            socket.close();
        }
    }
}

如果服務端監聽的埠已經被使用了，在啟動服務端的服務時候會拋異常

java.net.BindException
  • 輸出結果：（先啟動服務端，再啟動客戶端）

服務端輸出：我是伺服器，客戶端說：用戶名：admin;密碼：123用戶名：admin2;密碼：456

客戶端輸出：我是客戶端，伺服器端說：我是服務端

3、套接字發送和接受對象

  • 對象必須實現Serializable介面
package com.wangluo;

import java.io.Serializable;

public class Test implements Serializable{

    private static long serialVersionUID=1L;
    private int num;
    private String name;

    public Test(int num, String name){
        this.num=num;
        this.name=name;
    }
    public int getNum() {
        return num;
    }

    public void setNum(int num) {
        this.num = num;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "Test{" +
                "num=" + num +
                ", name='" + name + '\'' +
                '}';
    }
}
  • 客戶端代碼
package com.wangluo;

import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

    public static void main(String[] args) {
        try {
            //1.創建客戶端Socket,指定伺服器端地址和埠
            Socket socket = new Socket("localhost",8888);
            //2.獲取輸出流，向伺服器端發送信息
            OutputStream os = socket.getOutputStream();//位元組輸出流
//            PrintWriter pw = new PrintWriter(os);//將輸出流包裝為列印流
//            pw.write("用戶名：admin;密碼：123");
//            pw.write("用戶名：admin2;密碼：456");
//            pw.flush();
            ObjectOutputStream objectOutputStream=new ObjectOutputStream(os);
            objectOutputStream.writeObject(new Test(123,"deng"));
            objectOutputStream.flush();
            socket.shutdownOutput();//關閉輸出流
            //3.獲取輸入流，並讀取伺服器的響應信息
            InputStream is = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            String info = null;
            while((info = br.readLine()) != null) {
                System.out.println("我是客戶端，伺服器端說："+info);
            }
            //4.關閉資源
            br.close();
            is.close();
//            pw.close();
            objectOutputStream.close();
            os.close();
            socket.close();

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
  • 服務端代碼
package com.wangluo;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) {

        try {
            //1.創建一個伺服器端Socket,即ServerSocket,指定綁定的埠
            ServerSocket serverSocket = new ServerSocket(8888);
            //2.調用accept()方法開始監聽，等待客戶端 的連接
            System.out.println("***伺服器即將啟動，等待客戶端的連接***");
            while (true) {
                //監聽埠
                Socket socket = serverSocket.accept();
                new MyThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    static class MyThread extends Thread{
        private Socket socket;
        public MyThread(Socket socket){
            this.socket=socket;
        }
        @Override
        public void run() {
            try {
                server(socket);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        private void server(Socket socket) throws Exception {
            //3.獲取輸入流，並讀取客戶端信息
            InputStream is = socket.getInputStream();//位元組輸入流
//            InputStreamReader isr = new InputStreamReader(is);//將位元組輸入流轉換為字元流
//            BufferedReader br = new BufferedReader(isr);//為輸入流添加緩衝
//            String info = null;
//            while((info=br.readLine())!=null) {//迴圈讀取客戶端的信息
//                System.out.println("我是伺服器，客戶端說："+info);
//            }

            ObjectInputStream objectInputStream=new ObjectInputStream(is);
            Object test=objectInputStream.readObject();
            System.out.println("我是伺服器，客戶端說："+test);
            OutputStream os = socket.getOutputStream();//位元組輸出流
            PrintWriter pw = new PrintWriter(os);//將輸出流包裝為列印流
            pw.write("服務端應答");
            pw.flush();
            socket.shutdownInput();//關閉輸入流
             //4.關閉資源
//            br.close();
//            isr.close();
            objectInputStream.close();
            is.close();
            socket.close();
        }
    }
}
  • 輸出結果：

服務端：我是伺服器，客戶端說：Test{num=123, name='deng'}

客戶端：我是客戶端，伺服器端說：服務端應答


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

-Advertisement-
Play Games
更多相關文章
  • 【leetcode 簡單】第二十七題 二叉樹的最小深度
    給定一個二叉樹，找出其最小深度。 最小深度是從根節點到最近葉子節點的最短路徑上的節點數量。 說明: 葉子節點是指沒有子節點的節點。 示例: 給定二叉樹 [3,9,20,null,null,15,7], 3 / \ 9 20 / \ 15 7 返回它的最小深度 2. 最小深度是從根節點到最近葉子節點的 ...
  • 【leetcode 簡單】第二十三題 二叉樹的最大深度
    給定一個二叉樹，找出其最大深度。 二叉樹的深度為根節點到最遠葉子節點的最長路徑上的節點數。 說明: 葉子節點是指沒有子節點的節點。 示例： 給定二叉樹 [3,9,20,null,null,15,7]， 3 / \ 9 20 / \ 15 7 返回它的最大深度 3 。 /** * Definition ...
  • 《劍指Offer》——Singleton（Java版）
    1.單例模式的定義 單例模式確保某個類只有一個實例，而且自行實例化並向整個系統提供這個實例。 2.單例模式的特點 單例類只能有一個實例。 單例類必須自己創建自己的唯一實例。 單例類必須給所有其他對象提供這一實例。 3.單例模式的Java代碼 單例模式分為懶漢式（需要才去創建對象）和餓漢式（創建類的實 ...
  • python_爬蟲_通過selenium獲取人人網cookie值並模擬登陸個人界面
    平臺：mac 網站：人人網 最近練習爬蟲登陸，方法一是找頁面里的js文件，通過解析js文件找到cookie信息再保持。但現在的站點登陸都有驗證碼，而且最煩的是request時data表單里的值基本上沒有不加密的，js學的不好，就別想著破解了。所以想起了用的比較少的selenium模塊，用於模擬登陸並 ...
  • TP5部署伺服器問題總結
    及最近部署TP5遇到了很多坑,各種環境下都會出現一些問題,下麵是我記錄的排坑之路 先說最簡單的lnmp一鍵安裝包,我用的是1.5穩定版 安裝命令:wget http://soft.vpser.net/lnmp/lnmp1.5.tar.gz -cO lnmp1.5.tar.gz && tar zxf ...
  • 聊一聊如何接入支付寶
    說起來做一個支付系統最基礎的就是支付功能了，對於我們來說除了各大銀行以外微信和支付寶也是必選項，畢竟人家這個龐大的用戶群在那裡擺著呢，你不用那不是想著放棄這些用戶麽。 今天我們就來看一看對於我們開發者來說如何快速的進行接入。 首先我們要做的就是先去螞蟻金服開放平臺註冊賬號https://open.a ...
  • Python異常處理總結
    這篇文章主要介紹了Python異常處理總結,需要的朋友可以參考下本文較為詳細的羅列了Python常見的異常處理，供大家參考，具體如下： 1.入門讀物 2.進階讀物 3.Web框架 4.爬蟲開發 5.圖形圖像6.數據分析 7.機器學習等等資料！需要的可以加QQ群：832339352！進群免費獲取！ 拋 ...
  • POJ 1011 Sticks解題報告
    Description George took sticks of the same length and cut them randomly until all parts became at most 50 units long. Now he wants to return sticks to ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類