using UnityEngine;
using
System.Collections;
using
System.IO.Ports;
using
System;
using
System.Collections.Generic;
using
System.Threading;
public class PortControl : MonoBehaviour
{
public GUIText gui;
public string portName = "COM2";
public int baudRate = 9600;
public
Parity parity = Parity.None;
public
int dataBits = 8;
public StopBits
stopBits = StopBits.One;
int[]
data = new int[6];//用于存储6位数据
SerialPort sp = null;
Thread
dataReceiveThread;
//发送
string message =
"";
//byte[] message=new
byte[8];
void Start()
{
OpenPort();
dataReceiveThread = new Thread(new
ThreadStart(DataReceiveFunction));
dataReceiveThread.Start();
}
void Update()
{
string
str = "";
for(int i=0;
i<data.Length; i++)
{
str +=
data[i].ToString() + " ";
}
gui.text
= str;
Debug.Log(str);
}
public void OpenPort()
{
sp = new SerialPort(portName, baudRate, parity,
dataBits, stopBits);
sp.ReadTimeout =
400;
try
{
sp.Open();
}
catch(Exception ex)
{
Debug.Log(ex.Message);
}
}
public void ClosePort()
{
try
{
sp.Close();
}
catch(Exception ex)
{
Debug.Log(ex.Message);
}
}
public void WriteData(string
dataStr)
{
if(sp.IsOpen)
{
sp.Write(dataStr);
}
}
void OnApplicationQuit()
{
ClosePort
();
}
void
DataReceiveFunction()
{
byte[]
buffer = new byte[128];
int bytes =
0;
int flag0 = 0xFF;
int flag1 = 0xAA;
int
index = 0;//用于记录此时的数据次序
while
(true)
{
if
(sp != null && sp.IsOpen)
{
try
{
bytes = sp.Read(buffer, 0,
buffer.Length);
for(int i=0;
i<bytes; i++)
{
if(buffer[i]==flag0 ||
buffer[i]==flag1)
{
index = 0;//次序归0
continue;
}
else
{
if(index>=data.Length) index =
data.Length-1;//理论上不应该会进入此判断，但是由于传输的误码，导致数据的丢失，使得标志位与数据个数出错
data[index] = buffer[i];//将数据存入data中
index++;
}
}
}
catch (Exception ex)
{
if (ex.GetType() !=
typeof(ThreadAbortException))
{
Debug.Log(ex.Message);
}
}
}
Thread.Sleep(10);
}
}
void OnGUI()
{
message =
GUILayout.TextField(message);
if(GUILayout.Button("Send Message"))
{
WriteData(message);
}
string by= "XX AA 03 31 20 51 00
00";
if
(GUILayout.Button("Send",GUILayout.Height(50),GUILayout.Width(100)))
{
WriteData(by);
}
}
}