ImageSample sample added

2026-05-14 06:06:30 +09:00 · 2010-10-30 21:29:10 +00:00
parent f589208841
commit e866600c98
24 changed files with 1818 additions and 0 deletions
--- a/Samples/ImageSample/ImageServer/Program.cs
+++ b/Samples/ImageSample/ImageServer/Program.cs
@@ -0,0 +1,170 @@
+using System;
+using System.Collections.Generic;
+using System.Windows.Forms;
+
+using Lidgren.Network;
+using SamplesCommon;
+using System.Drawing;
+
+namespace ImageServer
+{
+	static class Program
+	{
+		public static Form1 MainForm;
+		public static NetServer Server;
+		public static byte[] ImageData;
+		public static int ImageWidth, ImageHeight;
+
+		[STAThread]
+		static void Main()
+		{
+			Application.EnableVisualStyles();
+			Application.SetCompatibleTextRenderingDefault(false);
+			MainForm = new Form1();
+
+			// create a configuration, use identifier "ImageTransfer" - same as client
+			NetPeerConfiguration config = new NetPeerConfiguration("ImageTransfer");
+			config.EnableMessageType(NetIncomingMessageType.ConnectionApproval);
+			config.EnableMessageType(NetIncomingMessageType.DiscoveryRequest);
+
+			// listen on port 14242
+			config.Port = 14242;
+
+			Server = new NetServer(config);
+
+			System.IO.File.Delete("C:\\tmp\\clientlog.txt");
+			System.IO.File.Delete("C:\\tmp\\serverlog.txt");
+
+			Application.Idle += new EventHandler(AppLoop);
+			Application.Run(MainForm);
+		}
+
+		static void AppLoop(object sender, EventArgs e)
+		{
+			NetIncomingMessage inc;
+
+			while (NativeMethods.AppStillIdle)
+			{
+				// read any pending messages
+				while ((inc = Server.WaitMessage(100)) != null)
+				{
+					switch (inc.MessageType)
+					{
+						case NetIncomingMessageType.DebugMessage:
+						case NetIncomingMessageType.VerboseDebugMessage:
+						case NetIncomingMessageType.WarningMessage:
+						case NetIncomingMessageType.ErrorMessage:
+							// just print any message
+							string str = inc.ReadString();
+							NativeMethods.AppendText(MainForm.richTextBox1, str);
+							System.IO.File.AppendAllText("C:\\tmp\\serverlog.txt", str + Environment.NewLine);
+							break;
+						case NetIncomingMessageType.DiscoveryRequest:
+							NetOutgoingMessage dom = Server.CreateMessage();
+							dom.Write("Kokosboll");
+							Server.SendDiscoveryResponse(dom, inc.SenderEndpoint);
+							break;
+						case NetIncomingMessageType.ConnectionApproval:
+
+							// Here we could check inc.SenderConnection.RemoteEndPoint, deny certain ip
+
+							// check hail data
+							try
+							{
+								int a = inc.ReadInt32();
+								string s = inc.ReadString();
+
+								if (a == 42 && s == "secret")
+									inc.SenderConnection.Approve();
+								else
+									inc.SenderConnection.Deny("Bad approve data, go away!");
+							}
+							catch (NetException)
+							{
+								inc.SenderConnection.Deny("Bad approve data, go away!");
+							}
+							break;
+						case NetIncomingMessageType.StatusChanged:
+							NetConnectionStatus status = (NetConnectionStatus)inc.ReadByte();
+							NativeMethods.AppendText(MainForm.richTextBox1, "New status: " + status + " (" + inc.ReadString() + ")");
+							if (status == NetConnectionStatus.Connected)
+							{
+								//
+								// A client connected; send the entire image in chunks of 990 bytes
+								//
+								/*
+								uint seg = 0;
+								int ptr = 0;
+								while (ptr < ImageData.Length)
+								{
+									int l = ImageData.Length - ptr > 990 ? 990 : ImageData.Length - ptr;
+									NetOutgoingMessage om = Server.CreateMessage(l);
+									om.Write((ushort)ImageWidth);
+									om.Write((ushort)ImageHeight);
+									om.WriteVariableUInt32(seg++);
+									om.Write(ImageData, ptr, l);
+									ptr += 990;
+
+									Server.SendMessage(om, inc.SenderConnection, NetDeliveryMethod.ReliableUnordered, 0);
+								}
+								*/
+
+								NetOutgoingMessage om = Server.CreateMessage(ImageData.Length + 5);
+
+								om.Write((ushort)ImageWidth);
+								om.Write((ushort)ImageHeight);
+								om.WriteVariableUInt32(0);
+
+								// send entire as a large message that will be automatically fragmented by the library
+								om.Write(ImageData);
+
+								Server.SendMessage(om, inc.SenderConnection, NetDeliveryMethod.ReliableOrdered, 0);
+
+								// all messages will be sent before disconnect so we can call it here
+								// inc.SenderConnection.Disconnect("Bye bye now");
+							}
+							break;
+					}
+
+					// recycle message to avoid garbage
+					Server.Recycle(inc);
+				}
+			}
+		}
+
+		public static void Start(string filename)
+		{
+			if (Server.Status != NetPeerStatus.NotRunning)
+			{
+				Server.Shutdown("Restarting");
+				System.Threading.Thread.Sleep(100);
+			}
+
+			Server.Start();
+
+			MainForm.Text = "Server: Running";
+
+			// get image size
+			Bitmap bm = Bitmap.FromFile(filename) as Bitmap;
+			ImageWidth = bm.Width;
+			ImageHeight = bm.Height;
+
+			// extract color bytes
+			// very slow method, but small code size
+			ImageData = new byte[3 * ImageWidth * ImageHeight];
+			int ptr = 0;
+			for (int y = 0; y < ImageHeight; y++)
+			{
+				for (int x = 0; x < ImageWidth; x++)
+				{
+					Color color = bm.GetPixel(x, y);
+					ImageData[ptr++] = color.R;
+					ImageData[ptr++] = color.G;
+					ImageData[ptr++] = color.B;
+				}
+			}
+
+			bm.Dispose();
+		}
+	}
+}