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
  • C# + WPF 音頻播放器 界面優雅，體驗良好
    前言 本文介紹一款使用 C# 與 WPF 開發的音頻播放器，其界面簡潔大方，操作體驗流暢。該播放器支持多種音頻格式（如 MP4、WMA、OGG、FLAC 等），並具備標記、實時歌詞顯示等功能。 另外，還支持換膚及多語言（中英文）切換。核心音頻處理採用 FFmpeg 組件，獲得了廣泛認可，目前 Git ...
  • OAuth2.0授權-gitee授權碼模式
    OAuth2.0授權驗證-gitee授權碼模式 本文主要介紹如何筆者自己是如何使用gitee提供的OAuth2.0協議完成授權驗證並登錄到自己的系統，完整模式如圖 1、創建應用 打開gitee個人中心->第三方應用->創建應用 創建應用後在我的應用界面，查看已創建應用的Client ID和Clien ...
  • FastReport.OpenSource .Net下開源免費報表列印組件
    解決了這個問題：《winForm下，fastReport.net 從.net framework 升級到.net5遇到的錯誤“Operation is not supported on this platform.”》 本文內容轉載自：https://www.fcnsoft.com/Home/Sho ...
  • 如何在 ASP.NET Core Web API 方法執行前後 “偷偷“ 作一些 “壞“ 事？初識 ActionFilterAttribute
    國內文章 WPF 從裸 Win 32 的 WM_Pointer 消息獲取觸摸點繪製筆跡 https://www.cnblogs.com/lindexi/p/18390983 本文將告訴大家如何在 WPF 裡面，接收裸 Win 32 的 WM_Pointer 消息，從消息裡面獲取觸摸點信息，使用觸摸點 ...
  • 在 ASP.NET Core Web API 中使用異常篩選器捕獲和統一處理異常
    前言 給大家推薦一個專為新零售快消行業打造了一套高效的進銷存管理系統。 系統不僅具備強大的庫存管理功能，還集成了高性能的輕量級 POS 解決方案，確保頁面載入速度極快，提供良好的用戶體驗。 項目介紹 Dorisoy.POS 是一款基於 .NET 7 和 Angular 4 開發的新零售快消進銷存管理 ...
  • AbpHelper CLI積累與實戰分享
    ABP CLI常用的代碼分享 一、確保環境配置正確 安裝.NET CLI： ABP CLI是基於.NET Core或.NET 5/6/7等更高版本構建的，因此首先需要在你的開發環境中安裝.NET CLI。這可以通過訪問Microsoft官網下載並安裝相應版本的.NET SDK來實現。 安裝ABP ...
  • 記一次HttpClient使用問題分析
    問題 問題是這樣的：第三方的webapi，需要先調用登陸介面獲取Cookie，訪問其它介面時攜帶Cookie信息。 但使用HttpClient類調用登陸介面，返回的Headers中沒有找到Cookie信息。 分析 首先，使用Postman測試該登陸介面，正常返回Cookie信息，說明是HttpCli ...
  • .NET周刊【9月第3期 2024-09-15】
    國內文章 關於.NET在中國為什麼工資低的分析 https://www.cnblogs.com/thinkingmore/p/18406244 .NET在中國開發者的薪資偏低，主要因市場需求、技術棧選擇和企業文化等因素所致。歷史上，.NET曾因微軟的閉源策略發展受限，儘管後來推出了跨平臺的.NET ...
  • 我的網站集成ElasticSearch初體驗
    在WPF開發應用中，動畫不僅可以引起用戶的註意與興趣，而且還使軟體更加便於使用。前面幾篇文章講解了畫筆（Brush），形狀（Shape），幾何圖形（Geometry），變換（Transform）等相關內容，今天繼續講解動畫相關內容和知識點，僅供學習分享使用，如有不足之處，還請指正。 ...
  • 第23篇 委托的概述
    什麼是委托？ 委托可以說是把一個方法代入另一個方法執行，相當於指向函數的指針；事件就相當於保存委托的數組； 1.實例化委托的方式： 方式1：通過new創建實例： public delegate void ShowDelegate(); 或者 public delegate string ShowDe ...
所有分類