编辑:将在SO上公开生产代码!希望没有人偷我的秘密!
我有一个Controller类,用于使用Modbus协议通过TCP与设备进行通信。我使用NModbus库。
这是控制器类实现的接口:
public interface CoilReader
{
bool[] Read(ushort startAddress, ushort numberOfCoils);
}
public interface CoilWriter
{
void WriteSingle(ushort address, bool value);
void WriteMultiple(ushort startAddress, bool[] values);
}
public interface HoldingRegisterReader
{
ushort[] Read(ushort startAddress, ushort numberOfRegisters);
}
public interface HoldingRegisterWriter
{
void WriteSingle(ushort address, ushort value);
void WriteMultiple(ushort startAddress, ushort[] values);
}
public interface InputReader
{
bool[] Read(ushort startAddress, ushort numberOfCoils);
}
public interface InputRegisterReader
{
ushort[] Read(ushort startAddress, ushort numberOfRegisters);
}
public interface ConnectionInfo
{
string IP { get; set; }
}
这是控制器类。
using System;
using System.Net.Sockets;
using System.Reflection;
using global::Modbus.Device;
public class Controller
: ConnectionInfo,
HoldingRegisterReader,
InputRegisterReader,
CoilReader,
InputReader,
CoilWriter,
HoldingRegisterWriter
{
static Controller()
{
AppDomain.CurrentDomain.AssemblyResolve += (sender, e) => loadEmbeddedAssembly(e.Name);
}
public virtual string IP
{
get
{
return this.ip;
}
set
{
this.ip = value;
}
}
public virtual ushort[] ReadHoldingRegisters(ushort startAddress, ushort numberOfRegisters)
{
using (var connection = this.createDeviceConnection())
{
return connection.ReadHoldingRegisters(startAddress, numberOfRegisters);
}
}
public virtual ushort[] ReadInputRegisters(ushort startAddress, ushort numberOfRegisters)
{
using (var connection = this.createDeviceConnection())
{
return connection.ReadInputRegisters(startAddress, numberOfRegisters);
}
}
public virtual bool[] ReadCoils(ushort startAddress, ushort numberOfCoils)
{
using (var connection = this.createDeviceConnection())
{
return connection.ReadCoils(startAddress, numberOfCoils);
}
}
public virtual bool[] ReadInputs(ushort startAddress, ushort numberOfInputs)
{
using (var connection = this.createDeviceConnection())
{
return connection.ReadInputs(startAddress, numberOfInputs);
}
}
public virtual void WriteSingleCoil(ushort address, bool value)
{
using (var connection = this.createDeviceConnection())
{
connection.WriteSingleCoil(address, value);
}
}
public virtual void WriteMultipleCoils(ushort startAddress, bool[] values)
{
using (var connection = this.createDeviceConnection())
{
connection.WriteMultipleCoils(startAddress, values);
}
}
public virtual void WriteSingleHoldingRegister(ushort address, ushort value)
{
using (var connection = this.createDeviceConnection())
{
connection.WriteSingleRegister(address, value);
}
}
public virtual void WriteMultipleHoldingRegisters(ushort startAddress, ushort[] values)
{
using (var connection = this.createDeviceConnection())
{
connection.WriteMultipleRegisters(startAddress, values);
}
}
string ConnectionInfo.IP
{
get
{
return this.IP;
}
set
{
this.IP = value;
}
}
ushort[] HoldingRegisterReader.Read(ushort startAddress, ushort numberOfRegisters)
{
return this.ReadHoldingRegisters(startAddress, numberOfRegisters);
}
ushort[] InputRegisterReader.Read(ushort startAddress, ushort numberOfRegisters)
{
return this.ReadInputRegisters(startAddress, numberOfRegisters);
}
bool[] CoilReader.Read(ushort startAddress, ushort numberOfCoils)
{
return this.ReadCoils(startAddress, numberOfCoils);
}
bool[] InputReader.Read(ushort startAddress, ushort numberOfInputs)
{
return this.ReadInputs(startAddress, numberOfInputs);
}
void CoilWriter.WriteSingle(ushort address, bool value)
{
this.WriteSingleCoil(address, value);
}
void CoilWriter.WriteMultiple(ushort startAddress, bool[] values)
{
this.WriteMultipleCoils(startAddress, values);
}
void HoldingRegisterWriter.WriteSingle(ushort address, ushort value)
{
this.WriteSingleHoldingRegister(address, value);
}
void HoldingRegisterWriter.WriteMultiple(ushort startAddress, ushort[] values)
{
this.WriteMultipleHoldingRegisters(startAddress, values);
}
private ModbusIpMaster createDeviceConnection()
{
const int port = 502;
var client = new TcpClient();
client.BeginConnect(this.ip, port, null, null).AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(2));
if (!client.Connected)
{
throw new Exception("Cannot connect to " + this.ip + ":" + port);
}
return ModbusIpMaster.CreateIp(client);
}
private static Assembly loadEmbeddedAssembly(string name)
{
if (name.EndsWith("Retargetable=Yes"))
{
return Assembly.Load(new AssemblyName(name));
}
var container = Assembly.GetExecutingAssembly();
var path = new AssemblyName(name).Name + ".dll";
using (var stream = container.GetManifestResourceStream(path))
{
if (stream == null)
{
return null;
}
var bytes = new byte[stream.Length];
stream.Read(bytes, 0, bytes.Length);
return Assembly.Load(bytes);
}
}
private string ip;
}
我没有从与包含此类及其接口的库相同的解决方案的Tests项目中创建的测试中得到以下错误。但是,在使用其他解决方案的项目中,使用库的情况下,我得到以下信息:
------ Test started: Assembly: CareControls.IvisHmi.Tests.dll ------
Unknown .NET Framework Version: v4.5.1
Test 'CareControls.IvisHmi.Tests.Presenters.ModbusTcpTogglePresenterTests.FactMethodName' failed: FakeItEasy.Core.FakeCreationException :
Failed to create fake of type "CareControls.Modbus.Tcp.Controller".
Below is a list of reasons for failure per attempted constructor:
No constructor arguments failed:
No default constructor was found on the type CareControls.Modbus.Tcp.Controller.
If either the type or constructor is internal, try adding the following attribute to the assembly:
[assembly: InternalsVisibleTo("DynamicProxyGenAssembly2")]
at FakeItEasy.Core.DefaultExceptionThrower.ThrowFailedToGenerateProxyWithResolvedConstructors(Type typeOfFake, String reasonForFailureOfUnspecifiedConstructor, IEnumerable`1 resolvedConstructors)
at FakeItEasy.Creation.FakeObjectCreator.TryCreateFakeWithDummyArgumentsForConstructor(Type typeOfFake, FakeOptions fakeOptions, IDummyValueCreationSession session, String failReasonForDefaultConstructor, Boolean throwOnFailure)
at FakeItEasy.Creation.FakeObjectCreator.CreateFake(Type typeOfFake, FakeOptions fakeOptions, IDummyValueCreationSession session, Boolean throwOnFailure)
at FakeItEasy.Creation.DefaultFakeAndDummyManager.CreateFake(Type typeOfFake, FakeOptions options)
at FakeItEasy.Creation.DefaultFakeCreatorFacade.CreateFake[T](Action`1 options)
at FakeItEasy.A.Fake[T]()
Presenters\ModbusTcpTogglePresenterTests.cs(22,0): at CareControls.IvisHmi.Tests.Presenters.ModbusTcpTogglePresenterTests.FactMethodName()
0 passed, 1 failed, 0 skipped, took 0.93 seconds (xUnit.net 1.9.2 build 1705).
这是测试:
namespace CareControls.IvisHmi.Tests.Presenters
{
using CareControls.IvisHmi.Framework;
using CareControls.IvisHmi.Presenters;
using CareControls.IvisHmi.UI;
using CareControls.Modbus.Tcp;
using FakeItEasy;
using Ploeh.AutoFixture;
using Xunit;
public class ModbusTcpTogglePresenterTests
{
[Fact]
public void FactMethodName()
{
A.Fake<Controller>();
}
}
}
为什么FakeItEasy不认为该类上存在默认构造函数?
抱歉,发布的帖子过多,但有人要求我提供代码。
编辑:如果我在行new Controller()
之前添加,则测试通过A.Fake<Controller>()
:
namespace CareControls.IvisHmi.Tests.Presenters
{
using CareControls.IvisHmi.Framework;
using CareControls.IvisHmi.Presenters;
using CareControls.IvisHmi.UI;
using CareControls.Modbus.Tcp;
using FakeItEasy;
using Ploeh.AutoFixture;
using Xunit;
public class ModbusTcpTogglePresenterTests
{
[Fact]
public void FactMethodName()
{
new Controller();
A.Fake<Controller>();
}
}
}
我通过将createDeviceConnection()
方法转换为NModbusDeviceConnection
可处理的类来解决了这个问题。在的静态构造函数NModbusDeviceConnection
中,AssemblyResolve
事件是订阅的。现在,我可以在Controller
不触发Modbus
程序集加载的情况下创建的伪造品。
有关详细信息,请参见以下NModbusDeviceConnection
类:
// ---------------------------------------------------------------------------------------------------------------------
// <copyright file="NModbusDeviceConnection.cs" company="Care Controls">
// Copyright (c) Care Controls Inc. All rights reserved.
// </copyright>
// ---------------------------------------------------------------------------------------------------------------------
namespace CareControls.Modbus.Tcp.Internal
{
using System;
using System.Net.Sockets;
using System.Reflection;
using global::Modbus.Device;
internal sealed class NModbusDeviceConnection : IDisposable
{
static NModbusDeviceConnection()
{
AppDomain.CurrentDomain.AssemblyResolve += (sender, e) => loadEmbeddedAssembly(e.Name);
}
public NModbusDeviceConnection(string ip)
{
const int port = 502;
var client = new TcpClient();
client.BeginConnect(ip, port, null, null).AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(2));
if (!client.Connected)
{
throw new Exception("Cannot connect to " + ip + ":" + port);
}
this.connection = ModbusIpMaster.CreateIp(client);
}
public ushort[] ReadHoldingRegisters(ushort startAddress, ushort numberOfRegisters)
{
return this.connection.ReadHoldingRegisters(startAddress, numberOfRegisters);
}
public ushort[] ReadInputRegisters(ushort startAddress, ushort numberOfRegisters)
{
return this.connection.ReadInputRegisters(startAddress, numberOfRegisters);
}
public bool[] ReadCoils(ushort startAddress, ushort numberOfCoils)
{
return this.connection.ReadCoils(startAddress, numberOfCoils);
}
public bool[] ReadInputs(ushort startAddress, ushort numberOfInputs)
{
return this.connection.ReadInputs(startAddress, numberOfInputs);
}
public void WriteSingleCoil(ushort address, bool value)
{
this.connection.WriteSingleCoil(address, value);
}
public void WriteMultipleCoils(ushort startAddress, bool[] values)
{
this.connection.WriteMultipleCoils(startAddress, values);
}
public void WriteSingleHoldingRegister(ushort address, ushort value)
{
this.connection.WriteSingleRegister(address, value);
}
public void WriteMultipleHoldingRegisters(ushort address, ushort[] values)
{
this.connection.WriteMultipleRegisters(address, values);
}
public void Dispose()
{
if (this.connection != null)
{
this.connection.Dispose();
}
}
private static Assembly loadEmbeddedAssembly(string name)
{
if (name.EndsWith("Retargetable=Yes"))
{
return Assembly.Load(new AssemblyName(name));
}
var container = Assembly.GetExecutingAssembly();
var path = new AssemblyName(name).Name + ".dll";
using (var stream = container.GetManifestResourceStream(path))
{
if (stream == null)
{
return null;
}
var bytes = new byte[stream.Length];
stream.Read(bytes, 0, bytes.Length);
return Assembly.Load(bytes);
}
}
private readonly ModbusIpMaster connection;
}
}
这是修改后的Controller
类:
// ---------------------------------------------------------------------------------------------------------------------
// <copyright file="Controller.cs" company="Care Controls">
// Copyright (c) Care Controls Inc. All rights reserved.
// </copyright>
// ---------------------------------------------------------------------------------------------------------------------
namespace CareControls.Modbus.Tcp
{
using System;
using CareControls.Modbus.Tcp.Internal;
public class Controller
: ConnectionInfo,
HoldingRegisterReader,
InputRegisterReader,
CoilReader,
InputReader,
CoilWriter,
HoldingRegisterWriter
{
public Controller()
{
this.newDeviceConnection = () => new NModbusDeviceConnection(this.IP);
}
public virtual string IP { get; set; }
public virtual ushort[] ReadHoldingRegisters(ushort startAddress, ushort numberOfRegisters)
{
using (var connection = this.newDeviceConnection())
{
return connection.ReadHoldingRegisters(startAddress, numberOfRegisters);
}
}
public virtual ushort[] ReadInputRegisters(ushort startAddress, ushort numberOfRegisters)
{
using (var connection = this.newDeviceConnection())
{
return connection.ReadInputRegisters(startAddress, numberOfRegisters);
}
}
public virtual bool[] ReadCoils(ushort startAddress, ushort numberOfCoils)
{
using (var connection = this.newDeviceConnection())
{
return connection.ReadCoils(startAddress, numberOfCoils);
}
}
public virtual bool[] ReadInputs(ushort startAddress, ushort numberOfInputs)
{
using (var connection = this.newDeviceConnection())
{
return connection.ReadInputs(startAddress, numberOfInputs);
}
}
public virtual void WriteSingleCoil(ushort address, bool value)
{
using (var connection = this.newDeviceConnection())
{
connection.WriteSingleCoil(address, value);
}
}
public virtual void WriteMultipleCoils(ushort startAddress, bool[] values)
{
using (var connection = this.newDeviceConnection())
{
connection.WriteMultipleCoils(startAddress, values);
}
}
public virtual void WriteSingleHoldingRegister(ushort address, ushort value)
{
using (var connection = this.newDeviceConnection())
{
connection.WriteSingleHoldingRegister(address, value);
}
}
public virtual void WriteMultipleHoldingRegisters(ushort startAddress, ushort[] values)
{
using (var connection = this.newDeviceConnection())
{
connection.WriteMultipleHoldingRegisters(startAddress, values);
}
}
string ConnectionInfo.IP
{
get
{
return this.IP;
}
set
{
this.IP = value;
}
}
ushort[] HoldingRegisterReader.Read(ushort startAddress, ushort numberOfRegisters)
{
return this.ReadHoldingRegisters(startAddress, numberOfRegisters);
}
ushort[] InputRegisterReader.Read(ushort startAddress, ushort numberOfRegisters)
{
return this.ReadInputRegisters(startAddress, numberOfRegisters);
}
bool[] CoilReader.Read(ushort startAddress, ushort numberOfCoils)
{
return this.ReadCoils(startAddress, numberOfCoils);
}
bool[] InputReader.Read(ushort startAddress, ushort numberOfInputs)
{
return this.ReadInputs(startAddress, numberOfInputs);
}
void CoilWriter.WriteSingle(ushort address, bool value)
{
this.WriteSingleCoil(address, value);
}
void CoilWriter.WriteMultiple(ushort startAddress, bool[] values)
{
this.WriteMultipleCoils(startAddress, values);
}
void HoldingRegisterWriter.WriteSingle(ushort address, ushort value)
{
this.WriteSingleHoldingRegister(address, value);
}
void HoldingRegisterWriter.WriteMultiple(ushort startAddress, ushort[] values)
{
this.WriteMultipleHoldingRegisters(startAddress, values);
}
private readonly Func<NModbusDeviceConnection> newDeviceConnection;
}
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句