scoket用法

来源:https://www.cnblogs.com/lihongtaoya/archive/2023/03/31/17276968.html
-Advertisement-
Play Games

一.scoket基本介紹 1.scoket簡介(以下是來自chatgpt回答) 1）Socket（套接字）是電腦網路中用於描述主機之間通信的一種機制。它定義了一種標準的介面， 使得應用程式可以利用網路傳輸層提供的服務（如TCP或UDP）進行通信。 2）Socket的作用是在網路應用程式之間提供數據 ...


一.scoket基本介紹

1.scoket簡介(以下是來自chatgpt回答)

1）Socket（套接字）是電腦網路中用於描述主機之間通信的一種機制。它定義了一種標準的介面，

      使得應用程式可以利用網路傳輸層提供的服務（如TCP或UDP）進行通信。

2）Socket的作用是在網路應用程式之間提供數據傳輸服務。通過Socket，應用程式可以將數據發送

      到網路上的另一個應用程式，並從網路上的另一個應用程式接收數據。

3）Socket還提供了一種機制，使得應用程式可以接收來自網路上的請求，並對這些請求進行響應。

     常見的網路應用程式，如Web伺服器、郵件伺服器、FTP伺服器等都使用Socket技術。此外，許多P2P

   （點對點）應用程式，如BitTorrent、eMule等也使用Socket技術。Socket還可以用於實現各種網路應用

      程式，如網路游戲、聊天程式等。

2.建立TCP/IP連接

1）創建一個scoket對象

socket_stream = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

第一個參數表示通信協議類型

AF_INET：適用於網路通信

AF_UNIX：適用於本地進程間通信

第二個參數表示創建什麼連接

SOCK_STREAM：表示tcp/ip連線

SOCK_DGRAM：表示udp連接

2）與服務端建立連接

# 建立連接
ip_port = ("ip", "port")  # 連接的服務端ip和埠
socket_stream.connect(ip_port)  # 建立連接，出錯不返回錯誤碼
socket_stream.connect_ex(ip_port)  # 出錯時返回錯誤碼，不拋異常

connect()和connect_ex()選一個即可

3）發送數據

# 發送數據
data = 'hello'
socket_stream.send(data.encode("utf-8"))  # 發送TCP數據，當send在待發送數據量大於己端緩存區剩餘空間時,數據丟失,不會發完
# or
socket_stream.sendall(data.encode("utf-8"))  # 發送完整的TCP數據(迴圈調用send,sendall在待發送數據量大於己端緩存區剩餘空間時,數據不丟失,迴圈調用send直到發完)

當發送的數據較大時建議使用sendall發送

4）接收TCP數據

# 接收TCP數據。1024(變數)表示每次最多接受1M位元組的數據，recv()函數是一個阻塞函數，沒有要接收的數據時，會一直等待，直到接收到數據或出現錯誤才會返回
response_data = socket_stream.recv(1024)

5）關閉連接

# 關閉連接
socket_stream.close()

3.建立UDP連接

1）創建scoket對象

client_dgram = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

2）發送數據

# 發送數據
ip_port = ('127.0.0.1', 8080)
data = 'Hello'
client_dgram.sendto(data.encode("utf-8"), ip_port)

這裡發送用的是sendto()方法

3）接收數據

# 接收UDP數據數據
data = client_dgram.recvfrom(4096)

4）關閉連接

# 關閉連接
client_dgram.close()

二.使用scoket編寫聊天程式

以下部分代碼參考：https://www.yuque.com/imhelloworld/nov9az/bffcea259d3c96fb17a130acebc12801

聊天程式的話涉及兩個端，既server和click。這裡直接貼代碼了，相關註釋都是代碼里

1）server

import socket
import threading

# 伺服器IP地址和埠號
SERVER_IP = 'IP地址'
SERVER_PORT = 埠號
# 創建一個socket對象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 綁定IP地址和埠號
server_socket.bind((SERVER_IP, SERVER_PORT))
# 設置最大連接數，超過10後拒絕。0的話表示不接受連接，直接拒絕
server_socket.listen(10)
# 客戶端列表
clients = []


def handle_client(client_socket):
    while True:
        try:
            # 接收客戶端發送的消息
            message = client_socket.recv(10240).decode('utf-8')
            print("列印", message)
            if message == 'quert':
                client_socket.send(message.encode('utf-8'))
            else:
                # 廣播消息給所有客戶端
                for c in clients:
                    if c != client_socket:
                        c.send(message.encode('utf-8'))
        except:
            # 發生異常時關閉連接
            client_socket.close()
            clients.remove(client_socket)
            print("發送異常了")
            break


# 迴圈監聽客戶端連接
while True:
    print('Waiting for client connections...')
    # 接受客戶端連接請求,新的客戶端請求時創建一個新的socket，用於處理客戶端的請求，原有的socket繼續監聽其他客戶端的連接請求；
    # 函數是一個阻塞函數，當沒有客戶端連接請求時，會一直等待，直到有客戶端連接請求到達
    client_socket, client_address = server_socket.accept()
    print('客戶socket', client_socket, 'ip和埠', client_address)
    clients.append(client_socket)
    # 創建一個新的線程處理客戶端連接
    client_thread = threading.Thread(target=handle_client, args=(client_socket, ))
    client_thread.start()

2）click

import socket
import threading
import time

# 伺服器IP地址和埠號
SERVER_IP = 'IP地址'
SERVER_PORT = 埠號
# 創建一個socket對象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 連接伺服器
client_socket.connect((SERVER_IP, SERVER_PORT))


def receive():
    while True:
        try:
            # 接收伺服器發送的消息
            message = client_socket.recv(1024).decode('utf-8')
            if message == 'quert':
                client_socket.close()
                break
            print('\n對方回答:', message)
        except:
            # 發生異常時關閉連接
            client_socket.close()
            break


def send():
    while True:
        # 獲取用戶輸入的消息
        message = input()
        if message == 'quert':
            client_socket.close()
            print('連接斷開，通信結束')
            break
        else:
            # 發送消息給伺服器
            client_socket.send(message.encode('utf-8'))


# 創建兩個線程，分別用於接收和發送消息
receive_thread = threading.Thread(target=receive)
send_thread = threading.Thread(target=send)
# 啟動線程
receive_thread.start()
send_thread.start()

這裡需要註意的是，既然是聊天程式，那麼肯定涉及兩個click，兩個click代碼一致即可，運行時先運行server，後運行click，之後就可以在Terminal下建立對話了。

以上是click在同一臺電腦上，若不在同一臺電腦的，建立對話需在同一個區域網下，ip地址在dos視窗下輸入ipconfig\all即可查看，埠號可隨便填個，只要不被占用就行。

三.scoket+chatgpt建立搜索對話框

1）獲取chatgpt搜索介面，這裡就直接貼代碼了

def api(params, tokened="token"):
    url = "https://api.aigcfun.com/api/v1/text?key=" + tokened
    data = {"messages": [{"role": "system", "content": "請以markdown的形式返回答案"},
                         {"role": "user", "content": params}], "tokensLength": 32, "model": "gpt-3.5-turbo"}
    response_data = requests.post(url=url, json=data)
    return response_data.json()["choices"][0]["text"]

params為用戶問的問題，return返回的是chatgpt回答的答案

2）獲取到chatgpt的回答內容後返回給服務端

def receive():
    while True:
        try:
            # 接收伺服器發送的消息
            message = client_socket.recv(1024).decode('utf-8')
            data_message = api(message)
            while data_message == None:  # 由於chatgpt有時響應的比較慢，這裡需添加個迴圈判斷
                continue
            # if data_message == '您今日使用次數已達上限，請明日再試！':
            #     data_message = api(params=message, tokened=token())

            client_socket.send(data_message.encode('utf-8'))  # 發送chatgpt回答的問題給服務端
        except:
            # 發生異常時關閉連接
            client_socket.close()
            break

3）目前chatpgt雖是免費的，但每天都有次數限制，所以可以請求獲取token的介面來獲取新的token。這裡就不做演示了（hhhhhh.........）

 


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

-Advertisement-
Play Games
更多相關文章
  • odoo 開發入門教程系列-模型之間的關係(Relations Between Models)
    模型之間的關係(Relations Between Models) 上一章介紹了為包含基本欄位的模型創建自定義視圖。然而，在任何真實的業務場景中，我們都需要不止一個模型。此外，模型之間的鏈接是必要的。人們可以很容易地想象一個模型包含客戶，另一個模型則包含用戶列表。你可能需要參考任何現有業務模型上的客 ...
  • 介紹ChatGPT：基於GPT-3.5的強大自然語言處理工具
    ChatGPT是一個基於GPT-3.5架構的自然語言處理工具，它具有文本生成、文本分類、對話生成等多種能力。作為一種強大的自然語言處理工具，ChatGPT可以應用於智能客服、智能問答、內容創作等多個領域。如果您對ChatGPT感興趣，可以通過關註本公眾號瞭解更多信息，並體驗基於ChatGPT的小程式... ...
  • Spring（Ioc和Bean的作用域）
    Spring Spring為簡化開發而生，讓程式員只關心核心業務的實現，儘可能的不在關註非業務邏輯代碼（事務控制，安全日誌等）。 1，Spring八大模塊 這八大模塊組成了Spring 1.1 Spring Core模塊 這是Spring框架的最基礎的部分，它提供了依賴註入（DependencyIn ...
  • React Native 備忘清單_開發速查表分享
    React Native 備忘清單 適合初學者的綜合 React Native 備忘清單，在開始 React Native 之前需要先掌握 react 庫入門，為開發人員分享快速參考備忘單。 React Native (簡稱RN)是Facebook於2015年4月開源的跨平臺移動應用開發框架，是Fa ...
  • React 備忘清單_開發速查表分享
    React 備忘清單 IT寶庫整理適合初學者入門的React開發速查備忘清單，為開發人員分享快速參考備忘單。 React是用於構建用戶界面的JavaScript庫，起源於Facebook的內部項目，該公司對市場上所有 JavaScript MVC框架都不滿意，決定自行開發一套，用於架設Instagr ...
  • Spark源碼解析（一）：RDD之Transfrom運算元
    一、延遲計算 RDD 代表的是分散式數據形態，因此，RDD 到 RDD 之間的轉換，本質上是數據形態上的轉換（Transformations） 在 RDD 的編程模型中，一共有兩種運算元，Transformations 類運算元和 Actions 類運算元。開發者需要使用 Transformations ...
  • php Trait基類use trait,本類不use
    一 回顧trait使用 https://blog.csdn.net/bushuwei/article/details/103514174發現之前本人說明很模糊，自己居然不知道為什麼其實這裡的$c,就是class B再次回顧邏輯 二 分析 self和static區別說的沒毛病 Trait基類use t ...
  • day3 函數的定義和調用，練習編寫簡單的程式（記錄1）
    一、函數的定義 可以分為以下兩種： 1、函數聲明和函數定義分離 這種方法將函數聲明和函數定義分開，通常在頭文件中先聲明函數原型，然後在源文件中實現函數定義。 例如，頭文件 example.h 中聲明瞭一個函數 add： #ifndef EXAMPLE_H #define EXAMPLE_H int ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類