using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.IO;
namespace Server
{
public partial class Form1 : Form
{
TcpListener listener;
TcpClient client;
NetworkStream networkStream;
MemoryStream memoryStream;
Bitmap bitmap;
IPHostEntry ipHostEntry;
Thread thread;
string serverIP;
int serverPort;
byte[] data = new byte[1048576]; // 1MB
byte[] dataSizeFromClient;
int receivedDataSize;
int expectedDataSize;
public Form1()
{
InitializeComponent();
pictureBox1.SizeMode = PictureBoxSizeMode.StretchImage;
serverPort = 7000;
// 호스트 이름으로 검색되는 첫 번째 IP4 주소 확인
string hostName = Dns.GetHostName();
ipHostEntry = Dns.GetHostEntry(hostName);
foreach (IPAddress address in ipHostEntry.AddressList)
{
if (address.AddressFamily == AddressFamily.InterNetwork)
{
serverIP = address.ToString();
break;
}
}
listBox1.Items.Add("Server IP: " + serverIP);
listener = new TcpListener(IPAddress.Any, serverPort);
//listener = new TcpListener(IPAddress.Parse("127.0.0.1"), serverPort);
}
private void ThreadProc()
{
listener.Start();
client = listener.AcceptTcpClient();
listBox1.Items.Add("Client IP: " + client.Client.RemoteEndPoint.ToString().Split(':')[0]);
networkStream = client.GetStream();
receivedDataSize = 0;
dataSizeFromClient = new byte[sizeof(int)];
if (networkStream.CanRead)
{
// 클라이언트로 부터 받아야 할 데이터 사이즈 정보 확인.
networkStream.Read(dataSizeFromClient, 0, dataSizeFromClient.Length);
expectedDataSize = BitConverter.ToInt32(dataSizeFromClient, 0);
listBox1.Items.Add("Expected data size: " + (expectedDataSize / 1024).ToString() + "KB");
// 데이터 송신
do
{
receivedDataSize += networkStream.Read(data, receivedDataSize, data.Length - receivedDataSize);
// Reads data from the NetworkStream and stores it to a byte array.
} while (networkStream.DataAvailable);
// while (expectedDataSize > receivedDataSize);
}
listBox1.Items.Add("Data received: " + (receivedDataSize / 1024).ToString() + "KB");
memoryStream = new MemoryStream(data, 0, receivedDataSize);
// Initializes a new non-resizable instance of the MemoryStream class
// based on the specified region (index) of a byte array.
bitmap = new Bitmap(memoryStream);
pictureBox1.Image = bitmap;
listener.Stop();
client.Close();
networkStream.Close();
memoryStream.Close();
}
private void button1_Click(object sender, EventArgs e)
{
// 클라이언트 접속 대기를 위한 스레드 생성(스레드는 1개만 생성한다)
if (thread == null || !thread.IsAlive)
{
thread = new Thread(new ThreadStart(ThreadProc));
thread.Start();
listBox1.Items.Add("Waiting for a client...");
}
}
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
if (thread != null && thread.IsAlive)
{
// 클라이언트 접속 대기 종료
listener.Stop();
//thread.Abort();
}
}
}
}
