using (NetMQSocket clientSocket = new StreamSocket()) { NetMQProactor proactor = new NetMQProactor(clientSocket, ProcessMessage); NetMQBeacon n = new NetMQBeacon();
Random rd = new Random(); int num = rd.Next(0, 100); clientSocket.Connect("tcp://127.0.0.1:5003"); while (true) { Console.WriteLine(num + ",Please enter your message:"); string message = Console.ReadLine(); clientSocket.SendMoreFrame(clientSocket.Options.Identity); clientSocket.SendFrame(num + ":" + message); if (message == "exit") { break; } } } } public static void ProcessMessage(NetMQSocket socket, NetMQMessage message) { byte[] serverId = message.First.ToByteArray(true); string answer = System.Text.Encoding.Default.GetString(message.Last.Buffer); Console.WriteLine("Answer from server:{0}", answer); } }
{
static void Main(string[] args)
{
using (NetMQSocket clientSocket = new StreamSocket())
{
NetMQProactor proactor = new NetMQProactor(clientSocket, ProcessMessage);
NetMQBeacon n = new NetMQBeacon();
Random rd = new Random();
int num = rd.Next(0, 100);
clientSocket.Connect("tcp://127.0.0.1:5003");
while (true)
{
Console.WriteLine(num + ",Please enter your message:");
string message = Console.ReadLine();
clientSocket.SendMoreFrame(clientSocket.Options.Identity);
clientSocket.SendFrame(num + ":" + message);
if (message == "exit")
{
break;
}
}
}
}
public static void ProcessMessage(NetMQSocket socket, NetMQMessage message)
{
byte[] serverId = message.First.ToByteArray(true);
string answer = System.Text.Encoding.Default.GetString(message.Last.Buffer);
Console.WriteLine("Answer from server:{0}", answer);
} }