同一不加密Wi-Fi下创建聊天室

开启服务器,客户端通过Socket来寻找服务器的IP地址,脚本直接过摄像机就能运行,打包。
using UnityEngine;
using System.Collections;
using UnityEngine.Networking;

using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.Text;

public class Chat : MonoBehaviour {
public string ip = "127.0.0.1";
public int port=4865;
private int connectCount = 15;
private bool useNAT=false;//是否启用网络地址转换器
private string recMes="";//接收到的消息
private string sendMes="";//要发送的消息
NetworkView netWorkView;

// Use this for initialization
void Start () {
    netWorkView = GetComponent<NetworkView> ();
}

// Update is called once per frame
void Update () {

}
void OnGUI()
{
    
    switch (Network.peerType) 
    {
    case NetworkPeerType.Disconnected://未连接,开始创建
        StartCreat ();
        break;
    case NetworkPeerType.Server://服务器状态,启动服务器
        OnServer ();
        break;
    case NetworkPeerType.Client://客户端状态 开启客户端
        OnClient();
        break;
    case NetworkPeerType.Connecting://尝试连接
        Debug.Log ("链接中。。。");
        break;
    }
}
/// <summary>
/// 开始创建服务器或者客户端
/// </summary>
void StartCreat()
{
    GUILayout.BeginVertical ();
    if (GUILayout.Button("新建服务器")) 
    {
        NetworkConnectionError error = Network.InitializeServer (connectCount,port,useNAT);//初始化网络服务连接
        Debug.Log (error);
        serverIsRun=true;
        StartServer ();
    }
    if (GUILayout.Button("连接服务器")) 
    {
        clientIsRun = true;
        StartClient ();
        NetworkConnectionError error = Network.Connect (ip,port);//根据服务器IP和端口连接
        Debug.Log(error);
    }
    GUILayout.EndVertical ();
}

private string strInfo;
Thread serverThread=null;//服务器线程
UdpClient UdpSend=null;//Udp网络传输
Thread clientThread=null;//客户端线程
UdpClient UdpListen=null;//客户端传输

bool serverIsRun=false;
bool clientIsRun=false;


const string specialText = "";

void StartServer()//服务器一直发消息  
{
    strInfo = "开始服务器...";//服务器信息
    if (serverThread != null && serverThread.IsAlive) return;//如果服务器线程不等于空,并且服务器线程处于活动状态

    serverThread = new Thread(() =>
        {
            UdpSend = new UdpClient();//服务器进行Udp网络传播

            while (serverIsRun)
            {
                Thread.Sleep(500);//线程暂停0.5s
                byte[] buf = Encoding.Unicode.GetBytes(specialText);//将特殊文本转换为字节流
                UdpSend.Send(buf, buf.Length, new IPEndPoint(IPAddress.Broadcast, port));
            }

            UdpSend.Close();
        });

    serverThread.IsBackground = true;
    InitServer();
    serverThread.Start();
    strInfo = "服务器已开启";
}

void StartClient()//客户端收消息直到收到服务器的IP  
{
    strInfo = "开始客户端...";
    if (clientThread != null && clientThread.IsAlive) return;

    clientThread = new Thread(() =>
        {
            UdpListen = new UdpClient(new IPEndPoint(IPAddress.Any, port));

            while (clientIsRun)
            {
                Thread.Sleep(10);
                IPEndPoint endpoint = new IPEndPoint(IPAddress.Any, port);//表示IP和端口的类
                byte[] bufRev = UdpListen.Receive(ref endpoint);//Udp监听到客户端的字节流
                string msg = Encoding.Unicode.GetString(bufRev, 0, bufRev.Length);//客户端得到的字节流转换为字符串
                if (msg.Contains(specialText))
                {
                    strInfo = "我是客户端,接收到的IP地址为:" + endpoint.Address.ToString();
                    Debug.Log(strInfo);
                    ip=endpoint.Address.ToString();

                    UdpListen.Close();
                    return;
                }
                else
                {
                    strInfo = "我是客户端,接收到的IP地址:" + endpoint.Address.ToString() + ",但是并没有用!";
                    ip=endpoint.Address.ToString();
                }
            }
            UdpListen.Close();
        });
    clientThread.IsBackground = true;//后台线程为正
    InitClient();
    clientThread.Start();
    strInfo = "接收...";
}
void InitServer()
{
    serverIsRun = true;
    if (UdpSend!=null) 
    {
        UdpSend.Close ();
    }
}
void InitClient()
{
    clientIsRun = true;
    if (UdpListen!=null) 
    {
        UdpListen.Close ();
    }
}
void StopServer()
{
    serverIsRun = false;
    if (UdpSend != null && serverThread.IsAlive)
        serverThread.Abort ();
}
public void StopClient()
{
    clientIsRun = false;
    if (UdpListen != null)
        UdpSend.Close ();
    if (serverThread != null && clientThread.IsAlive)
        clientThread.Abort ();
}
void OnDestroy()
{
    StopClient ();
    StopServer ();
    Debug.Log ("Stop");
}



void OnServer()
{
    GUILayout.Label ("新建服务器成功,等待客户端连接");
    int length = Network.connections.Length;
    for (int i = 0; i < length; i++) 
    {
        GUILayout.Label ("连接的IP:"+Network.connections[i].ipAddress);
        GUILayout.Label ("连接的端口:"+Network.connections[i].port);
        GUILayout.Label ("Udp连接到IP"+ip);
    }
    if (GUILayout.Button("断开连接")) 
    {
        Network.Disconnect ();
    }
    GUILayout.TextArea(recMes);//显示接收到的消息(只显示)
    sendMes = GUILayout.TextField (sendMes);//输入消息
    if (GUILayout.Button("发送消息")) 
    {
        netWorkView.RPC ("SendMes", RPCMode.All, Network.player + "Say:" + sendMes);
    }
}
void OnClient()
{
    GUILayout.Label ("连接成功");
    int length = Network.connections.Length;
    for (int i = 0; i < length; i++) 
    {
        GUILayout.Label ("连接的IP:"+Network.connections[i].ipAddress);
        GUILayout.Label ("连接的端口:"+Network.connections[i].port);
        GUILayout.Label ("Udp连接到IP"+ip);
    }
    if (GUILayout.Button("断开连接")) 
    {
        Network.Disconnect ();
    }
    GUILayout.TextArea (recMes);
    sendMes = GUILayout.TextField (sendMes);
    if (GUILayout.Button("发送消息")) 
    {
        netWorkView.RPC ("SendMes", RPCMode.All, Network.player + "说:" + sendMes);
    }
}
[RPC]
void SendMes(string mes)
{
    this.recMes+="\n";
    this.recMes += mes;
}

}

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,711评论 5 468
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,932评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,770评论 0 330
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,799评论 1 271
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,697评论 5 359
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,069评论 1 276
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,535评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,200评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,353评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,290评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,331评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,020评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,610评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,694评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,927评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,330评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,904评论 2 341

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,563评论 18 139
  • 我们知道 在RPG里单机游戏里 游戏存档功能必不可少 在这里 网上有个教程 非常的好 是基于xml下的保存 保...
    Unity与iOS的灵魂小白阅读 3,487评论 1 2
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,531评论 18 399
  • 前言 众所周知,网络游戏中,服务器的搭建尤为重要,无论是授权服务器,还是非授权服务器,它都承担着很大一部分的数据处...
    欣羽馨予阅读 8,401评论 0 24
  • 今天立春。寒冷的冬季就要过去了吧。 老冯躺在被窝里,淡蓝色的被罩裹着暖暖的棉絮做成的里子,不知从何时起,已经成了他...
    霓衣风马阅读 207评论 1 1