作者：VW旻shi只吃货8453 | 来源：互联网 | 2023-08-04 14:15
效果展示(尚未完善)chatudpclienttestusingsystem.collections;usingsystem.collections.generic;using
效果展示(尚未完善)
chatudpclienttest
using system.collections;
using system.collections.generic;
using unityengine;
using system.threading;
using system.net;
using system.net.sockets;
using system.text;
using common;
using uiwidgetssamples;
using system;
///
/// 服务端
///
public class chatudpservertest : monobehaviour
{
public string serverip;
//ip地址
public int serverport;
//端口
//1.创建scoket对象 ip port
private thread thread;
private udpclient udpseivic;
public void start()
{
chatview = transform.findchildbyname("chatview").
getcomponent();
//给端口和ip
//构建终结点 ip和一个端口
ipendpoint localep = new
ipendpoint(ipaddress.parse(serverip), serverport);
udpseivic = new udpclient(localep);
thread = new thread(receivemessage);
thread.start();
}
///
/// 接收消息
///
private void receivemessage()
{
while (true)
{
ipendpoint remote = new
ipendpoint(ipaddress.any, 0);
//创建任意终结点
//ref
byte[] date = udpseivic.receive(ref remote);
//receive接收消息 如果没有收到消息 线程阻塞 放在线程中
string msg = encoding.utf8.getstring(date);
//获取的客户都安信息
debug.log(remote.address + "===" + remote.port);
//如果接收客户端的消息,会把任意终结点修改为客户端的终结点
threadcrosshelper.instance.executeonmainthread(() => { showmessage(msg); });
}
}
private chatview chatview;
///
/// 显示消息
///
///
public void showmessage(string msg)
{
chatview.datasource.add(new chatline()
{
username = "annns",
message = msg,
time = datetime.now,
type = chatlinetype.user,
});
}
private void onapplicationquit()
{
udpseivic.close();
thread.abort();
}
}
chatudpservertest
脚本引用的工具箱
- monosingleton (泛型单例)
- threadcrosshelper (为子线程提供，可以在主线程中执行的方法)
- transformhelper(根据名称查找后代元素)
using system.collections;
using system.collections.generic;
using unityengine;
namespace common
{
///
///
///
public class monosingleton : monobehaviour where t : monosingleton
{
//public static t instance
//{
// get;
// private set;
//}
//private void awake()
//{
// instance = this as t;
//}
//按需加载
private static t instance;
public static t instance
{
get
{
if (instance == null)
{
//在场景中查找对象
instance = findobjectoftype();
if (instance == null)
{
//创建游戏对象 附加 脚本对象
new gameobject("singleton of " + typeof(t)).addcomponent();//立即执行awake
}
else
{
instance.initialized();
}
}
return instance;
}
}
protected virtual void initialized()
{
}
[tooltip("是否需要跨场景不销毁")]
public bool isdOntdestroy= true;
//如果管理类自行附加到物体中
//在awake中为instance赋值
protected void awake()
{
if (isdontdestroy)
{
dontdestroyonload(gameobject);
}
if (instance == null)
{
instance = this as t;
instance.initialized();
}
}
}
}monosingleton
using system;
using system.collections;
using system.collections.generic;
using unityengine;
namespace common
{
///
///
///
public class threadcrosshelper : monosingleton
{
///
/// 延迟项
///
class delayeditem
{
public action currentaction { get; set; }
public datetime time { get; set; }
}
private list actionlist;
//private list actionlist;
//private list timelist;
protected override void initialized()
{
base.initialized();
actiOnlist= new list();
}
private void update()
{
for (int i = actionlist.count - 1; i >= 0; i--)
{
//到时间
if (actionlist[i].time <= datetime.now)
{
lock (actionlist)
{
actionlist[i].currentaction();//执行
actionlist.removeat(i);//从列表中移除
}
}
}
}
///
/// 为子线程提供，可以在主线程中执行的方法
///
///
///
public void executeonmainthread(action action, float dealy = 0)
{
delayeditem item = new delayeditem()
{
currentaction = action,
//time = time.time + dealy
time = datetime.now.addseconds(dealy)
};
lock (actionlist)
{
actionlist.add(item);
}
}
}
}
threadcrosshelper
using system.collections;
using system.collections.generic;
using unityengine;
namespace common
{
///
/// 变换组件助手类
///
public static class transformhelper
{
///
/// 未知层级，根据名称查找后代元素
///
///
///
///
public static transform findchildbyname(this transform currenttf, string childname)
{
transform childtf = currenttf.find(childname);
if (childtf != null) return childtf;
//将问题推迟给子物体
for (int i = 0; i {
//在方法体内部，又遇到了相同的问题，所以需要调用自身。
childtf = findchildbyname(currenttf.getchild(i), childname);
if (childtf != null) return childtf;
}
return null;
}
}
}transformhelper
京公网安备 11010802041100号