用于WebGL平台的Unity WebSocket插件

1. // 命名空间
   
2. using UnityWebSocket;
   
3. 
   
4. // 创建实例
   
5. string address = "ws://echo.websocket.org";
   
6. WebSocket socket = new WebSocket(address);
   
7. 
   
8. // 注册回调
   
9. socket.OnOpen += OnOpen;
   
10. socket.OnClose += OnClose;
    
11. socket.OnMessage += OnMessage;
    
12. socket.OnError += OnError;
    
13. 
    
14. // 连接
    
15. socket.ConnectAsync();
    
16. 
    
17. // 发送 string 类型数据
    
18. socket.SendAsync(str);
    
19. 
    
20. // 或者 发送 byte[] 类型数据（建议使用）
    
21. socket.SendAsync(bytes);
    
22. 
    
23. // 关闭连接
    
24. socket.CloseAsync();
    

点击此处复制文本

1. using UnityEngine;
   
2. 
   
3. namespace UnityWebSocket.Demo
   
4. {
   
5.     public class UnityWebSocketDemo : MonoBehaviour
   
6.     {
   
7.         public string address = "wss://echo.websocket.events";
   
8.         public string sendText = "Hello UnityWebSocket!";
   
9. 
   
10.         private IWebSocket socket;
    
11. 
    
12.         private bool logMessage = true;
    
13.         private string log = "";
    
14.         private int sendCount;
    
15.         private int receiveCount;
    
16.         private Vector2 scrollPos;
    
17.         private Color green = new Color(0.1f, 1, 0.1f);
    
18.         private Color red = new Color(1f, 0.1f, 0.1f);
    
19.         private Color wait = new Color(0.7f, 0.3f, 0.3f);
    
20. 
    
21.         private void OnGUI()
    
22.         {
    
23.             var scale = Screen.width / 800f;
    
24.             GUI.matrix = Matrix4x4.TRS(new Vector3(0, 0, 0), Quaternion.identity, new Vector3(scale, scale, 1));
    
25.             var width = GUILayout.Width(Screen.width / scale - 10);
    
26. 
    
27.             WebSocketState state = socket == null ? WebSocketState.Closed : socket.ReadyState;
    
28. 
    
29.             GUILayout.BeginHorizontal();
    
30.             GUILayout.Label("SDK Version: " + Settings.VERSION, GUILayout.Width(Screen.width / scale - 100));
    
31.             GUI.color = green;
    
32.             GUILayout.Label([        DISCUZ_CODE_1        ]quot;FPS: {fps:F2}", GUILayout.Width(80));
    
33.             GUI.color = Color.white;
    
34.             GUILayout.EndHorizontal();
    
35. 
    
36.             GUILayout.BeginHorizontal();
    
37.             GUILayout.Label("State: ", GUILayout.Width(36));
    
38.             GUI.color = WebSocketState.Closed == state ? red : WebSocketState.Open == state ? green : wait;
    
39.             GUILayout.Label([        DISCUZ_CODE_1        ]quot;{state}", GUILayout.Width(120));
    
40.             GUI.color = Color.white;
    
41.             GUILayout.EndHorizontal();
    
42. 
    
43.             GUI.enabled = state == WebSocketState.Closed;
    
44.             GUILayout.Label("Address: ", width);
    
45.             address = GUILayout.TextField(address, width);
    
46. 
    
47.             GUILayout.BeginHorizontal();
    
48.             GUI.enabled = state == WebSocketState.Closed;
    
49.             if (GUILayout.Button(state == WebSocketState.Connecting ? "Connecting..." : "Connect"))
    
50.             {
    
51.                 socket = new WebSocket(address);
    
52.                 socket.OnOpen += Socket_OnOpen;
    
53.                 socket.OnMessage += Socket_OnMessage;
    
54.                 socket.OnClose += Socket_OnClose;
    
55.                 socket.OnError += Socket_OnError;
    
56.                 AddLog(string.Format("Connecting..."));
    
57.                 socket.ConnectAsync();
    
58.             }
    
59. 
    
60.             GUI.enabled = state == WebSocketState.Open;
    
61.             if (GUILayout.Button(state == WebSocketState.Closing ? "Closing..." : "Close"))
    
62.             {
    
63.                 AddLog(string.Format("Closing..."));
    
64.                 socket.CloseAsync();
    
65.             }
    
66.             GUILayout.EndHorizontal();
    
67. 
    
68.             GUILayout.Label("Message: ");
    
69.             sendText = GUILayout.TextArea(sendText, GUILayout.MinHeight(50), width);
    
70. 
    
71.             GUILayout.BeginHorizontal();
    
72.             if (GUILayout.Button("Send") && !string.IsNullOrEmpty(sendText))
    
73.             {
    
74.                 socket.SendAsync(sendText);
    
75.                 AddLog(string.Format("Send: {0}", sendText));
    
76.                 sendCount += 1;
    
77.             }
    
78.             if (GUILayout.Button("Send Bytes") && !string.IsNullOrEmpty(sendText))
    
79.             {
    
80.                 var bytes = System.Text.Encoding.UTF8.GetBytes(sendText);
    
81.                 socket.SendAsync(bytes);
    
82.                 AddLog(string.Format("Send Bytes ({1}): {0}", sendText, bytes.Length));
    
83.                 sendCount += 1;
    
84.             }
    
85.             if (GUILayout.Button("Send x100") && !string.IsNullOrEmpty(sendText))
    
86.             {
    
87.                 for (int i = 0; i < 100; i++)
    
88.                 {
    
89.                     var text = (i + 1).ToString() + ". " + sendText;
    
90.                     socket.SendAsync(text);
    
91.                     AddLog(string.Format("Send: {0}", text));
    
92.                     sendCount += 1;
    
93.                 }
    
94.             }
    
95.             if (GUILayout.Button("Send Bytes x100") && !string.IsNullOrEmpty(sendText))
    
96.             {
    
97.                 for (int i = 0; i < 100; i++)
    
98.                 {
    
99.                     var text = (i + 1).ToString() + ". " + sendText;
    
100.                     var bytes = System.Text.Encoding.UTF8.GetBytes(text);
     
101.                     socket.SendAsync(bytes);
     
102.                     AddLog(string.Format("Send Bytes ({1}): {0}", text, bytes.Length));
     
103.                     sendCount += 1;
     
104.                 }
     
105.             }
     
106. 
     
107.             GUILayout.EndHorizontal();
     
108. 
     
109.             GUI.enabled = true;
     
110.             GUILayout.BeginHorizontal();
     
111.             logMessage = GUILayout.Toggle(logMessage, "Log Message");
     
112.             GUILayout.Label(string.Format("Send Count: {0}", sendCount));
     
113.             GUILayout.Label(string.Format("Receive Count: {0}", receiveCount));
     
114.             GUILayout.EndHorizontal();
     
115. 
     
116.             if (GUILayout.Button("Clear"))
     
117.             {
     
118.                 log = "";
     
119.                 receiveCount = 0;
     
120.                 sendCount = 0;
     
121.             }
     
122. 
     
123.             scrollPos = GUILayout.BeginScrollView(scrollPos, GUILayout.MaxHeight(Screen.height / scale - 270), width);
     
124.             GUILayout.Label(log);
     
125.             GUILayout.EndScrollView();
     
126.         }
     
127. 
     
128.         private void AddLog(string str)
     
129.         {
     
130.             if (!logMessage) return;
     
131.             if (str.Length > 100) str = str.Substring(0, 100) + "...";
     
132.             log += str + "\n";
     
133.             if (log.Length > 22 * 1024)
     
134.             {
     
135.                 log = log.Substring(log.Length - 22 * 1024);
     
136.             }
     
137.             scrollPos.y = int.MaxValue;
     
138.         }
     
139. 
     
140.         private void Socket_OnOpen(object sender, OpenEventArgs e)
     
141.         {
     
142.             AddLog(string.Format("Connected: {0}", address));
     
143.         }
     
144. 
     
145.         private void Socket_OnMessage(object sender, MessageEventArgs e)
     
146.         {
     
147.             if (e.IsBinary)
     
148.             {
     
149.                 AddLog(string.Format("Receive Bytes ({1}): {0}", e.Data, e.RawData.Length));
     
150.             }
     
151.             else if (e.IsText)
     
152.             {
     
153.                 AddLog(string.Format("Receive: {0}", e.Data));
     
154.             }
     
155.             receiveCount += 1;
     
156.         }
     
157. 
     
158.         private void Socket_OnClose(object sender, CloseEventArgs e)
     
159.         {
     
160.             AddLog(string.Format("Closed: StatusCode: {0}, Reason: {1}", e.StatusCode, e.Reason));
     
161.         }
     
162. 
     
163.         private void Socket_OnError(object sender, ErrorEventArgs e)
     
164.         {
     
165.             AddLog(string.Format("Error: {0}", e.Message));
     
166.         }
     
167. 
     
168.         private void OnApplicationQuit()
     
169.         {
     
170.             if (socket != null && socket.ReadyState != WebSocketState.Closed)
     
171.             {
     
172.                 socket.CloseAsync();
     
173.             }
     
174.         }
     
175. 
     
176.         private int frame = 0;
     
177.         private float time = 0;
     
178.         private float fps = 0;
     
179.         private void Update()
     
180.         {
     
181.             frame += 1;
     
182.             time += Time.deltaTime;
     
183.             if (time >= 0.5f)
     
184.             {
     
185.                 fps = frame / time;
     
186.                 frame = 0;
     
187.                 time = 0;
     
188.             }
     
189.         }
     
190.     }
     
191. }
     

点击此处复制文本

用于WebGL平台的Unity WebSocket插件

1. // 命名空间
   
2. using UnityWebSocket;
   
3. 
   
4. // 创建实例
   
5. string address = "ws://echo.websocket.org";
   
6. WebSocket socket = new WebSocket(address);
   
7. 
   
8. // 注册回调
   
9. socket.OnOpen += OnOpen;
   
10. socket.OnClose += OnClose;
    
11. socket.OnMessage += OnMessage;
    
12. socket.OnError += OnError;
    
13. 
    
14. // 连接
    
15. socket.ConnectAsync();
    
16. 
    
17. // 发送 string 类型数据
    
18. socket.SendAsync(str);
    
19. 
    
20. // 或者 发送 byte[] 类型数据（建议使用）
    
21. socket.SendAsync(bytes);
    
22. 
    
23. // 关闭连接
    
24. socket.CloseAsync();
    

点击此处复制文本

1. using UnityEngine;
   
2. 
   
3. namespace UnityWebSocket.Demo
   
4. {
   
5.     public class UnityWebSocketDemo : MonoBehaviour
   
6.     {
   
7.         public string address = "wss://echo.websocket.events";
   
8.         public string sendText = "Hello UnityWebSocket!";
   
9. 
   
10.         private IWebSocket socket;
    
11. 
    
12.         private bool logMessage = true;
    
13.         private string log = "";
    
14.         private int sendCount;
    
15.         private int receiveCount;
    
16.         private Vector2 scrollPos;
    
17.         private Color green = new Color(0.1f, 1, 0.1f);
    
18.         private Color red = new Color(1f, 0.1f, 0.1f);
    
19.         private Color wait = new Color(0.7f, 0.3f, 0.3f);
    
20. 
    
21.         private void OnGUI()
    
22.         {
    
23.             var scale = Screen.width / 800f;
    
24.             GUI.matrix = Matrix4x4.TRS(new Vector3(0, 0, 0), Quaternion.identity, new Vector3(scale, scale, 1));
    
25.             var width = GUILayout.Width(Screen.width / scale - 10);
    
26. 
    
27.             WebSocketState state = socket == null ? WebSocketState.Closed : socket.ReadyState;
    
28. 
    
29.             GUILayout.BeginHorizontal();
    
30.             GUILayout.Label("SDK Version: " + Settings.VERSION, GUILayout.Width(Screen.width / scale - 100));
    
31.             GUI.color = green;
    
32.             GUILayout.Label([        DISCUZ_CODE_1        ]quot;FPS: {fps:F2}", GUILayout.Width(80));
    
33.             GUI.color = Color.white;
    
34.             GUILayout.EndHorizontal();
    
35. 
    
36.             GUILayout.BeginHorizontal();
    
37.             GUILayout.Label("State: ", GUILayout.Width(36));
    
38.             GUI.color = WebSocketState.Closed == state ? red : WebSocketState.Open == state ? green : wait;
    
39.             GUILayout.Label([        DISCUZ_CODE_1        ]quot;{state}", GUILayout.Width(120));
    
40.             GUI.color = Color.white;
    
41.             GUILayout.EndHorizontal();
    
42. 
    
43.             GUI.enabled = state == WebSocketState.Closed;
    
44.             GUILayout.Label("Address: ", width);
    
45.             address = GUILayout.TextField(address, width);
    
46. 
    
47.             GUILayout.BeginHorizontal();
    
48.             GUI.enabled = state == WebSocketState.Closed;
    
49.             if (GUILayout.Button(state == WebSocketState.Connecting ? "Connecting..." : "Connect"))
    
50.             {
    
51.                 socket = new WebSocket(address);
    
52.                 socket.OnOpen += Socket_OnOpen;
    
53.                 socket.OnMessage += Socket_OnMessage;
    
54.                 socket.OnClose += Socket_OnClose;
    
55.                 socket.OnError += Socket_OnError;
    
56.                 AddLog(string.Format("Connecting..."));
    
57.                 socket.ConnectAsync();
    
58.             }
    
59. 
    
60.             GUI.enabled = state == WebSocketState.Open;
    
61.             if (GUILayout.Button(state == WebSocketState.Closing ? "Closing..." : "Close"))
    
62.             {
    
63.                 AddLog(string.Format("Closing..."));
    
64.                 socket.CloseAsync();
    
65.             }
    
66.             GUILayout.EndHorizontal();
    
67. 
    
68.             GUILayout.Label("Message: ");
    
69.             sendText = GUILayout.TextArea(sendText, GUILayout.MinHeight(50), width);
    
70. 
    
71.             GUILayout.BeginHorizontal();
    
72.             if (GUILayout.Button("Send") && !string.IsNullOrEmpty(sendText))
    
73.             {
    
74.                 socket.SendAsync(sendText);
    
75.                 AddLog(string.Format("Send: {0}", sendText));
    
76.                 sendCount += 1;
    
77.             }
    
78.             if (GUILayout.Button("Send Bytes") && !string.IsNullOrEmpty(sendText))
    
79.             {
    
80.                 var bytes = System.Text.Encoding.UTF8.GetBytes(sendText);
    
81.                 socket.SendAsync(bytes);
    
82.                 AddLog(string.Format("Send Bytes ({1}): {0}", sendText, bytes.Length));
    
83.                 sendCount += 1;
    
84.             }
    
85.             if (GUILayout.Button("Send x100") && !string.IsNullOrEmpty(sendText))
    
86.             {
    
87.                 for (int i = 0; i < 100; i++)
    
88.                 {
    
89.                     var text = (i + 1).ToString() + ". " + sendText;
    
90.                     socket.SendAsync(text);
    
91.                     AddLog(string.Format("Send: {0}", text));
    
92.                     sendCount += 1;
    
93.                 }
    
94.             }
    
95.             if (GUILayout.Button("Send Bytes x100") && !string.IsNullOrEmpty(sendText))
    
96.             {
    
97.                 for (int i = 0; i < 100; i++)
    
98.                 {
    
99.                     var text = (i + 1).ToString() + ". " + sendText;
    
100.                     var bytes = System.Text.Encoding.UTF8.GetBytes(text);
     
101.                     socket.SendAsync(bytes);
     
102.                     AddLog(string.Format("Send Bytes ({1}): {0}", text, bytes.Length));
     
103.                     sendCount += 1;
     
104.                 }
     
105.             }
     
106. 
     
107.             GUILayout.EndHorizontal();
     
108. 
     
109.             GUI.enabled = true;
     
110.             GUILayout.BeginHorizontal();
     
111.             logMessage = GUILayout.Toggle(logMessage, "Log Message");
     
112.             GUILayout.Label(string.Format("Send Count: {0}", sendCount));
     
113.             GUILayout.Label(string.Format("Receive Count: {0}", receiveCount));
     
114.             GUILayout.EndHorizontal();
     
115. 
     
116.             if (GUILayout.Button("Clear"))
     
117.             {
     
118.                 log = "";
     
119.                 receiveCount = 0;
     
120.                 sendCount = 0;
     
121.             }
     
122. 
     
123.             scrollPos = GUILayout.BeginScrollView(scrollPos, GUILayout.MaxHeight(Screen.height / scale - 270), width);
     
124.             GUILayout.Label(log);
     
125.             GUILayout.EndScrollView();
     
126.         }
     
127. 
     
128.         private void AddLog(string str)
     
129.         {
     
130.             if (!logMessage) return;
     
131.             if (str.Length > 100) str = str.Substring(0, 100) + "...";
     
132.             log += str + "\n";
     
133.             if (log.Length > 22 * 1024)
     
134.             {
     
135.                 log = log.Substring(log.Length - 22 * 1024);
     
136.             }
     
137.             scrollPos.y = int.MaxValue;
     
138.         }
     
139. 
     
140.         private void Socket_OnOpen(object sender, OpenEventArgs e)
     
141.         {
     
142.             AddLog(string.Format("Connected: {0}", address));
     
143.         }
     
144. 
     
145.         private void Socket_OnMessage(object sender, MessageEventArgs e)
     
146.         {
     
147.             if (e.IsBinary)
     
148.             {
     
149.                 AddLog(string.Format("Receive Bytes ({1}): {0}", e.Data, e.RawData.Length));
     
150.             }
     
151.             else if (e.IsText)
     
152.             {
     
153.                 AddLog(string.Format("Receive: {0}", e.Data));
     
154.             }
     
155.             receiveCount += 1;
     
156.         }
     
157. 
     
158.         private void Socket_OnClose(object sender, CloseEventArgs e)
     
159.         {
     
160.             AddLog(string.Format("Closed: StatusCode: {0}, Reason: {1}", e.StatusCode, e.Reason));
     
161.         }
     
162. 
     
163.         private void Socket_OnError(object sender, ErrorEventArgs e)
     
164.         {
     
165.             AddLog(string.Format("Error: {0}", e.Message));
     
166.         }
     
167. 
     
168.         private void OnApplicationQuit()
     
169.         {
     
170.             if (socket != null && socket.ReadyState != WebSocketState.Closed)
     
171.             {
     
172.                 socket.CloseAsync();
     
173.             }
     
174.         }
     
175. 
     
176.         private int frame = 0;
     
177.         private float time = 0;
     
178.         private float fps = 0;
     
179.         private void Update()
     
180.         {
     
181.             frame += 1;
     
182.             time += Time.deltaTime;
     
183.             if (time >= 0.5f)
     
184.             {
     
185.                 fps = frame / time;
     
186.                 frame = 0;
     
187.                 time = 0;
     
188.             }
     
189.         }
     
190.     }
     
191. }
     

点击此处复制文本