【D69】三菱PLC(Mitsubishi)通讯协议的C#实现

项目编号：D69

文件大小：1.66M

源码说明：带中文注释

开发环境：.cs

简要概述：

三菱PLC(Mitsubishi)通讯协议的C#实现，支持FX、Q系列的ASCII-3E、BIN-3E、FX串口格式。

HOW TO USE

将Mitsubishi、FX等目录及其下文件直接加到目标项目中即可。

下面是读写Q系列的示例代码（ASCII-3E或BIN-3E格式）

public static class McTest
{
	private static IMitsubishiPlc _plc = null;


	public static void Test()
	{
		_plc = new McProtocolUdp("192.0.1.254", 8195);

		_plc.Open();

		_plc.Excute("D0,32");
		_plc.Excute("M850,32");
		_plc.Excute("D001");
		_plc.Excute("D126,2");
		_plc.Excute("D126..130=0");
		_plc.Excute("D10=135");
	}

}

下面是读写FX系列的测试代码

public class Fx_Test
{
	private FxSerialDeamon _FxSerial;

	public void OpenPort ()
	{
		if(_FxSerial == null) {
			_FxSerial = new FxSerialDeamon();
			_FxSerial.Start(1);
		}
	}

	public void ClosePort ()
	{
		if(_FxSerial != null) {
			_FxSerial.Dispose();
		}
		_FxSerial = null;
	}

	public void Test_ReadAllPoints ()
	{
		List<AcquireRawValue> rawValues =
			_FxSerial.ReadAllPoints(null, TimeSpan.FromSeconds(3));
	}

	public void Test_All ()
	{
		string cmd;
		FxCommandResponse res;
		Random _Random = new Random();

		//// 置位
		//response = FxCommandHelper.Make(FxCommandConst.FxCmdForceOn, new FxAddress("S1"));
		//res = _FxSerial.SendCmdToQnCPU(0, response);

		//// 复位
		//response = FxCommandHelper.Make(FxCommandConst.FxCmdForceOff, new FxAddress("S1"));
		//res = _FxSerial.SendCmdToQnCPU(0, response);


		#region 读取所有 X/Y/M/ ,并计算其耗时

		Stopwatch sw = new Stopwatch();
		sw.Start();
		for(int ct = 0; ct < 10; ct++) {

			// 一次性读取多个字节的 X，例如 16 字节:：必须采用 AddressLayoutBin 方式
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("X0", ControllerTypeConst.ctPLC_Fx), 16);
			res = _FxSerial.Send(0, cmd);
			//Debug.WriteLine(string.Format("成批读X0..X177 \t{0}", res.ToString()));
			//System.Threading.Thread.Sleep(1000);

			// 一次性读取多个字节的 Y，例如 16 字节:：必须采用 AddressLayoutBin 方式
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("Y0", ControllerTypeConst.ctPLC_Fx), 16);
			res = _FxSerial.Send(0, cmd);
			//Debug.WriteLine(string.Format("成批读Y0..Y177 \t{0}", res.ToString()));
			//System.Threading.Thread.Sleep(1000);

			// 一次性读取多个字节的 M，每次读取128个单元:：必须采用 AddressLayoutBin 方式
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("M0", ControllerTypeConst.ctPLC_Fx), 128);
			res = _FxSerial.Send(0, cmd);
			//Debug.WriteLine(string.Format("成批读M{0}..M{1} \t{2}", result, result + 128, res.ToString()));

			Debug.Print("=====================> {0}", sw.ElapsedMilliseconds);

		}

		System.Threading.Thread.Sleep(1000);

		#endregion

		#region 针对 X/Y 的设置、读取

		// 置位与复位：必须采用 AddressLayoutByte 方式
		cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOn, new FxAddress("Y20", FxAddressLayoutType.AddressLayoutByte));
		res = _FxSerial.Send(0, cmd);
		Debug.WriteLine(res.ToString());
		System.Threading.Thread.Sleep(1000);

		cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOff, new FxAddress("Y20", FxAddressLayoutType.AddressLayoutByte));
		res = _FxSerial.Send(0, cmd);
		Debug.WriteLine(res.ToString());
		System.Threading.Thread.Sleep(1000);

		// 针对 Y001..Y177 设置与读取
		for(int i = 0; i < 128; i++) {
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOff,
									new FxAddress(string.Format("Y{0}", Convert.ToString(i, 8)), FxAddressLayoutType.AddressLayoutByte));
			res = _FxSerial.Send(0, cmd);
		}

		// 针对 Y001..Y077 设置与读取
		for(int i = 0; i < 128; i++) {
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOn,
									new FxAddress(string.Format("Y{0}", Convert.ToString(i, 8)), FxAddressLayoutType.AddressLayoutByte));
			res = _FxSerial.Send(0, cmd);
			//Debug.WriteLine(res.ToString());
			System.Threading.Thread.Sleep(100);

			if((i - 8) >= 0) {
				cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOff,
										new FxAddress(string.Format("Y{0}", Convert.ToString(i - 8, 8)), FxAddressLayoutType.AddressLayoutByte));
				res = _FxSerial.Send(0, cmd);
				Debug.WriteLine(string.Format("Y{0}\t{1}", Convert.ToString(i, 8), res.ToString()));
			}

			//System.Threading.Thread.Sleep(1000);
		}

		// 一次性读取多个字节的 X，例如 16 字节:：必须采用 AddressLayoutBin 方式
		cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("X0", ControllerTypeConst.ctPLC_Fx), 16);
		res = _FxSerial.Send(0, cmd);
		Debug.WriteLine(string.Format("成批读X0..X177 \t{0}", res.ToString()));
		System.Threading.Thread.Sleep(1000);

		// 一次性读取多个字节的 Y，例如 16 字节:：必须采用 AddressLayoutBin 方式
		cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("Y0", ControllerTypeConst.ctPLC_Fx), 16);
		res = _FxSerial.Send(0, cmd);
		Debug.WriteLine(string.Format("成批读Y0..Y177 \t{0}", res.ToString()));
		System.Threading.Thread.Sleep(1000);

		#endregion


		#region 针对 M 类型的读写
		// 针对 M001..M077 设置与读取
		for(int i = 0; i < 64; i++) {
			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdForceOn,
									new FxAddress(string.Format("M{0}", i), FxAddressLayoutType.AddressLayoutByte));
			res = _FxSerial.Send(0, cmd);
			Debug.WriteLine(res.ToString());

			//response = FxCommandHelper.Make(FxCommandConst.FxCmdForceOff,
			//                        new FxAddress(string.Format("M{0}", Convert.ToString(result, 8)), FxAddressLayoutType.AddressLayoutByte));
			//res = _FxSerial.SendCmdToQnCPU(0, response);
			//Debug.WriteLine(res.ToString());

			//System.Threading.Thread.Sleep(100);
		}

		// 一次性读取多个字节的 M，例如 16 字节:：必须采用 AddressLayoutBin 方式
		cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("M0", ControllerTypeConst.ctPLC_Fx), 64);
		res = _FxSerial.Send(0, cmd);
		Debug.WriteLine(string.Format("成批读M0..M77 \t{0}", res.ToString()));
		System.Threading.Thread.Sleep(1000);

		#endregion


		#region 循环设置与读取 Dxxx 的数据
		for(int i = 0; i < 1; i++) {

			List<uint> lst = new List<uint>() { (uint)i };
			for(int k = 0; k < 10; k++)
				lst.Add((uint)_Random.Next());

			cmd = FxCommandHelper.Make<UInt32DataType>(FxCommandConst.FxCmdWrite, new FxAddress("D1", ControllerTypeConst.ctPLC_Fx), lst);
			res = _FxSerial.Send(0, cmd);
			Debug.WriteLine(res.ToString());

			cmd = FxCommandHelper.Make(FxCommandConst.FxCmdRead, new FxAddress("D1", ControllerTypeConst.ctPLC_Fx), lst.Count * 4);
			res = _FxSerial.Send(0, cmd, UInt32DataType.Default);
			Debug.WriteLine(res.ToString());

			if(res.ResponseValue != null && res.ResponseValue.Count > 0) {
				Debug.WriteLine("");
				Debug.Write(DateTime.Now.ToString());
				Debug.Write("\t");
				for(int j = 0; j < res.ResponseValue.Count; j++) {
					Debug.Write(res.ResponseValue[j]);
					Debug.Write(',');
				}
			} else {
				Debug.WriteLine("没有收到FX PLC响应。");
			}
		}
		#endregion


		Debug.Assert(false, "运行暂停！！！");
	}
}

目录│文件列表:

 └ MitsubishiPlcProtocol

    │ App.config

    │ MitsubishiTester.csproj

    │ MitsubishiTester.sln

    │ Program.cs

    ├ Common

    │  │ AcquirePoint.cs

    │  │ AcquirePointConversion.cs

    │  │ AcquirePointEnum.cs

    │  │ AcquirePointUnitType.cs

    │  │ AcquireRawValue.cs

    │  │ AcquireValue.cs

    │  │ ConfigItem.cs

    │  │ ConfigItemCatalogo.cs

    │  │ ControllerBaseImpl.cs

    │  │ ControllerType.cs

    │  │ CraftworkItemInfo.cs

    │  │ CraftworkMaterialNoEnum.cs

    │  │ EnumForMixSystem.cs

    │  │ IControllerAction.cs

    │  │ IControllerBase.cs

    │  │ IOServerStatus.cs

    │  │ WeightingInfoArgs.cs

    │  │ WeightingStepEnum.cs

    │  │ WorkRegionEnum.cs

    │  └ WorkRegionStateItem.cs

    ├ packages

    │  │ System.Data.SQLite.dll

    │  │ System.Data.SQLite.pdb

    │  │ System.Data.SQLite.xml

    │  │ Vila.Core.dll

    │  └ Vila.Core.pdb

    ├ PLC

    │  │ CellDataTypes.cs

    │  │ ResultCodeConst.cs

    │  ├ FX

    │  │  │ FxAddress.cs

    │  │  │ FxAddressLayoutInfo.cs

    │  │  │ FxAddressManager.cs

    │  │  │ FxCommandArgs.cs

    │  │  │ FxCommandHelper.cs

    │  │  │ FxCommandResponse.cs

    │  │  │ FxCommController.cs

    │  │  │ FxConvert.cs

    │  │  │ FxDefine.cs

    │  │  │ FxRingBuffer.cs

    │  │  │ FxSerialDeamon.cs

    │  │  └ Fx_Test.cs

    │  ├ MCPackage

    │  │  │ MCComponentGroup.cs

    │  │  │ MCDefine.cs

    │  │  └ ResponseMessage.cs

    │  ├ Mitsubishi

    │  │  │ IMitsubishiPlc.cs

    │  │  │ McCommand.cs

    │  │  │ McCommandExtersions.cs

    │  │  │ McProtocolApp.cs

    │  │  │ McProtocolBinary.cs

    │  │  │ McProtocolTcp.cs

    │  │  │ McProtocolUdp.cs

    │  │  │ McSwapExtersions.cs

    │  │  │ McTest.cs

    │  │  └ PlcDeviceTypeExtersions.cs

    │  └ SerialDevice

    │     │ SerialParam.cs

    │     │ SerialPortManager.cs

    │     └ SerialPortSync.cs

    └ Properties

       └ AssemblyInfo.cs