unity UDP 通信

news/2024/5/18 14:00:34 标签: unity, udp, 游戏引擎

客户端 接收端 :

using System;
using System.IO;
using System.Collections;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;
using UnityEngine.UI;

public class UDPServer : MonoBehaviour
{
    //以下默认都是私有的成员
    Socket socket;//目标socket
    EndPoint clientEnd;//客户端IP
    EndPoint ipEnd;//侦听端口
    public string recvStr; //接收的字符串
    string sendStr;//发送的字符串
    byte[] recvData = new byte[1024];//接收的数据,必须为字节
    byte[] sendData = new byte[1024];//发送的数据,必须为字节
    int recvLen;//接收的数据长度
    Thread connectThread;//连接线程

    // Start is called before the first frame update
    void Start()
    {
        InitSocket();
    }
    private void OnApplicationQuit()
    {
        SocketQuit();

    }
    // Update is called once per frame
    void Update()
    {
        //监听接受数据
        switch (recvStr)
        {
            //接收到的数据
            case "":
                //事件
                break;
               
		  }
    }
    void InitSocket()
    {
        // 定义侦听端口,侦听任何IP  自定义端口号和服务端保持一致
        ipEnd = new IPEndPoint(IPAddress.Any, 8883);//定义套接字类型,在主线程中定义
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//服务端需要绑定ip
        socket.Bind(ipEnd);//定义客户端
        IPEndPoint sender = new IPEndPoint(IPAddress.Any, 8880);//自定义端口号 发送给别的某个电脑的 这台电脑的端口号
        clientEnd = (EndPoint)sender;
        //print("waiting for UDP dgram");
        //开启一个线程连接,必须的,否则主线程卡死
        connectThread = new Thread(new ThreadStart(SocketReceive));
        connectThread.Start();
    }

    public void SocketSend(string sendStr)
    {
        //清空发送缓存
        sendData = new byte[1024];//数据类型转换
        sendData = Encoding.UTF8.GetBytes(sendStr);//发送给指定客户端
        socket.SendTo(sendData, sendData.Length, SocketFlags.None, clientEnd);
    }

    void SocketReceive()
    {
        //进入接收循环
        while (true)
        {
            //对data清零
            recvData = new byte[1024];
            //获取客户端,获取客户端数据,用引用给客户端赋值
            recvLen = socket.ReceiveFrom(recvData, ref clientEnd);
            //print("message from:" + clientEnd.ToString());//打印客户端信息
            // 输出接收到的数据
            recvStr = Encoding.ASCII.GetString(recvData, 0, recvLen);

            print("我是服务器,接收到客户端的数据" + recvStr);
            //将接收到的数据经过处理再发送出去
            sendStr = "From Server333: " + recvStr;
            SocketSend(sendStr);

            //ProcessInformation(recvStr);
            // Debug.Log(sendStr);
        }

    }
    //连接关闭
    void SocketQuit()
    {
        //关闭线程
        if (connectThread != null)
        {
            connectThread.Interrupt();
            connectThread.Abort();
        }
        // 最后关闭socket
        if (socket != null)
            socket.Close();
        print("disconnect-1");
    }

}

服务器 发送端 :

using UnityEngine;
using UnityEngine.UI;
using System.Collections;
using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
//服务器  发送端
public class UDPClient : MonoBehaviour
{
    public string recvStr;
    private string UDPClientIP;
    Socket socket;
    EndPoint serverEnd;
    IPEndPoint ipEnd;

    byte[] recvData = new byte[1024];
    byte[] sendData = new byte[1024];
    int recvLen = 0;
    Thread connectThread;


    private void Awake()
    {

    }
    void Start()
    {
        //IP地址
        UDPClientIP = "192.168.1.16";//自己电脑的ip地址
        UDPClientIP = UDPClientIP.Trim();
        InitSocket();
    }

    //ipEnd = new IPEndPoint(IP地址,端口号);
    //这里用json读取配置方便外部修改
    void InitSocket()
    {
        ipEnd = new IPEndPoint(IPAddress.Parse(UDPClientIP), 8880);// 后面的端口是接收端的端口号
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
        serverEnd = (EndPoint)sender;
        //开启一个线程连接
        connectThread = new Thread(new ThreadStart(SocketReceive));
        connectThread.Start();
    }

    //可以绑定Button发送string类型信息
    public void SocketSend(string sendStr)
    {
        //清空
        sendData = new byte[1024];
        //数据转换
        sendData = Encoding.UTF8.GetBytes(sendStr);
        //发送给指定服务端
        socket.SendTo(sendData, sendData.Length, SocketFlags.None, ipEnd);
    }

    //接收服务器信息
    void SocketReceive()
    {
        while (true)
        {

            recvData = new byte[1024];
            try
            {
                recvLen = socket.ReceiveFrom(recvData, ref serverEnd);
            }
            catch (Exception e)
            {
            }

            //print("信息来自: " + serverEnd.ToString());
            if (recvLen > 0)
            {
                recvStr = Encoding.UTF8.GetString(recvData, 0, recvLen);
                print(recvStr);
            }

            
        }
    }

    //连接关闭
    void SocketQuit()
    {
        //关闭线程
        if (connectThread != null)
        {
            connectThread.Interrupt();
            connectThread.Abort();
        }
        //最后关闭socket
        if (socket != null)
            socket.Close();
    }
    void OnApplicationQuit()
    {
        SocketQuit();
    }

    void Update()
    {
        if (Input.GetKeyDown(KeyCode.K))
        {
            SocketSend("ddddd");
        }
    }

}


http://www.niftyadmin.cn/n/5028648.html

相关文章

网络安全进阶学习第十六课——业务逻辑漏洞介绍

文章目录 一、什么是业务逻辑二、业务逻辑漏洞的成因三、逻辑漏洞的重要性四、业务逻辑漏洞分类五、业务逻辑漏洞——业务授权安全1、未授权访问2、越权访问1) 平行越权(水平越权是指相同权限的不同用户可以互相访问)2) 垂直越权(垂直越权是指…

Pytorch Pytorch+深度学习神经网络相关学习收获

文章目录 一、基础知识二、Pytorch三、如何实现一个神经网络四、pytorch的数据类型五、常用结构六、构造神经网络的相关知识七、数据集处理 一、基础知识 机器学习 本质就是通过 数据答案的数据集 经过机器学习的训练 得到相关的规则进行预测 对应2242243的图像 代表的意思是…

3.SpringEL方法调用实例

SpringEL方法调用实例 文章目录 SpringEL方法调用实例介绍Spring EL在注解的形式SpringEL调用List,Map中的方法**从List中过滤元素****从Map中获取值** Spring EL在XML的形式 介绍 Spring表达式语言(使用SpEL)允许开发人员使用表达式来执行方法和将返回值以注入的方式到属性&a…

JavaScript中的`async`和`await`关键字的作用

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ async关键字⭐ await 关键字3. 错误处理 ⭐ 写在最后 ⭐ 专栏简介 前端入门之旅:探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅!这个专栏是为那些对We…

【Redis】redis实现限流

【Redis】redis实现限流 【一】固定窗口【二】滑动窗口【三】令牌桶【四】深入分析Zset的数据结构 【一】固定窗口 所谓固定窗口限流就是时间窗口的起始和节数时间是固定的,在固定时间段内允许要求的请求数量访问,超过这个数量就会拒绝;当固…

spark临时文件较大问题处理

最近使用spark对ods明细表数据进行清洗,由于清洗的表数据量较大,加上集群只有5个节点,磁盘使用率也上去了,导致每次跑spark任务时,都会产生很多临时文件,是由于内存使用完了,就会把临时数据存到磁盘,导致磁盘使用率超过…

C语言 指针 模拟排序函数 指针数组笔试题上

目标&#xff1a;使用【冒泡排序】的算法&#xff0c;模拟一个排序函数&#xff0c;可以排序任意类型的数据 void print_arr(int arr[], int sz)//打印函数 只能接受整型数组 {int i 0;for (i 0; i < sz; i){printf("%d ", arr[i]);}printf("\n"); }…

基于SpringBoot的点餐系统

基于SpringBootVue的点餐系统、食堂餐厅点餐系统、前后端分离 开发语言&#xff1a;Java数据库&#xff1a;MySQL技术&#xff1a;SpringBoot、Vue、Mybaits Plus、ELementUI工具&#xff1a;IDEA/Ecilpse、Navicat、Maven 【主要功能】 角色&#xff1a;管理员、用户 管理员…