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

相关文章

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)只包含了头文件,不依

poj 3181 网络流,建图。

题意: 农夫约翰为他的牛准备了F种食物和D种饮料。 每头牛都有各自喜欢的食物和饮料,而每种食物和饮料都只能分配给一头牛。 问最多能有多少头牛可以同时得到喜欢的食物和饮料。 解析: 由于要同时得到喜欢的食物和饮料,所以网络流建图的时候要把牛拆点了。 如下建图: s -> 食物 -> 牛1 -> 牛2 -> 饮料 -> t 所以分配一下点: s  =  0, 牛1= 1~

poj 3068 有流量限制的最小费用网络流

题意: m条有向边连接了n个仓库,每条边都有一定费用。 将两种危险品从0运到n-1,除了起点和终点外,危险品不能放在一起,也不能走相同的路径。 求最小的费用是多少。 解析: 抽象出一个源点s一个汇点t,源点与0相连,费用为0,容量为2。 汇点与n - 1相连,费用为0,容量为2。 每条边之间也相连,费用为每条边的费用,容量为1。 建图完毕之后,求一条流量为2的最小费用流就行了