unity UDP 通信

news2024/9/23 5:28:19

客户端 接收端 :

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.coloradmin.cn/o/1013204.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

轻松剪辑大量视频,批量AI智剪让你省时又省力

在今天的数字时代,视频已经成为了信息传播的主要方式之一。无论是个人用户还是专业人士,都需要对视频进行剪辑以满足各种需求。但是,对于一些需要处理大量视频的情况,传统的剪辑方式往往费时费力。幸运的是,有一种名为…

利用芯片74hc165为单片机增加输入扩展端口proteus仿真arduino

我们前面的博文《输入端口少如何扩展?74hc148或74ls148级联在arduino中实现16转4的应用》介绍了148,148输入后可以立即输出到数码管,可以说它是自带编BCD编码器的。而今天这里我们主要介绍的74hc165是没有编码器,这里我们以proteus为仿真环境…

sqlserver存储过程报错:当前事务无法提交,而且无法支持写入日志文件的操作。请回滚该事务。

现象: 系统出现异常,手动执行过程提示如上。 问题排查: 1.直接执行的过程事务挂起(排除) 2.重启数据库实例(重启后无效) 3.过程中套用过程,套用的过程中使用事务,因为…

计算机丢失mfc140u.dll怎么办,mfc140u.dll丢失的解决方法分享

随着科技的飞速发展,计算机已经成为了人们日常生活和工作中不可或缺的工具。然而,在使用计算机的过程中,用户可能会遇到各种问题,其中计算机丢失 mfc140u.dll 无法运行的问题就是一个比较常见的困扰。小编将从以下几个方面对这个问…

Ubuntu22.04配置WiFi

Ubuntu22.04配置WiFi 注意:在/etc/netplan/​下的配置文件,格式一定要正确,否则用sudo netplan try​的时候会报错 一、查看无线网卡的名称 //choice-1 ls /sys/class/net//choice-2 ip a//choice-3 ifconfig -a‍ 二、修改配置文件 文件…

基于JAVA+SSM+微信小程序+MySql的图书捐赠管理系统设计与实现

✌全网粉丝20W,csdn特邀作者、博客专家、CSDN新星计划导师、java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取项目下载方式🍅 一、项目背景介绍: 在当今社会&#xff0…

ChatGPT Code Interpreter实用教程,14种方法助你数据分析绘图

目录 1. 设置解释一下上传的文档高难度:根据文档创建10个可视化图表代表不同的数据。 1. 设置 勾选 Advanced data analysis 选择GPT-4,下面已经出现了代码解释器 点击 解释一下上传的文档 Prompt:请用简单的语言,解释一下该…

eMAG、ManoMano、Allegro店铺如何快速出单?自己产号测评的重要性

对于一个新开的店铺而言,首先要做的就是想办法让自己的店铺快速出单,只有有订单了,才能够稳住局势,才能够让自己店铺在市场上有立足的资本。 不过对于一个店铺而言,要想做到快速出单是很难的,尤其是一个新…

Java学习——基本语法笔记

1. 基本框架 Java中的程序是以类为单位,所以所有的程序都必须在class定义范畴之内, 类的定义有两种形式: class 类名称{程序代码 } public class 类名称{程序代码 } ⭐public class定义类,要求文件名称与类名称一致 ⭐如果现在没有…

⑩ vue新特性

ref 或者reactive ref相当于data methods props和context props !!!setup中没有this关键字,使用context(简写:ctx)就是this 在steup中使用生命周期函数 Provide / Inject 1、原来是 a传…

CANopen扫盲

目录 1 概述 2 CANopen 的基本概念 3 基于对象的通信 4 对象字典 5 EDS 文件 6 服务数据对象(SDO) 7 过程数据对象(PDO) 8 网络管理(NMT)概述 9 守护与心跳 10 紧急消息 1 概述 CANopen是基于CAN…

CVPR 2024 截稿时间

CVPR 2024 截稿时间为2023年11月10日,小伙伴们注意提前写好论文,及时投稿,祝大家都能高中!

Git 版本控制系统 笔记

概念:一个免费开源,分布式的代码版本控制系统,帮助开发团队维护代码 作用:记录代码内容,切换代码版本,多人开发时高效合并代码内容【团队开发同一个项目的代码版本管理】 1、Git 安装 之前写了&#xff0…

【视觉SLAM入门】7.4.后端优化 --- 基于位姿图和基于因子图

"议论平恕,无所向背” 1. 位姿图1.1 具体做法1.2 小结 2. 因子图2.1 具体做法2.1.1 贝叶斯网络2.1.2 因子图2.1.3 更具体的因子图2.1.4 增量的求解方法 引入: 上节BA将位姿和路标都作为优化的节点,H矩阵也告诉我们路标远大于位姿&#…

初识Mybatis(二)动态SQL、缓存和逆向工程

动态SQL Mybatis框架的动态SQL技术是一种根据特定条件动态拼装SQL语句的功能,它存在的意义是为了解决拼接SQL语句字符串时的痛点问题。 (比如多条件查询的设置,实现判空等) 1、if 创建DynamicSQLMapper接口,DynamicSQL…

C语言基础知识点(六)二维数组指针和地址

#include <stdio.h>int main() {int a[2][3] {2, 4, 6,8, 10, 12};printf("a:%p, a1:%p\n", a, a 1); // 相差3*sizeof&#xff08;int&#xff09;12&#xff0c;二维数组名是一个指向每一行的指针&#xff0c;a:0061FF08, a1:0061FF14prin…

Redis Part1

单体架构&#xff1a;一台Web服务器、一台数据库服务器。 1.了解NoSql 什么是Nosql&#xff1f; NoSQL&#xff0c;即Not-Only-SQL&#xff0c;意思就是我们干事情不能只用SQL&#xff0c;泛指非关系型的数据库&#xff01;NoSQL定位&#xff1a;作为关系型数据库的补充&am…

信息安全三级概述

信息安全三级概述

C语言之const

C语言之const const修饰全局变量 此时全局变量只能使用但是不能修改&#xff0c; 如果直接拿全局变量修改值&#xff0c;编译直接报错 如果使用全局变量的地址修改值&#xff0c;运行时程序异常结束 const修饰普通局部变量 可以读取变量的值 不能直接通过变量进行修改值&a…

开源库源码分析:Okhttp源码分析(一)

开源库源码分析&#xff1a;OkHttp源码分析 导言 接下来就要开始分析一些常用开源库的源码了&#xff0c;作为最常用的网络请求库&#xff0c;OkHttp以其强大的功能深受Android开发者的喜爱&#xff08;比如说我&#xff09;&#xff0c;还有对该库进行二次封装而成的热门库&a…