通过流处理不同的类类型
本文关键字:类型 处理 | 更新日期: 2023-09-27 18:35:48
我正在编写一个基于TCP连接的DLL。
基本前提是它可以被任何客户端使用,客户端需要做的就是提供一个IP地址和一个端口号,然后dll负责连接,传输消息,检测断开连接等。dll 公开 3 个事件Connected
、Disconnected
和MessageReceived
客户端只需连接到这些事件即可使用它。DLL 还定义了一个基Message
类,客户端可以从该类继承,然后将自己的类/对象传递到 DLL 中以进行发送/接收。
在 dll 中,我定义了一个Packet
类和支持类型:
[Serializable]
internal class Packet
{
private MessageType _type;
private MessageItem _item;
public MessageType MYtpe
{
get
{
return _type;
}
set
{
_type = value;
}
}
//similar for MessageItem
// ...
}
枚举:
public enum MessageType
{
None,
PollItem,
Binary1,
Binary2
}
和对象/类发送的基类:
public abstract class MessageItem
{
}
我的低级别,发送类,代码,隐藏在DLL中,然后是这个(没有错误处理)
internal bool SendPacket(Packet p)
{
bool sentOk = false;
BinaryFormatter bin = new BinaryFormatter();
try
{
bin.Serialize(theNetworkStream, p);
}
catch etc..
}
ReadPacket
基本上与此相反。
dll 公开一个函数供客户端使用,该函数构造数据包并调用上面的发送函数
public void SendMessage(MessageType type, MessageItem message)
现在是客户端。因为我在 DLL 中定义了 2 个二进制枚举类型,所以我可以在客户端代码中使用 2 个单独的类。
例如
public class Employee : MessageItem
{
string name;
//etc
}
并且,说:
public class Car : MessageItem
{
string Model;
//etc
}
这一切都有效,我可以通过执行以下操作来接收两种类型中的任何一种:
if(myConnection.NextMessageType() == MessageType.Binary1)
{
Employee e = (Employee)myConnection.ReadMessage();
}
if(myConnection.NextMessageType() == MessageType.Binary2)
{
Car c = (Car)myConnection.ReadMessage();
}
只要客户端始终以binary1
发送Employee
类型,以binary2
发送Car
类型。
如果我想发送第三种类型的对象/类,目前我必须进入 dll,添加一个枚举; binary3
,重建 dll,然后我可以在我的客户端中再次派生并在上面的接收代码中使用第 3 个 if
-子句。
if(myConnection.NextMessageType() == MessageType.Binary3)
{
Animal a = (Animal)myConnection.ReadMessage();
}
所以最后进入我的问题!
有没有办法避免重建 DLL,但客户端可以通过 DLL 发送任意数量的不同类类型,并且 DLL 中的发送/接收机制(对客户端隐藏)仍然有效?我也认为一长串if messagetype == 1, 2 3
等突出了一个糟糕的设计,但我无法弄清楚什么是更好的设计。
如果你走到了这一步,明白我在问什么,谢谢! 真的很感激解决方案。
最简单的解决方案是将 MessageType 枚举更改为字符串并完全摆脱枚举。改变:-
public void SendMessage(MessageType type, MessageItem message)
变成只是:-
public void SendMessage(MessageItem message)
,然后将发送数据包更改为:
internal bool SendPacket(Packet p)
{
bool sentOk = false;
BinaryFormatter bin = new BinaryFormatter();
try
{
bin.write (p.MessageItem.GetType ().Name); // or whatever the write/serialise function is called
bin.Serialize(theNetworkStream, p);
}
catch etc..
}
然后,接收方首先读取字符串,然后使用反射创建该类型的对象,然后在伪代码中反序列化为该对象:
string message_type = ethernet.readstring ();
Type item_type = convert_name_to_object_type;
ConstructorInfo constructor = item_type.GetConstructor ();
object item = constructor.Invoke ();
ethernet.Deserialise (item);
invoke MessageReceived event (item);
最后一部分可以使用SortedDicationary <message type name, message handler delegate>
将消息调度到正确的处理程序(但这会强制处理程序将 MessageItem 参数类型转换为正确的消息类型)。或者,再次使用反射来查找一个名为"HandleEthernetMessage"的方法,该方法采用通过以太网接收的类型的一个参数。 SortedDicationary <message type name, method info>
运行时会更快,并克服第一个 SortedDictionary 问题。