Unity3D网络之Socket聊天室初探

2024-08-29 03:48

本文主要是介绍Unity3D网络之Socket聊天室初探,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

首先创建一个服务端程序,这个程序就用VS的控制台程序做就行了。

using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.Net.Sockets;  
   
namespace SocketServer  
{  
    class Program  
    {  
        const int Port = 20000; //设置连接端口  
        static void Main(string[] args)  
        {  
            // 初始化服务器IP  
            System.Net.IPAddress SocketIP = System.Net.IPAddress.Parse("127.0.0.1");  
            // 创建TCP侦听器  
            TcpListener listener = new TcpListener(SocketIP, Port);  
            listener.Start();  
            // 显示服务器启动信息  
            Console.WriteLine("服务开启中...\n");  
            // 循环接受客户端的连接请求  
            while (true)  
            {  
                ChatClient client = new ChatClient(listener.AcceptTcpClient());  
   
                // 显示连接客户端的IP与端口  
                Console.WriteLine(client._clientIP + " 加入...\n");  
            }  
        }  
    }  
}



using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.Collections;  
using System.Net.Sockets;  
   
namespace SocketServer  
{  
    class ChatClient  
    {  
        public static Hashtable ALLClients = new Hashtable(); // 客户列表  
        private TcpClient _client;  // 客户端实体  
        public string _clientIP;   // 客户端IP  
        private string _clientNick; // 客户端昵称  
        private byte[] data;        // 消息数据  
   
        private bool ReceiveNick = true;  
   
        public ChatClient(TcpClient client)  
        {  
            this._client = client;  
            this._clientIP = client.Client.RemoteEndPoint.ToString();  
   
            // 把当前客户端实例添加到客户列表当中  
            ALLClients.Add(this._clientIP, this);  
   
            data = new byte[this._client.ReceiveBufferSize];  
   
            // 从服务端获取消息  
            client.GetStream().BeginRead(data, 0, System.Convert.ToInt32(this._client.ReceiveBufferSize), ReceiveMessage, null);  
        }  
   
        // 从客戶端获取消息  
        public 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 = System.Text.Encoding.ASCII.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 + "离开聊天室");  
            }  
        }  
   
        // 向客戶端发送消息  
        public void sendMessage(string message)  
        {  
            try 
            {  
                System.Net.Sockets.NetworkStream ns;  
                lock (this._client.GetStream())  
                {  
                    ns = this._client.GetStream();  
                }  
                // 对信息进行编码  
                byte[] bytesToSend = System.Text.Encoding.ASCII.GetBytes(message);  
                ns.Write(bytesToSend, 0, bytesToSend.Length);  
                ns.Flush();  
            }  
            catch (Exception ex)  
            {  
   
            }  
        }  
   
        // 向客户端广播消息  
        public void Broadcast(string message)  
        {  
            Console.WriteLine(message);  
   
            foreach (DictionaryEntry c in ALLClients)  
            {  
                ((ChatClient)(c.Value)).sendMessage(message + Environment.NewLine);  
            }  
        }  
   
    }  
}


这个比较简单啊,我就直接拷贝了别人的代码,比较好理解,适合新手~~~(如有侵犯版权,请私信联系我)

    接下来就是Unity这边的代码了~

    代码如下:


using UnityEngine;  
using System.Collections;  
using System;  
using System.Collections.Generic;  
using System.ComponentModel;  
using System.Text;  
using System.Net.Sockets;  
   
public class ScoketClient : MonoBehaviour  
{  
    const int Port = 20000;//端口号与服务端端口对应  
    private TcpClient client;  
    byte[] data;  
   
    public string UserName = "";//用户名  
    public string message = "";//聊天内容  
    public string sendMsg = "";//输入框  
   
    void OnGUI()  
    {  
        UserName = GUI.TextField(new Rect(10, 10, 100, 20), UserName);  
        message = GUI.TextArea(new Rect(10, 40, 300, 200), message);  
        sendMsg = GUI.TextField(new Rect(10, 250, 210, 20), sendMsg);  
   
        if (GUI.Button(new Rect(120, 10, 80, 20), "连接服务器"))  
        {  
            this.client = new TcpClient();  
            this.client.Connect("127.0.0.1", Port);  
            data = new byte[this.client.ReceiveBufferSize];  
            SendSocket(UserName);  
            this.client.GetStream().BeginRead(data, 0, System.Convert.ToInt32(this.client.ReceiveBufferSize), ReceiveMessage, null);  
        };  
   
        if (GUI.Button(new Rect(230, 250, 80, 20), "发送"))  
        {  
            SendSocket(sendMsg);  
            sendMsg = "";  
        };  
    }  
   
    public void SendSocket(string message)  
    {  
        try 
        {  
            NetworkStream ns = this.client.GetStream();  
            byte[] data = System.Text.Encoding.ASCII.GetBytes(message);  
            ns.Write(data, 0, data.Length);  
            ns.Flush();  
        }  
        catch (Exception ex)  
        {  
              
        }  
    }  
   
    public void ReceiveMessage(IAsyncResult ar)  
    {  
        try 
        {  
            int bytesRead;  
            bytesRead = this.client.GetStream().EndRead(ar);  
            if (bytesRead < 1)  
            {  
                return;  
            }  
            else 
            {  
                message += System.Text.Encoding.ASCII.GetString(data, 0, bytesRead);  
            }  
            this.client.GetStream().BeginRead(data, 0, System.Convert.ToInt32(this.client.ReceiveBufferSize), ReceiveMessage, null);  
        }  
        catch (Exception ex)  
        {  
   
        }  
    }  
}


这样就可以了~先开启服务端,然后在用客户端连接。这里用的编码是ASCII。如果想用中文的话改成UTF-8,或者GB2312。

这篇关于Unity3D网络之Socket聊天室初探的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1116761

相关文章

Linux系统配置NAT网络模式的详细步骤(附图文)

《Linux系统配置NAT网络模式的详细步骤(附图文)》本文详细指导如何在VMware环境下配置NAT网络模式,包括设置主机和虚拟机的IP地址、网关,以及针对Linux和Windows系统的具体步骤,... 目录一、配置NAT网络模式二、设置虚拟机交换机网关2.1 打开虚拟机2.2 管理员授权2.3 设置子

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

SpringBoot使用OkHttp完成高效网络请求详解

《SpringBoot使用OkHttp完成高效网络请求详解》OkHttp是一个高效的HTTP客户端,支持同步和异步请求,且具备自动处理cookie、缓存和连接池等高级功能,下面我们来看看SpringB... 目录一、OkHttp 简介二、在 Spring Boot 中集成 OkHttp三、封装 OkHttp

Linux系统之主机网络配置方式

《Linux系统之主机网络配置方式》:本文主要介绍Linux系统之主机网络配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、查看主机的网络参数1、查看主机名2、查看IP地址3、查看网关4、查看DNS二、配置网卡1、修改网卡配置文件2、nmcli工具【通用

使用Python高效获取网络数据的操作指南

《使用Python高效获取网络数据的操作指南》网络爬虫是一种自动化程序,用于访问和提取网站上的数据,Python是进行网络爬虫开发的理想语言,拥有丰富的库和工具,使得编写和维护爬虫变得简单高效,本文将... 目录网络爬虫的基本概念常用库介绍安装库Requests和BeautifulSoup爬虫开发发送请求解

如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

《如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解》:本文主要介绍如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别的相关资料,描述了如何使用海康威视设备网络SD... 目录前言开发流程问题和解决方案dll库加载不到的问题老旧版本sdk不兼容的问题关键实现流程总结前言作为

SSID究竟是什么? WiFi网络名称及工作方式解析

《SSID究竟是什么?WiFi网络名称及工作方式解析》SID可以看作是无线网络的名称,类似于有线网络中的网络名称或者路由器的名称,在无线网络中,设备通过SSID来识别和连接到特定的无线网络... 当提到 Wi-Fi 网络时,就避不开「SSID」这个术语。简单来说,SSID 就是 Wi-Fi 网络的名称。比如

Java实现任务管理器性能网络监控数据的方法详解

《Java实现任务管理器性能网络监控数据的方法详解》在现代操作系统中,任务管理器是一个非常重要的工具,用于监控和管理计算机的运行状态,包括CPU使用率、内存占用等,对于开发者和系统管理员来说,了解这些... 目录引言一、背景知识二、准备工作1. Maven依赖2. Gradle依赖三、代码实现四、代码详解五

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor

ASIO网络调试助手之一:简介

多年前,写过几篇《Boost.Asio C++网络编程》的学习文章,一直没机会实践。最近项目中用到了Asio,于是抽空写了个网络调试助手。 开发环境: Win10 Qt5.12.6 + Asio(standalone) + spdlog 支持协议: UDP + TCP Client + TCP Server 独立的Asio(http://www.think-async.com)只包含了头文件,不依