網站首頁 編程語言 正文
本文實例為大家分享了Unity實現多人聊天工具的具體代碼，供大家參考，具體內容如下
代碼1 : 服務端代碼
using UnityEngine;
using System.Net.Sockets;
using System.Net;
using System.Threading;
public class ChatServer : MonoBehaviour
{
? ? ? ?// 設置連接端口
? ? ? ?const int portNo = 500;
? ? ? ?string m_ServerIP = "";
? ? ? ?// Use this for initialization
? ? ? ?void Start ()
? ? ? ?{
? ? ? ? ? ? ? m_ServerIP = Network.player.ipAddress;//獲取本機服務器的IP
? ? ? ? ? ?print("服務器ＩＰ："+m_ServerIP);
? ? ? ?//開啟新的線程來執行TCP的監聽
? ? ? ? ? ? ? myThread.Start ();
? ? ? ? //支持后臺運行避免最小化后不運行
? ? ? ? ? ? ? Application.runInBackground = true;
? ? ? ?}
? ? ? ?private void ListenClientConnect ()
? ? ? ?{
? ? ? ? ? ? ? Debug.Log("正在啟動服務器！");
? ? ? ? // 初始化服務器IP
? ? ? ? ? ?IPAddress localAdd = IPAddress.Parse(m_ServerIP);
? ? ? ? ? ? ? // 創建TCP偵聽器
? ? ? ? ? ? ? TcpListener listener = new TcpListener (localAdd, portNo);
? ? ? ? ? ? ? listener.Start ();
? ? ? ? ? ?Debug.Log("服務器正在運行中.......");
? ? ? ? ? ?//溫馨提示：建議使用Windows電腦運行服務器，如果是Mac系統一定要看到打印這句話服務器才啟動起來了，否則服務器表示沒有啟動
? ? ? ? // 循環接受客戶端的連接請求
? ? ? ? while (true) {
? ? ? ? ? ? //編寫各個客戶端的類，只要監聽到有IP連接服務器，就實例化對應的客戶端
? ? ? ? ? ? ? ? ? ? ?ChatClient user = new ChatClient (listener.AcceptTcpClient());
? ? ? ? ? ? ? ? ? ? ?// 顯示連接客戶端的IP與端口【只要有新的客戶端連接進來就會打印打控制臺誰進來了】
? ? ? ? ? ? ? ? ? ? ?print (user._clientIP + " 加入服務器\n");
? ? ? ? ? ? ? }
? ? ? ?}
}代碼2 :?客戶端與服務端交互
using UnityEngine;
using System.Collections;
using System.Net.Sockets;
using System;
using System.Text;
//各個客戶端自身應該有的邏輯【進入服務器離開服務器等】
public class ChatClient : MonoBehaviour
{
? ? ? ? static Hashtable ALLClients = new Hashtable ();// 客戶端列表
? ? private TcpClient _client;// 客戶端實體
? ? ?public string _clientIP;// 客戶端IP
? ? private string _clientNick;// 客戶端昵稱
? ? private byte[] data;// 消息數據
? ? private bool ReceiveNick = true;//是否從客戶端接受到他的昵稱[消息分割標識]
? ? ? ?void Awake ()
? ? ? ?{
? ? ? ? ? ? ? Application.runInBackground = true;
? ? ? ?}
? ? //由服務器創建實例
? ? ? ?public ChatClient (TcpClient client)
? ? ? ?{
? ? ? ? //客戶端實體對象
? ? ? ? ? ? ? this._client = client;
? ? ? ? ? ? ? this._clientIP = client.Client.RemoteEndPoint.ToString ();
? ? ? ? ? ? ? // 把當前客戶端實例添加到客戶列表當中
? ? ? ? ? ? ? //第一個參數時IP，第二個為對應客戶端
? ? ? ? ? ? ? ALLClients.Add (this._clientIP, this);
? ? ? ? ? ? ? data = new byte[this._client.ReceiveBufferSize];
? ? ? ? ? ? ? // 從服務端獲取消息
? ? ? ? ? ? ? client.GetStream ().BeginRead (data, 0, System.Convert.ToInt32 (this._client.ReceiveBufferSize), ReceiveMessage, null);
? ? ? ?}
? ? ? ?// 從客戶端獲取消息
? ? ? ? void ReceiveMessage (IAsyncResult ar)
? ? ? ?{
? ? ? ? ? ? ? int bytesRead;
? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ?lock (this._client.GetStream()) {
? ? ? ? ? ? ? ? ? ? ? ? ? ?bytesRead = this._client.GetStream ().EndRead (ar);
? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? //沒有讀到數據說明這個客戶端已經掉線
? ? ? ? ? ? ? ? ? ? ?if (bytesRead < 1) {
? ? ? ? ? ? ? ? ? ? ? ? ? ?ALLClients.Remove (this._clientIP);
? ? ? ? ? ? ? ? ? ? ? ? ? ?//廣播
? ? ? ? ? ? ? ? ? ? ? ? ? ?Broadcast (this._clientNick + " 已經離開服務器");//已經離開服務器
? ? ? ? ? ? ? ? ? ? ? ? ? ?return;
? ? ? ? ? ? ? ? ? ? ?} else {
? ? ? ? ? ? ? ? ? ? ? ? ? ?string messageReceived = Encoding.UTF8.GetString (data, 0, bytesRead);
? ? ? ? ? ? ? ? //這個開關很關鍵，讀取到了發送進來的數據后，默認是收到了對應客戶端的昵稱的，將這個客戶端第一次發來的信息作為昵稱，以后的都是他發消息
? ? ? ? ? ? ? ? ? ? ? ? ? ?if (ReceiveNick) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? this._clientNick = messageReceived;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Broadcast (this._clientNick + " 已經進入服務器");//已經進入服務器
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ReceiveNick = false;
? ? ? ? ? ? ? ? ? ? ? ? ? ?} else {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Broadcast (this._clientNick + ":" + messageReceived);
? ? ? ? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ? ? ? ?lock (this._client.GetStream()) {
? ? ? ? ? ? ? ? //尾遞歸處理
? ? ? ? ? ? ? ? ? ? ? ? ? ?this._client.GetStream ().BeginRead (data, 0, System.Convert.ToInt32 (this._client.ReceiveBufferSize), ReceiveMessage, null);
? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? } catch (Exception ex) {
? ? ? ? ? ? ? ? ? ? ?ALLClients.Remove (this._clientIP);
? ? ? ? ? ? ? ? ? ? ?Broadcast (this._clientNick + " 已經離開服務器");//已經離開服務器
? ? ? ? ? ? ? }
? ? ? ?}
? ? ? ?// 向一個客戶端發送消息
? ? ? ? void sendMessage (string message)
? ? ? ?{
? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ?NetworkStream ns;
? ? ? ? ? ? ? ? ? ? ?lock (this._client.GetStream()) {
? ? ? ? ? ? ? ? ? ? ? ? ? ?ns = this._client.GetStream ();
? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? ? ? ? ? ?// 對信息進行編碼，寫入流，別忘記沖刷趕緊緩沖
? ? ? ? ? ? ? ? ? ? ?byte[] bytesToSend = Encoding.UTF8.GetBytes (message);
? ? ? ? ? ? ? ? ? ? ?ns.Write (bytesToSend, 0, bytesToSend.Length);
? ? ? ? ? ? ? ? ? ? ?ns.Flush ();
? ? ? ? ? ? ? } catch (Exception ex) {
? ? ? ? ? ? ? ? ? ? ?Debug.Log ("Error:" + ex);
? ? ? ? ? ? ? }
? ? ? ?}
? ? ? ?// 向所有客戶端廣播消息
? ? ? ? void Broadcast (string message)
? ? ? ?{
? ? ? ? ? ? ? Debug.Log (message);//打印消息
? ? ? ? //向在服務器中連接的所有客戶端發送最新消息
? ? ? ? ? ? ? foreach (DictionaryEntry c in ALLClients) {
? ? ? ? ? ? ? ? ? ? ?((ChatClient)(c.Value)).sendMessage (message + Environment.NewLine);
? ? ? ? ? ? // ? \r是回車，英文是Carriage return ?運輸返回 ? ? ? ? ? ?B位置
? ? ? ? ? ? // ? \n是換行，英文是New line ? ? ? ? ? ? ? ? ? ? ? ? ? ?C位置
? ? ? ? ? ? // ? Enter = 回車+換行(\r\n) 確認按鍵 ? ? ? ? ? ? ? ? ? ?D位置
? ? ? ? ? ? //在 Windows 環境中，C# 語言 Environment.NewLine == "\r\n"
? ? ? ? ? ? // B ? ? ? A
? ? ? ? ? ? // D ? ? ? C
? ? ? ? ? ? // 當前編輯光標位置：A
? ? ? ? ? ? //機械打字機有回車和換行兩個鍵作用分別是:
? ? ? ? ? ? //換行就是把滾筒卷一格，不改變水平位置。
? ? ? ? ? ? //回車就是把水平位置復位，不卷動滾筒。
? ? ? ? }
? ? }
}代碼3 :?客戶端與UI交互
using UnityEngine;
using System.Net.Sockets;
using System;
using System.Text;
using UnityEngine.UI;
//各個客戶端聊天的UI交互
public class ClientHandler : MonoBehaviour
{
? ? ? ?const int portNo = 500;
? ? ? ?private TcpClient _client;
? ? ? ?private ?byte[] data;
? ? ? ? string nickName = "";
? ? ? ? string message = "";
? ? ? ? string sendMsg = "";
? ? ? ?[SerializeField]InputField m_NickInput;
? ? ? ?[SerializeField]InputField m_SendMsgInput;
? ? ? ?[SerializeField]Text m_ShowMessageText;
? ? [SerializeField] InputField m_IPInput;
? ? ? ?void Update ()
? ? ? ?{
? ? ? ? ? ? ? nickName = m_NickInput.text;
? ? ? ? ? ? ? m_ShowMessageText.text = message;
? ? ? ? ? ? ? sendMsg = m_SendMsgInput.text;
? ? ? ?}
? ? //連接服務器按鈕
? ? ? ?public void ConBtnOnClik ()
? ? ? ?{
? ? ? ? ? ?if (m_IPInput.text != "" || m_IPInput.text != null)
? ? ? ? ? ?{
? ? ? ? ? ? //真正的當前客戶端
? ? ? ? ? ? ? ?this._client = new TcpClient();
? ? ? ? ? ? ? ?//連接服務器的IP和端口
? ? ? ? ? ? ? ?this._client.Connect(m_IPInput.text, portNo);
? ? ? ? ? ? ? ?//獲取緩沖區的位元組數目，即緩存區的大小
? ? ? ? ? ? ? ?data = new byte[this._client.ReceiveBufferSize];//避免去去死，比如有些同志寫成1024
? ? ? ? ? ? ? ?//點擊了連接服務器按鈕后就將昵稱也發送過去
? ? ? ? ? ? ? ?SendMyMessage(nickName);
? ? ? ? ? ? //當前客戶端開始去讀取數據流
? ? ? ? ? ? ? ?this._client.GetStream()
? ? ? ? ? ? ? ? ? ?.BeginRead(data, 0, System.Convert.ToInt32(this._client.ReceiveBufferSize), ReceiveMessage, null);
? ? ? ? ? ?}
? ? ? ? ? ?else
? ? ? ? ? ?{
? ? ? ? ? ? ? ?Debug.Log("請輸入正確的IP");
? ? ? ? ? ?}
? ? ? ?}
? ? //發送消息按鈕
? ? ? ?public void SendBtnOnClik ()
? ? ? ?{
? ? ? ? //每次將輸入消息發送到服務器，并制空輸入框
? ? ? ? ? ? ? SendMyMessage (sendMsg);
? ? ? ? ? ? ? m_SendMsgInput.text = "";
? ? ? ?}
? ? ? ?/// <summary>
? ? ? ?/// 向服務器發送數據（發送聊天信息）
? ? ? ?/// </summary>
? ? ? ?/// <param name="message"></param>
? ? ? ? void SendMyMessage (string message)
? ? ? ?{
? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ?NetworkStream ns = this._client.GetStream ();
? ? ? ? ? ? //因為我們現在只做文本信息的傳輸，所以這里使用UTF編碼來寫入和識別
? ? ? ? ? ? ? ? ? ? ?byte[] data = Encoding.UTF8.GetBytes (message);
? ? ? ? ? ? ? ? ? ? ?ns.Write (data, 0, data.Length);
? ? ? ? ? ? ? ? ? ? ?ns.Flush ();//沖刷趕緊buffer緩沖，準備下次再接受新的數據
? ? ? ? ? ? ? } catch (Exception ex) {
? ? ? ? ? ? ? ? ? ? ?Debug.Log ("Error:" + ex);
? ? ? ? ? ? ? }
? ? ? ?}
? ? ? ?/// <summary>
? ? ? ?/// 接收服務器的數據（聊天信息）
? ? ? ?/// </summary>
? ? ? ?/// <param name="ar"></param>
? ? ? ? void ReceiveMessage (IAsyncResult ar)
? ? ? ?{
? ? ? ? ? ? ? try {
? ? ? ? ? ? //當上面的讀取方法執行完畢后，會自動回調這個方法
? ? ? ? ? ? ? ? ? ? ?int bytesRead = this._client.GetStream ().EndRead (ar);//讀取完畢
? ? ? ? ? ? ? ? ? ? ?if (bytesRead < 1) {
? ? ? ? ? ? ? ? //說明沒有讀取到任何信息
? ? ? ? ? ? ? ? ? ? ? ? ? ?return;
? ? ? ? ? ? ? ? ? ? ?} else {
? ? ? ? ? ? ? ? //讀取到文本信息后使用UTF編碼解碼 ? ，并連續拼接起來
? ? ? ? ? ? ? ? ? ? ? ? ? ?message += Encoding.UTF8.GetString (data, 0, bytesRead);
? ? ? ? ? ? ? ? ? ? ?}
? ? ? ? ? ? //再次去讀取信息
? ? ? ? ? ? _client.GetStream ().BeginRead (data, 0, Convert.ToInt32 (_client.ReceiveBufferSize), ReceiveMessage, null);
? ? ? ? ? ? ? } catch (Exception ex) {
? ? ? ? ? ? ? ? ? ? ?print ("Error:" + ex);
? ? ? ? ? ? ? }
? ? ? ?}
}原文鏈接：https://blog.csdn.net/jinxiul5/article/details/82115735
相關推薦
- 2022-10-02 C#利用FileSystemWatcher實時監控文件的增加,修改,重命名和刪除_C#教程
- 2022-02-09 QT5實現UDP通信的示例代碼_C 語言
- 2022-08-03 python中multiprosessing模塊的Pool類中的apply函數和apply_asyn
- 2022-07-11 docker搭建redis 主從哨兵集群
- 2024-01-12 間隙鎖(Gap Lock)
- 2022-12-24 Python創建增量目錄的代碼實例_python
- 2023-02-26 pandas的apply函數用法詳解_python
- 2022-07-15 python優雅實現代碼與敏感信息分離的方法_python
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版（
- Linux 中運行的top命令 怎么退出？
- MySQL 中decimal 的用法？ 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符，流程控制 Flo
- 1. Int 和Integer 的區別，Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤：Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密？
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串（SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列，發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支
提供CDN加速