「copilot」タグの記事が1件件あります

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Collections.Generic;

namespace SocketSample
{
	// Command constants
	public static class Commands
	{
		public const string Start = "0001";
		public const string GetValue = "0002";
		public const string End = "0003";
	}

	// Result constants
	public static class Results
	{
		public const string OK = "0000";
		public const string NG = "9999";
	}

	// Request message (128 bytes)
	public class RequestMessage
	{
		public string SeqNo { get; set; } = "0000";
		public string Cmd { get; set; } = "0000";
		public string ReqData { get; set; } = new string('0', 64);
		public string Reserved { get; set; } = new string('0', 56); // 128 - (4+4+64)

		public byte[] ToBytes()
		{
			string msg = SeqNo + Cmd + ReqData + Reserved;
			return Encoding.ASCII.GetBytes(msg.PadRight(128, '0'));
		}

		public static RequestMessage FromBytes(byte[] data)
		{
			string msg = Encoding.ASCII.GetString(data);
			return new RequestMessage
			{
				SeqNo = msg.Substring(0, 4),
				Cmd = msg.Substring(4, 4),
				ReqData = msg.Substring(8, 64),
				Reserved = msg.Substring(72, 56)
			};
		}
	}

		public static RequestMessage FromBytes(byte[] data)
		{
			string msg = Encoding.ASCII.GetString(data);
			return new RequestMessage
			{
				SeqNo = msg.Substring(0, 4),
				Cmd = msg.Substring(4, 4),
				ReqData = msg.Substring(8, 64),
				Reserved = msg.Substring(72, 56)
			};
		}
	}

	// Response message (128 bytes)
	public class ResponseMessage
	{
		public string SeqNo { get; set; } = "0000";
		public string Cmd { get; set; } = "0000";
		public string Result { get; set; } = Results.OK;
		public string ResData { get; set; } = new string('0', 64);
		public string Reserved { get; set; } = new string('0', 56);

		public byte[] ToBytes()
		{
			string msg = SeqNo + Cmd + Result + ResData + Reserved;
			return Encoding.ASCII.GetBytes(msg.PadRight(128, '0'));
		}

		public static ResponseMessage FromBytes(byte[] data)
		{
			string msg = Encoding.ASCII.GetString(data);
			return new ResponseMessage
			{
				SeqNo = msg.Substring(0, 4),
				Cmd = msg.Substring(4, 4),
				Result = msg.Substring(8, 4),
				ResData = msg.Substring(12, 64),
				Reserved = msg.Substring(76, 52)
			};
		}
	}
}

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Collections.Generic;

namespace SocketSample
{
	public class Server
	{
		private TcpListener listener;
		private bool exitFlag = false;

		// Command dictionary
		private Dictionary<string, Action<RequestMessage>> commandHandlers;

		public Server()
		{
			commandHandlers = new Dictionary<string, Action<RequestMessage>>
			{
				{ Commands.Start, HandleStart },
				{ Commands.GetValue, HandleGetValue },
				{ Commands.End, HandleEnd }
			};
		}

		public void StartServer()
		{
			listener = new TcpListener(IPAddress.Parse("127.0.0.1"), 50001);
			listener.Start();
			Console.WriteLine("Server started. Waiting for connection...");

			while (!exitFlag)
			{
				if (!listener.Pending())
				{
					Thread.Sleep(100);
					continue;
				}

				TcpClient client = listener.AcceptTcpClient();
				Console.WriteLine("Client connected.");

				NetworkStream stream = client.GetStream();
				byte[] buffer = new byte[128];

				while (!exitFlag)
				{
					int read = stream.Read(buffer, 0, buffer.Length);
					if (read == 0) break;

					RequestMessage req = RequestMessage.FromBytes(buffer);
					Console.WriteLine($"Received Cmd={req.Cmd}, SeqNo={req.SeqNo}");

					// Call handler
					if (commandHandlers.ContainsKey(req.Cmd))
						commandHandlers[req.Cmd](req);

					// Build response
					ResponseMessage res = new ResponseMessage
					{
						SeqNo = req.SeqNo,
						Cmd = req.Cmd,
						Result = Results.OK,
						ResData = new string('0', 64)
					};

					stream.Write(res.ToBytes(), 0, 128);
					Console.WriteLine("Response sent.");
				}

				client.Close();
			}

			listener.Stop();
			Console.WriteLine("Server stopped.");
		}

	// Command handlers
	private void HandleStart(RequestMessage req) => Console.WriteLine("Start command executed.");
	private void HandleGetValue(RequestMessage req) => Console.WriteLine("GetValue command executed.");
	private void HandleEnd(RequestMessage req) => Console.WriteLine("End command executed.");
	public void StopServer() => exitFlag = true;
	}
}

using System;
using System.Net.Sockets;
using System.Text;
using System.Collections.Generic;

namespace SocketSample
{
	public class Client
	{
		private TcpClient client;
		private NetworkStream stream;
		private int globalSeqNo = 0;

		private Dictionary<string, Action> commandMethods;

		public Client()
		{
			commandMethods = new Dictionary<string, Action>
			{
				{ Commands.Start, Start },
				{ Commands.GetValue, GetValue },
				{ Commands.End, End }
			};
		}

		public void Connect()
		{
			client = new TcpClient("127.0.0.1", 50001);
			stream = client.GetStream();
			Console.WriteLine("Connected to server.");
		}
		private void SendRequest(string cmd)
		{
			globalSeqNo++;
			RequestMessage req = new RequestMessage
			{
				SeqNo = globalSeqNo.ToString("D4"),
				Cmd = cmd,
				ReqData = new string('0', 64)
			};

			stream.Write(req.ToBytes(), 0, 128);
			Console.WriteLine($"Request sent. Cmd={cmd}, SeqNo={req.SeqNo}");

			byte[] buffer = new byte[128];
			int read = stream.Read(buffer, 0, buffer.Length);

			ResponseMessage res = ResponseMessage.FromBytes(buffer);
			if (res.SeqNo != req.SeqNo)
				Console.WriteLine("Error: SeqNo mismatch!");
			else
				Console.WriteLine($"Response OK. Cmd={res.Cmd}, SeqNo={res.SeqNo}");
		}

		// Command methods
		public void Start() => SendRequest(Commands.Start);
		public void GetValue() => SendRequest(Commands.GetValue);
		public void End() => SendRequest(Commands.End);

		public void Close()
		{
			stream.Close();
			client.Close();
		}
	}
}