您好,登錄后才能下訂單哦!
本篇內容介紹了“Remoting如何測試”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!
服務端與客戶端通信對象,盡量放在一個共享庫中,需要繼續MarshalByRefObject類
using System;
using System.Collections.Generic;
namespace MessageObject
{
public class RemoteObject : MarshalByRefObject
{
public static Queue<string> qMessage { get; set; }
public string SendMessage(string message)
{
if (qMessage == null)
{
qMessage = new Queue<string>();
}
qMessage.Enqueue(message);
return message;
}
}
}
單獨建立一個控制臺工程,引入帶有上面通信對象的共享庫,注冊Remoting通道,開啟Remoting服務,等待客戶端調用。
using MessageObject;
using System;
using System.Collections.Generic;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Channels.Ipc;
using System.Threading;
namespace IPCServer
{
class Program
{
static void Main(string[] args)
{
StartServer();
Thread thread = new Thread(new ThreadStart(ReceviceMessage));
thread.Start();
}
private static void StartServer()
{
IpcServerChannel channel = new IpcServerChannel("ServerChannel");
ChannelServices.RegisterChannel(channel, false);
RemotingConfiguration.RegisterWellKnownServiceType(typeof(RemoteObject), "RemoteObject", WellKnownObjectMode.SingleCall);
Console.WriteLine("消息服務啟動...");
}
private static void ReceviceMessage()
{
while (true)
{
Queue<string> qMessage = RemoteObject.qMessage;
if (qMessage != null)
{
if (qMessage.Count > 0)
{
string message = qMessage.Dequeue();
Console.WriteLine("接收消息是:" + message);
}
}
Thread.Sleep(1000);
}
}
}
}
單獨建立一個客戶端測試控制臺工程,連接服務端Remoting服務,調用服務端通信對象,達到訪問服務端的目的
using MessageObject;
using System;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Channels.Ipc;
namespace IPCClient
{
class Program
{
static void Main(string[] args)
{
RemoteObject objRemoteObject = ConnectServer();
Send(objRemoteObject);
}
private static void Send(RemoteObject objRmoteObject)
{
while (true)
{
Console.WriteLine("請輸入消息...");
string message = Console.ReadLine();
try
{
objRmoteObject.SendMessage(message);
Console.WriteLine("發送成功");
}
catch (Exception ex)
{
Console.WriteLine($"無法連接到消息服務:{ex.Message}");
}
}
}
private static RemoteObject ConnectServer()
{
IpcClientChannel channel = new IpcClientChannel();
ChannelServices.RegisterChannel(channel, false);
RemoteObject objRemoteObject = (RemoteObject)Activator.GetObject(typeof(RemoteObject), "ipc://ServerChannel/RemoteObject");
return objRemoteObject;
}
}
}
通信對象如果必須放在兩個不同的解決方案或者工程中,當客戶端無法訪問服務端遠程對象時,比如提示:“連接到 IPC 端口失敗: 系統找不到指定的文件。”,可使用此demo測試:
服務端是否先于客戶端開啟?
嘗試檢查兩端通信對象命名空間一致嗎?比如服務端遠程對象命令空間定義為:namespace MessageObjectServer,客戶端為:namespace MessageObjectClient,這樣肯定不行的
通信使用的屬性定義相同嗎?比如都要使用這個屬性:public static Queue qMessage { get; set; },服務端定義為Queue<string>,客戶端定義為List<string>,這樣也是不行的。
“Remoting如何測試”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。