TCP Archives - icodebroker

[PYTHON/COMMON] socket 클래스 : 단순 TCP 서버/클라이언트 만들기

■ socket 클래스를 사용해 단순 TCP 서버/클라이언트를 만드는 방법을 보여준다. ▶ server.py


import json
import socket

def startServer(hostIPAddress, hosePort):
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as socket1:
        socket1.bind((hostIPAddress, hosePort))
        socket1.listen()

        print(f"클라이언트 요청 수신중 : {hostIPAddress}:{hosePort}")

        while True:
            socket2, clientAddress = socket1.accept()

            with socket2:
                print(f"클라이언트 연결 : {clientAddress}")

                while True:
                    receiveBytes = socket2.recv(1024)

                    if not receiveBytes:
                        break

                    receiveDictionary = json.loads(receiveBytes.decode())

                    print(f"수신 데이터 : {receiveDictionary}")

                    sendDictonary = {"status" : "success", "message" : "Data received"}

                    socket2.sendall(json.dumps(sendDictonary).encode())

            print(f"클라이언트 연결 종료 : {clientAddress}")

if __name__ == "__main__":
    startServer("127.0.0.1", 12345)

import json

import socket

def startServer(hostIPAddress, hosePort):

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as socket1:

socket1.bind((hostIPAddress, hosePort))

socket1.listen()

print(f"클라이언트 요청 수신중 : {hostIPAddress}:{hosePort}")

while True:

socket2, clientAddress = socket1.accept()

with socket2:

print(f"클라이언트 연결 : {clientAddress}")

while True:

receiveBytes = socket2.recv(1024)

if not receiveBytes:

break

receiveDictionary = json.loads(receiveBytes.decode())

print(f"수신 데이터 : {receiveDictionary}")

sendDictonary = {"status" : "success", "message" : "Data received"}

socket2.sendall(json.dumps(sendDictonary).encode())

print(f"클라이언트 연결 종료 : {clientAddress}")

if __name__ == "__main__":

startServer("127.0.0.1", 12345)

▶ client.py —————————————————————————————————- import json import socket def start_client(serverIPAddress,

[RUST/COMMON] TCP 프로토콜을 사용해 간이 채팅 프로그램 만들기

■ TCP 프로토콜을 사용해 간이 채팅 프로그램을 만드는 방법을 보여준다. [test_server 프로젝트] ▶ src/main.rs


use std::io;
use std::io::BufRead;
use std::io::Write;
use std::net;
use std::sync::mpsc;
use std::thread;
use std::time;

fn main()
{
    let server_address : &str = "127.0.0.1:8888";

    let (tx, rx) = mpsc::channel::<String>();

    let mut tcp_stream_vector : Vec<net::TcpStream> = Vec::new();

    let tcp_listener : net::TcpListener = net::TcpListener::bind(server_address).expect("서버 실행시 에러가 발생했습니다.");

    tcp_listener.set_nonblocking(true).expect("넌블로킹 모드 설정시 에러가 발생했습니다.");

    println!("서버 실행이 시작되었습니다 : {}", server_address);

    loop
    {
        if let Ok((client, client_address)) = tcp_listener.accept()
        {
            println!("클라이언트가 접속했습니다 : {}", client_address);

            tcp_stream_vector.push(client.try_clone().unwrap());

            start_thread(client, tx.clone());
        }

        if let Ok(client_message) = rx.try_recv()
        {
            println!("모든 클라기언트에게 메시지 전송 : {}", client_message.trim());

            tcp_stream_vector = reply_to_all_clients(tcp_stream_vector, &client_message);
        }

        thread::sleep(time::Duration::from_millis(100));
    }
}

fn start_thread(tcp_stream : net::TcpStream, tx : mpsc::Sender<String>)
{
    let mut buf_reader : io::BufReader<net::TcpStream> = io::BufReader::new(tcp_stream);

    thread::spawn
    (
        move ||
        {
            loop
            {
                let mut message : String = String::new();

                if let Ok(byte_count_read) = buf_reader.read_line(&mut message)
                {
                    if byte_count_read > 0
                    {
                        tx.send(message).unwrap();
                    }
                }

                thread::sleep(time::Duration::from_millis(100));
            }
        }
    );
}

fn reply_to_all_clients(tcp_stream_vector : Vec<net::TcpStream>, message : &str) -> Vec<net::TcpStream>
{
    let mut new_tcp_stream_vector : Vec<net::TcpStream> = vec![];

    for mut tcp_stream in tcp_stream_vector.into_iter()
    {
        let message_byte_vector : Vec<u8> = String::from(message).into_bytes();

        if let Err(e) = tcp_stream.write_all(&message_byte_vector)
        {
            println!("전송시 에러가 발생했습니다 : {}", e);

            continue;
        }

        new_tcp_stream_vector.push(tcp_stream);
    }

    return new_tcp_stream_vector;
}

use std::io;

use std::io::BufRead;

use std::io::Write;

use std::net;

use std::sync::mpsc;

use std::thread;

use std::time;

fn main()

{

let server_address : &str = "127.0.0.1:8888";

let (tx, rx) = mpsc::channel::<String>();

let mut tcp_stream_vector : Vec<net::TcpStream> = Vec::new();

let tcp_listener : net::TcpListener = net::TcpListener::bind(server_address).expect("서버 실행시 에러가 발생했습니다.");

tcp_listener.set_nonblocking(true).expect("넌블로킹 모드 설정시 에러가 발생했습니다.");

println!("서버 실행이 시작되었습니다 : {}", server_address);

loop

{

if let Ok((client, client_address)) = tcp_listener.accept()

{

println!("클라이언트가 접속했습니다 : {}", client_address);

tcp_stream_vector.push(client.try_clone().unwrap());

start_thread(client, tx.clone());

}

if let Ok(client_message) = rx.try_recv()

{

println!("모든 클라기언트에게 메시지 전송 : {}", client_message.trim());

tcp_stream_vector = reply_to_all_clients(tcp_stream_vector, &client_message);

}

thread::sleep(time::Duration::from_millis(100));

}

fn start_thread(tcp_stream : net::TcpStream, tx : mpsc::Sender<String>)

{

let mut buf_reader : io::BufReader<net::TcpStream> = io::BufReader::new(tcp_stream);

thread::spawn

(

move ||

{

loop

{

let mut message : String = String::new();

if let Ok(byte_count_read) = buf_reader.read_line(&mut message)

{

if byte_count_read > 0

{

tx.send(message).unwrap();

}

thread::sleep(time::Duration::from_millis(100));

}

);

}

fn reply_to_all_clients(tcp_stream_vector : Vec<net::TcpStream>, message : &str) -> Vec<net::TcpStream>

{

let mut new_tcp_stream_vector : Vec<net::TcpStream> = vec![];

for mut tcp_stream in tcp_stream_vector.into_iter()

{

let message_byte_vector : Vec<u8> = String::from(message).into_bytes();

if let Err(e) = tcp_stream.write_all(&message_byte_vector)

{

println!("전송시 에러가 발생했습니다 : {}", e);

continue;

}

new_tcp_stream_vector.push(tcp_stream);

}

return new_tcp_stream_vector;

}

[test_client 프로젝트] ▶ src/main.rs


use std::io;
use std::io::BufRead;
use std::io::Write;
use std::net;
use std::thread;
use std::time;

fn main()
{
    let server_addresss : &str = "127.0.0.1:8888";

    let mut tcp_stream : net::TcpStream = net::TcpStream::connect(server_addresss).expect("서버 접속시 에러가 발생했습니다.");

    tcp_stream.set_nonblocking(true).expect("넌블로킹 모드 설정시 에러가 발생했습니다.");

    println!("서버에 접속했습니다 : {}", server_addresss);

    start_thread(tcp_stream.try_clone().unwrap());

    let user_name : String = input("사용자명을 입력해 주시기 바랍니다.");

    println!("{}님 메시지를 입력해 주시기 바랍니다.", user_name);

    loop
    {
        let message : String = input("");

        let message : String = format!("{} > {}\n", user_name, message);

        let message_byte_array : &[u8] = message.as_bytes();

        tcp_stream.write_all(message_byte_array).unwrap();
    }
}

fn start_thread(tcp_stream : net::TcpStream)
{
    let mut reader : io::BufReader<net::TcpStream> = io::BufReader::new(tcp_stream);

    thread::spawn
    (
        move ||
        {
            loop
            {
                let mut message : String = String::new();

                if let Ok(byte_count_read) = reader.read_line(&mut message)
                {
                    if byte_count_read > 0
                    {
                        println!("입력 메시지 : {}", message.trim());
                    }
                }

                thread::sleep(time::Duration::from_millis(100));
            }
        }
    );
}

fn input(display_message : &str) -> String
{
    if display_message != ""
    {
        println!("{}", display_message);
    }

    let mut input_message : String = String::new();

    io::stdin().read_line(&mut input_message).expect("메시지 입력시 에러가 발생했습니다.");

    return String::from(input_message.trim());
}

use std::io;

use std::io::BufRead;

use std::io::Write;

use std::net;

use std::thread;

use std::time;

fn main()

{

let server_addresss : &str = "127.0.0.1:8888";

let mut tcp_stream : net::TcpStream = net::TcpStream::connect(server_addresss).expect("서버 접속시 에러가 발생했습니다.");

tcp_stream.set_nonblocking(true).expect("넌블로킹 모드 설정시 에러가 발생했습니다.");

println!("서버에 접속했습니다 : {}", server_addresss);

start_thread(tcp_stream.try_clone().unwrap());

let user_name : String = input("사용자명을 입력해 주시기 바랍니다.");

println!("{}님 메시지를 입력해 주시기 바랍니다.", user_name);

loop

{

let message : String = input("");

let message : String = format!("{} > {}\n", user_name, message);

let message_byte_array : &[u8] = message.as_bytes();

tcp_stream.write_all(message_byte_array).unwrap();

}

fn start_thread(tcp_stream : net::TcpStream)

{

let mut reader : io::BufReader<net::TcpStream> = io::BufReader::new(tcp_stream);

thread::spawn

(

move ||

{

loop

{

let mut message : String = String::new();

if let Ok(byte_count_read) = reader.read_line(&mut message)

{

if byte_count_read > 0

{

println!("입력 메시지 : {}", message.trim());

}

thread::sleep(time::Duration::from_millis(100));

}

);

}

fn input(display_message : &str) -> String

{

if display_message != ""

{

println!("{}", display_message);

}

let mut input_message : String = String::new();

io::stdin().read_line(&mut input_message).expect("메시지 입력시 에러가 발생했습니다.");

return String::from(input_message.trim());

}

test_server.zip test_client.zip

[PYTHON/COMMON] socket 클래스 사용하기

■ socket 클래스를 사용하는 기본적인 방법을 보여준다. [TestServer 프로젝트] ▶ main.py


import socket

HOST = ""
PORT = 50007

socket1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

socket1.bind((HOST, PORT))

socket1.listen(1)

socket2, addressTuple = socket1.accept()

print("{0}에 연결되었습니다.".format(addressTuple))

while True:
    data = socket2.recv(1024)

    if not data:
        break

    socket2.send(data)

socket2.close()

import socket

HOST = ""

PORT = 50007

socket1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

socket1.bind((HOST, PORT))

socket1.listen(1)

socket2, addressTuple = socket1.accept()

print("{0}에 연결되었습니다.".format(addressTuple))

while True:

data = socket2.recv(1024)

if not data:

break

socket2.send(data)

socket2.close()

[TestClient 프로젝트] ▶ main.py


import socket

HOST = "127.0.0.1"
PORT = 50007

socket1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

socket1.connect((HOST, PORT))

socket1.send("안녕하세요, 파이썬".encode())

data = socket1.recv(1024)

socket1.close()

print("수신 데이터 : {0}".format(repr(data.decode())))

import socket

HOST = "127.0.0.1"

PORT = 50007

socket1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

socket1.connect((HOST, PORT))

socket1.send("안녕하세요, 파이썬".encode())

data = socket1.recv(1024)

socket1.close()

print("수신 데이터 : {0}".format(repr(data.decode())))

[C#/COMMON] Socket 클래스 : 연결시 타임아웃 처리하기

■ Socket 클래스에서 연결시 타임아웃을 처리하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Net;
using System.Net.Sockets;

#region 연결하기 - Connect(socket, endpoint, timeout)

/// <summary>
/// 연결하기
/// </summary>
/// <param name="socket">소켓</param>
/// <param name="endpoint">종단 포인트</param>
/// <param name="timeout">타임아웃</param>
public void Connect(Socket socket, EndPoint endpoint, TimeSpan timeout)
{
    IAsyncResult result = socket.BeginConnect(endpoint, null, null);

    bool success = result.AsyncWaitHandle.WaitOne(timeout, true);

    if(success)
    {
        socket.EndConnect(result);
    }
    else
    {
        socket.Close();

        throw new SocketException(10060); // 연결 타임 아웃
    }
}

#endregion

using System;

using System.Net;

using System.Net.Sockets;

#region 연결하기 - Connect(socket, endpoint, timeout)

/// <summary>

/// 연결하기

/// </summary>

/// <param name="socket">소켓</param>

/// <param name="endpoint">종단 포인트</param>

/// <param name="timeout">타임아웃</param>

public void Connect(Socket socket, EndPoint endpoint, TimeSpan timeout)

{

IAsyncResult result = socket.BeginConnect(endpoint, null, null);

bool success = result.AsyncWaitHandle.WaitOne(timeout, true);

if(success)

{

socket.EndConnect(result);

}

else

{

socket.Close();

throw new SocketException(10060); // 연결 타임 아웃

}

#endregion

[C#/COMMON] TcpListener 클래스 : Pending 메소드를 사용해 신규 연결시 기존 연결 버리기

■ TcpListener 클래스의 Pending 메소드를 사용해 신규 연결시 기존 연결을 버리는 방법을 보여준다. ▶ TcpListener 클래스 : Pending 메소드를 사용해 신규 연결시

[C#/COMMON] TcpListener 클래스 : TCP 서버 사용하기

■ TcpListener 클래스에서 TCP 서버를 사용하는 방법을 보여준다. [TestServer 프로젝트] ▶ MainForm.cs


using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Security.Cryptography;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace TestServer
{
    /// <summary>
    /// 메인 폼
    /// </summary>
    public partial class MainForm : Form
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// TCP 리스너
        /// </summary>
        private TcpListener tcpListener;

        /// <summary>
        /// TCP 클라이언트
        /// </summary>
        private TcpClient tcpClient;

        /// <summary>
        /// 네트워크 스트림
        /// </summary>
        private NetworkStream networkStream;

        /// <summary>
        /// 스트림 라이터
        /// </summary>
        private StreamWriter streamWriter;

        /// <summary>
        /// 서버 작업 여부
        /// </summary>
        private bool isServerWorking = false;

        /// <summary>
        /// 스레드
        /// </summary>
        private Thread thread;

        /// <summary>
        /// 트리플 DES 암호 서비스 공급자
        /// </summary>
        private TripleDESCryptoServiceProvider tripleDESCryptoServiceProvider = new TripleDESCryptoServiceProvider();

        /// <summary>
        /// 개인 키 바이트 배열
        /// </summary>
        private byte[] privateKeyByteArray = new byte[]
        {
            98 , 45 , 125, 56, 1 , 60 , 11, 38 ,
            123, 54 , 234, 9 , 76, 20 , 44, 7  ,
            12 , 223, 219, 95, 48, 156, 32, 239
        };

        /// <summary>
        /// 개인 키 초기 값 바이트 배열
        /// </summary>
        private byte[] privateKeyInitialValueByteArray = new byte[]
        {
            67, 12, 3, 41, 66, 78, 34, 123
        };

        /// <summary>
        /// 난수기
        /// </summary>
        Random random = new Random();

        /// <summary>
        /// 임의 값
        /// </summary>
        private int randomValue = 0;

        /// <summary>
        /// 임의 개인 키 바이트 배열
        /// </summary>
        private byte[] randomPrivateKeyByteArray = null;

        /// <summary>
        /// 임의 개인 키 초기 값 바이트 배열
        /// </summary>
        private byte[] randomPrivateKeyInitialValueByteArray = null;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - MainForm()

        /// <summary>
        /// 생성자
        /// </summary>
        public MainForm()
        {
            InitializeComponent();

            #region 이벤트를 설정한다.

            this.Load             += Form_Load;
            this.FormClosing      += Form_FormClosing;
            this.sendButton.Click += sendButton_Click;
            this.timer.Tick       += timer_Tick;

            #endregion
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Private
        //////////////////////////////////////////////////////////////////////////////// Event

        #region 폼 로드시 처리하기 - Form_Load(sender, e)

        /// <summary>
        /// 폼 로드시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e"></param>
        private void Form_Load(object sender, EventArgs e)
        {
            this.isServerWorking = true;

            IPAddress ipAddress = new IPAddress(0);

            this.tcpListener = new TcpListener(ipAddress, 2014);

            this.tcpListener.Start();

            this.thread = new Thread(StartServer);

            this.thread.Start();

            this.timer.Enabled = true;

            this.randomValue = this.random.Next(1, 9);

            SetRandomPrivateKeyByteArray(this.randomValue);
        }

        #endregion
        #region 폼을 닫을 경우 처리하기 - Form_FormClosing(sender, e)

        /// <summary>
        /// 폼을 닫을 경우 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void Form_FormClosing(object sender, FormClosingEventArgs e)
        {
            if(!(this.streamWriter == null))
            {
                try
                {
                    this.streamWriter.WriteLine(Encrypt("서버를 종료합니다."));

                    this.streamWriter.Flush();
                }
                catch { }
            }

            this.isServerWorking = false;

            this.timer.Enabled = false;

            if(!(this.streamWriter == null))
            {
                this.streamWriter.Close();
            }

            if(!(this.networkStream == null))
            {
                this.networkStream.Close();
            }

            if(!(this.tcpClient == null))
            {
                this.tcpClient.Close();
            }

            if(!(this.tcpListener == null))
            {
                this.tcpListener.Stop();
            }

            if(!(this.thread == null))
            {
                this.thread.Abort();
            }

            Application.ExitThread();
        }

        #endregion
        #region 송신 버튼 클릭시 처리하기 - sendButton_Click(sender, e)

        /// <summary>
        /// 송신 버튼 클릭시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void sendButton_Click(object sender, EventArgs e)
        {
            if(this.networkStream != null && this.streamWriter != null)
            {
                this.streamWriter.WriteLine(Encrypt("12345abcde"));

                this.streamWriter.Flush();
            }
        }

        #endregion
        #region 타이머 틱 처리하기 - timer_Tick(sender, e)

        /// <summary>
        /// 타이머 틱 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void timer_Tick(object sender, EventArgs e)
        {
            SendTimeMessage();
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////// Function

        #region 임의 개인 키 바이트 배열 설정하기 - SetRandomPrivateKeyByteArray(randomValue)

        /// <summary>
        /// 임의 개인 키 바이트 배열 설정하기
        /// </summary>
        /// <param name="randomValue">임의 값</param>
        private void SetRandomPrivateKeyByteArray(int randomValue)
        {
            randomPrivateKeyByteArray = new byte[this.privateKeyByteArray.Length];
            randomPrivateKeyInitialValueByteArray  = new byte[this.privateKeyInitialValueByteArray.Length];

            for(int i = 0; i < this.privateKeyByteArray.Length; i++)
            {
                int value = (int)this.privateKeyByteArray[i];

                randomPrivateKeyByteArray[i] = Convert.ToByte(value / randomValue);
            }

            for(int i = 0; i < this.privateKeyInitialValueByteArray.Length; i++)
            {
                int value = (int)this.privateKeyInitialValueByteArray[i];

                randomPrivateKeyInitialValueByteArray[i] = Convert.ToByte(value / randomValue);
            }
        }

        #endregion
        #region 메시지 박스 데이터 추가하기 - AddMessageTextBoxData(text)

        /// <summary>
        /// 메시지 박스 데이터 추가하기
        /// </summary>
        /// <param name="text">텍스트</param>
        private void AddMessageTextBoxData(string text)
        {
            this.messageTextBox.AppendText(text + "\r\n");

            this.messageTextBox.Focus();

            this.messageTextBox.ScrollToCaret();
        }

        #endregion
        #region 서버 시작하기 - StartServer()

        /// <summary>
        /// 서버 시작하기
        /// </summary>
        private void StartServer()
        {
            AddMessageTextBoxData("서버가 실행이 되었습니다.");

            while(this.isServerWorking)
            {
                try
                {
                    this.tcpClient = this.tcpListener.AcceptTcpClient();

                    AddMessageTextBoxData("클라이언트가 접속하였습니다.");

                    this.networkStream = this.tcpClient.GetStream();

                    this.streamWriter = new StreamWriter(this.networkStream);
                }
                catch
                {
                }
            }
        }

        #endregion
        #region 시간 메시지 송신하기 - SendTimeMessage()

        /// <summary>
        /// 시간 메시지 송신하기
        /// </summary>
        private void SendTimeMessage()
        {
            try
            {
                string messageEncrypted = Encrypt(Convert.ToString(DateTime.Now));

                this.streamWriter.WriteLine(messageEncrypted);

                this.streamWriter.Flush();
            }
            catch
            {
            }
        }

        #endregion
        #region 암호화 하기 - Encrypt(message)

        /// <summary>
        /// 암호화 하기
        /// </summary>
        /// <param name="message">메시지</param>
        /// <returns>암호화 메시지</returns>
        private string Encrypt(string message)
        {
            string messageEncrypted = null;

            byte[] textByteArray = UTF8Encoding.UTF8.GetBytes(message);

            messageEncrypted = Convert.ToBase64String
            (
                this.tripleDESCryptoServiceProvider.CreateEncryptor
                (
                    randomPrivateKeyByteArray,
                    randomPrivateKeyInitialValueByteArray
                ).TransformFinalBlock(textByteArray, 0, textByteArray.Length)
            );

            textByteArray = UTF8Encoding.UTF8.GetBytes(this.randomValue.ToString() + messageEncrypted);

            messageEncrypted = Convert.ToBase64String
            (
                this.tripleDESCryptoServiceProvider.CreateEncryptor
                (
                    this.privateKeyByteArray,
                    this.privateKeyInitialValueByteArray
                ).TransformFinalBlock(textByteArray, 0, textByteArray.Length)
            );

            return messageEncrypted;
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

using System;

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Security.Cryptography;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace TestServer

{

/// <summary>

/// 메인 폼

/// </summary>

public partial class MainForm : Form

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// TCP 리스너

/// </summary>

private TcpListener tcpListener;

/// <summary>

/// TCP 클라이언트

/// </summary>

private TcpClient tcpClient;

/// <summary>

/// 네트워크 스트림

/// </summary>

private NetworkStream networkStream;

/// <summary>

/// 스트림 라이터

/// </summary>

private StreamWriter streamWriter;

/// <summary>

/// 서버 작업 여부

/// </summary>

private bool isServerWorking = false;

/// <summary>

/// 스레드

/// </summary>

private Thread thread;

/// <summary>

/// 트리플 DES 암호 서비스 공급자

/// </summary>

private TripleDESCryptoServiceProvider tripleDESCryptoServiceProvider = new TripleDESCryptoServiceProvider();

/// <summary>

/// 개인 키 바이트 배열

/// </summary>

private byte[] privateKeyByteArray = new byte[]

{

98 , 45 , 125, 56, 1 , 60 , 11, 38 ,

123, 54 , 234, 9 , 76, 20 , 44, 7 ,

12 , 223, 219, 95, 48, 156, 32, 239

};

/// <summary>

/// 개인 키 초기 값 바이트 배열

/// </summary>

private byte[] privateKeyInitialValueByteArray = new byte[]

{

67, 12, 3, 41, 66, 78, 34, 123

};

/// <summary>

/// 난수기

/// </summary>

Random random = new Random();

/// <summary>

/// 임의 값

/// </summary>

private int randomValue = 0;

/// <summary>

/// 임의 개인 키 바이트 배열

/// </summary>

private byte[] randomPrivateKeyByteArray = null;

/// <summary>

/// 임의 개인 키 초기 값 바이트 배열

/// </summary>

private byte[] randomPrivateKeyInitialValueByteArray = null;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - MainForm()

/// <summary>

/// 생성자

/// </summary>

public MainForm()

{

InitializeComponent();

#region 이벤트를 설정한다.

this.Load += Form_Load;

this.FormClosing += Form_FormClosing;

this.sendButton.Click += sendButton_Click;

this.timer.Tick += timer_Tick;

#endregion

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Private

//////////////////////////////////////////////////////////////////////////////// Event

#region 폼 로드시 처리하기 - Form_Load(sender, e)

/// <summary>

/// 폼 로드시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e"></param>

private void Form_Load(object sender, EventArgs e)

{

this.isServerWorking = true;

IPAddress ipAddress = new IPAddress(0);

this.tcpListener = new TcpListener(ipAddress, 2014);

this.tcpListener.Start();

this.thread = new Thread(StartServer);

this.thread.Start();

this.timer.Enabled = true;

this.randomValue = this.random.Next(1, 9);

SetRandomPrivateKeyByteArray(this.randomValue);

}

#endregion

#region 폼을 닫을 경우 처리하기 - Form_FormClosing(sender, e)

/// <summary>

/// 폼을 닫을 경우 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void Form_FormClosing(object sender, FormClosingEventArgs e)

{

if(!(this.streamWriter == null))

{

try

{

this.streamWriter.WriteLine(Encrypt("서버를 종료합니다."));

this.streamWriter.Flush();

}

catch { }

}

this.isServerWorking = false;

this.timer.Enabled = false;

if(!(this.streamWriter == null))

{

this.streamWriter.Close();

}

if(!(this.networkStream == null))

{

this.networkStream.Close();

}

if(!(this.tcpClient == null))

{

this.tcpClient.Close();

}

if(!(this.tcpListener == null))

{

this.tcpListener.Stop();

}

if(!(this.thread == null))

{

this.thread.Abort();

}

Application.ExitThread();

}

#endregion

#region 송신 버튼 클릭시 처리하기 - sendButton_Click(sender, e)

/// <summary>

/// 송신 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void sendButton_Click(object sender, EventArgs e)

{

if(this.networkStream != null && this.streamWriter != null)

{

this.streamWriter.WriteLine(Encrypt("12345abcde"));

this.streamWriter.Flush();

}

#endregion

#region 타이머 틱 처리하기 - timer_Tick(sender, e)

/// <summary>

/// 타이머 틱 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void timer_Tick(object sender, EventArgs e)

{

SendTimeMessage();

}

#endregion

//////////////////////////////////////////////////////////////////////////////// Function

#region 임의 개인 키 바이트 배열 설정하기 - SetRandomPrivateKeyByteArray(randomValue)

/// <summary>

/// 임의 개인 키 바이트 배열 설정하기

/// </summary>

/// <param name="randomValue">임의 값</param>

private void SetRandomPrivateKeyByteArray(int randomValue)

{

randomPrivateKeyByteArray = new byte[this.privateKeyByteArray.Length];

randomPrivateKeyInitialValueByteArray = new byte[this.privateKeyInitialValueByteArray.Length];

for(int i = 0; i < this.privateKeyByteArray.Length; i++)

{

int value = (int)this.privateKeyByteArray[i];

randomPrivateKeyByteArray[i] = Convert.ToByte(value / randomValue);

}

for(int i = 0; i < this.privateKeyInitialValueByteArray.Length; i++)

{

int value = (int)this.privateKeyInitialValueByteArray[i];

randomPrivateKeyInitialValueByteArray[i] = Convert.ToByte(value / randomValue);

}

#endregion

#region 메시지 박스 데이터 추가하기 - AddMessageTextBoxData(text)

/// <summary>

/// 메시지 박스 데이터 추가하기

/// </summary>

/// <param name="text">텍스트</param>

private void AddMessageTextBoxData(string text)

{

this.messageTextBox.AppendText(text + "\r\n");

this.messageTextBox.Focus();

this.messageTextBox.ScrollToCaret();

}

#endregion

#region 서버 시작하기 - StartServer()

/// <summary>

/// 서버 시작하기

/// </summary>

private void StartServer()

{

AddMessageTextBoxData("서버가 실행이 되었습니다.");

while(this.isServerWorking)

{

try

{

this.tcpClient = this.tcpListener.AcceptTcpClient();

AddMessageTextBoxData("클라이언트가 접속하였습니다.");

this.networkStream = this.tcpClient.GetStream();

this.streamWriter = new StreamWriter(this.networkStream);

}

catch

{

}

#endregion

#region 시간 메시지 송신하기 - SendTimeMessage()

/// <summary>

/// 시간 메시지 송신하기

/// </summary>

private void SendTimeMessage()

{

try

{

string messageEncrypted = Encrypt(Convert.ToString(DateTime.Now));

this.streamWriter.WriteLine(messageEncrypted);

this.streamWriter.Flush();

}

catch

{

}

#endregion

#region 암호화 하기 - Encrypt(message)

/// <summary>

/// 암호화 하기

/// </summary>

/// <param name="message">메시지</param>

/// <returns>암호화 메시지</returns>

private string Encrypt(string message)

{

string messageEncrypted = null;

byte[] textByteArray = UTF8Encoding.UTF8.GetBytes(message);

messageEncrypted = Convert.ToBase64String

(

this.tripleDESCryptoServiceProvider.CreateEncryptor

(

randomPrivateKeyByteArray,

randomPrivateKeyInitialValueByteArray

).TransformFinalBlock(textByteArray, 0, textByteArray.Length)

);

textByteArray = UTF8Encoding.UTF8.GetBytes(this.randomValue.ToString() + messageEncrypted);

messageEncrypted = Convert.ToBase64String

(

this.tripleDESCryptoServiceProvider.CreateEncryptor

(

this.privateKeyByteArray,

this.privateKeyInitialValueByteArray

).TransformFinalBlock(textByteArray, 0, textByteArray.Length)

);

return messageEncrypted;

}

#endregion

}

[TestClient 프로젝트] ▶ MainForm.cs


using System;
using System.IO;
using System.Net.Sockets;
using System.Security.Cryptography;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace TestClient
{
    /// <summary>
    /// 메인 폼
    /// </summary>
    public partial class MainForm : Form
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// TCP 클라이언트
        /// </summary>
        private TcpClient tcpClient;

        /// <summary>
        /// 네트워크 스트림
        /// </summary>
        private NetworkStream networkStream;

        /// <summary>
        /// 스트림 리더
        /// </summary>
        private StreamReader streamReader;

        /// <summary>
        /// 스레드
        /// </summary>
        private Thread thread;

        /// <summary>
        /// 트리플 DES 암호 서비스 공급자
        /// </summary>
        private TripleDESCryptoServiceProvider tripleDESCryptoServiceProvider = new TripleDESCryptoServiceProvider();

        /// <summary>
        /// 개인 키 바이트 배열
        /// </summary>
        private byte[] privateKeyByteArray = new byte[]
        {
            98 , 45 , 125, 56, 1 , 60 , 11, 38 ,
            123, 54 , 234, 9 , 76, 20 , 44, 7  ,
            12 , 223, 219, 95, 48, 156, 32, 239
        };

        /// <summary>
        /// 개인 키 초기 값 바이트 배열
        /// </summary>
        private byte[] privateKeyInitialValueByteArray = new byte[]
        {
            67, 12, 3, 41, 66, 78, 34, 123
        };

        /// <summary>
        /// 임의 개인 키 바이트 배열
        /// </summary>
        private byte[] randomPrivateKeyByteArray = null;

        /// <summary>
        /// 임의 개인 키 초기 값 바이트 배열
        /// </summary>
        private byte[] randomPrivateKeyInitialValueByteArray = null;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - MainForm()

        /// <summary>
        /// 생성자
        /// </summary>
        public MainForm()
        {
            InitializeComponent();

            #region 이벤트를 설정한다.

            Load        += Form_Load;
            FormClosing += Form_FormClosing;

            #endregion
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Private
        //////////////////////////////////////////////////////////////////////////////// Event

        #region 폼 로드시 처리하기 - Form_Load(sender, e)

        /// <summary>
        /// 폼 로드시 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void Form_Load(object sender, EventArgs e)
        {
            try
            {
                this.tcpClient = new TcpClient("127.0.0.1", 2014);

                AddMessageTextBoxData("서버에 접속 했습니다.");

                this.networkStream = this.tcpClient.GetStream();

                this.streamReader = new StreamReader(this.networkStream);

                this.thread = new Thread(ReceiveMessage);

                this.thread.Start();
            }
            catch
            {
                AddMessageTextBoxData("서버에 접속하지 못 했습니다.");
            }
        }

        #endregion
        #region 폼을 닫을 경우 처리하기 - Form_FormClosing(sender, e)

        /// <summary>
        /// 폼을 닫을 경우 처리하기
        /// </summary>
        /// <param name="sender">이벤트 발생자</param>
        /// <param name="e">이벤트 인자</param>
        private void Form_FormClosing(object sender, FormClosingEventArgs e)
        {
            try
            {
                if(!(this.streamReader == null))
                {
                    this.streamReader.Close();
                }

                if(!(this.networkStream == null))
                {
                    this.networkStream.Close();
                }

                if(!(this.tcpClient == null))
                {
                    this.tcpClient.Close();
                }

                if(!(this.thread == null))
                {
                    this.thread.Abort();
                }
            }
            catch
            {
                return;
            }

            Application.ExitThread();
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////// Function

        #region 메시지 텍스트 박스 데이터 추가하기 - AddMessageTextBoxData(text)

        /// <summary>
        /// 메시지 텍스트 박스 데이터 추가하기
        /// </summary>
        /// <param name="text">텍스트</param>
        private void AddMessageTextBoxData(string text)
        {
            this.messageTextBox.AppendText(text + "\r\n");

            this.messageTextBox.Focus();

            this.messageTextBox.ScrollToCaret();
        }

        #endregion
        #region 임의 개인 키 바이트 배열 설정하기 - SetRandomPrivateKeyByteArray(randomValue)

        /// <summary>
        /// 임의 개인 키 바이트 배열 설정하기
        /// </summary>
        /// <param name="randomValue">임의 값</param>
        private void SetRandomPrivateKeyByteArray(int randomValue)
        {
            this.randomPrivateKeyByteArray             = new byte[this.privateKeyByteArray.Length];
            this.randomPrivateKeyInitialValueByteArray = new byte[this.privateKeyInitialValueByteArray.Length];

            for(int i = 0; i < this.privateKeyByteArray.Length; i++)
            {
                int value = (int)this.privateKeyByteArray[i];

                this.randomPrivateKeyByteArray[i] = Convert.ToByte(value / randomValue);
            }

            for(int i = 0; i < this.privateKeyInitialValueByteArray.Length; i++)
            {
                int value = (int)this.privateKeyInitialValueByteArray[i];

                this.randomPrivateKeyInitialValueByteArray[i] = Convert.ToByte(value / randomValue);
            }
        }

        #endregion
        #region 암호화 풀기 - Decrypt(messageEncrypted)

        /// <summary>
        /// 암호화 풀기
        /// </summary>
        /// <param name="messageEncrypted">암호화 메시지</param>
        /// <returns>메시지</returns>
        private string Decrypt(string messageEncrypted)
        {
            string message = null;

            byte[] messageEncryptedByteArrat = Convert.FromBase64String(messageEncrypted);

            message = UTF8Encoding.UTF8.GetString
            (
                this.tripleDESCryptoServiceProvider.CreateDecryptor
                (
                    this.privateKeyByteArray,
                    this.privateKeyInitialValueByteArray
                ).TransformFinalBlock(messageEncryptedByteArrat, 0, messageEncryptedByteArrat.Length)
            );

            SetRandomPrivateKeyByteArray(Convert.ToInt32(message.Substring(0, 1)));

            messageEncryptedByteArrat = Convert.FromBase64String(message.Substring(1, message.Length - 1));

            message = UTF8Encoding.UTF8.GetString
            (
                this.tripleDESCryptoServiceProvider.CreateDecryptor
                (
                    this.randomPrivateKeyByteArray,
                    this.randomPrivateKeyInitialValueByteArray
                ).TransformFinalBlock(messageEncryptedByteArrat, 0, messageEncryptedByteArrat.Length)
            );

            return message;
        }

        #endregion
        #region 메시지 수신하기 - ReceiveMessage()

        /// <summary>
        /// 메시지 수신하기
        /// </summary>
        private void ReceiveMessage()
        {
            try
            {
                while(true)
                {
                    if(this.networkStream.CanRead)
                    {
                        string messageEncrypted = this.streamReader.ReadLine();

                        if(messageEncrypted.Length > 0)
                        {
                            string message = Decrypt(messageEncrypted);

                            AddMessageTextBoxData(message);
                        }
                    }
                }
            }
            catch
            {
            }
        }

        #endregion
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

using System;

using System.IO;

using System.Net.Sockets;

using System.Security.Cryptography;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace TestClient

{

/// <summary>

/// 메인 폼

/// </summary>

public partial class MainForm : Form

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// TCP 클라이언트

/// </summary>

private TcpClient tcpClient;

/// <summary>

/// 네트워크 스트림

/// </summary>

private NetworkStream networkStream;

/// <summary>

/// 스트림 리더

/// </summary>

private StreamReader streamReader;

/// <summary>

/// 스레드

/// </summary>

private Thread thread;

/// <summary>

/// 트리플 DES 암호 서비스 공급자

/// </summary>

private TripleDESCryptoServiceProvider tripleDESCryptoServiceProvider = new TripleDESCryptoServiceProvider();

/// <summary>

/// 개인 키 바이트 배열

/// </summary>

private byte[] privateKeyByteArray = new byte[]

{

98 , 45 , 125, 56, 1 , 60 , 11, 38 ,

123, 54 , 234, 9 , 76, 20 , 44, 7 ,

12 , 223, 219, 95, 48, 156, 32, 239

};

/// <summary>

/// 개인 키 초기 값 바이트 배열

/// </summary>

private byte[] privateKeyInitialValueByteArray = new byte[]

{

67, 12, 3, 41, 66, 78, 34, 123

};

/// <summary>

/// 임의 개인 키 바이트 배열

/// </summary>

private byte[] randomPrivateKeyByteArray = null;

/// <summary>

/// 임의 개인 키 초기 값 바이트 배열

/// </summary>

private byte[] randomPrivateKeyInitialValueByteArray = null;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - MainForm()

/// <summary>

/// 생성자

/// </summary>

public MainForm()

{

InitializeComponent();

#region 이벤트를 설정한다.

Load += Form_Load;

FormClosing += Form_FormClosing;

#endregion

}

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Private

//////////////////////////////////////////////////////////////////////////////// Event

#region 폼 로드시 처리하기 - Form_Load(sender, e)

/// <summary>

/// 폼 로드시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void Form_Load(object sender, EventArgs e)

{

try

{

this.tcpClient = new TcpClient("127.0.0.1", 2014);

AddMessageTextBoxData("서버에 접속 했습니다.");

this.networkStream = this.tcpClient.GetStream();

this.streamReader = new StreamReader(this.networkStream);

this.thread = new Thread(ReceiveMessage);

this.thread.Start();

}

catch

{

AddMessageTextBoxData("서버에 접속하지 못 했습니다.");

}

#endregion

#region 폼을 닫을 경우 처리하기 - Form_FormClosing(sender, e)

/// <summary>

/// 폼을 닫을 경우 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

private void Form_FormClosing(object sender, FormClosingEventArgs e)

{

try

{

if(!(this.streamReader == null))

{

this.streamReader.Close();

}

if(!(this.networkStream == null))

{

this.networkStream.Close();

}

if(!(this.tcpClient == null))

{

this.tcpClient.Close();

}

if(!(this.thread == null))

{

this.thread.Abort();

}

catch

{

return;

}

Application.ExitThread();

}

#endregion

//////////////////////////////////////////////////////////////////////////////// Function

#region 메시지 텍스트 박스 데이터 추가하기 - AddMessageTextBoxData(text)

/// <summary>

/// 메시지 텍스트 박스 데이터 추가하기

/// </summary>

/// <param name="text">텍스트</param>

private void AddMessageTextBoxData(string text)

{

this.messageTextBox.AppendText(text + "\r\n");

this.messageTextBox.Focus();

this.messageTextBox.ScrollToCaret();

}

#endregion

#region 임의 개인 키 바이트 배열 설정하기 - SetRandomPrivateKeyByteArray(randomValue)

/// <summary>

/// 임의 개인 키 바이트 배열 설정하기

/// </summary>

/// <param name="randomValue">임의 값</param>

private void SetRandomPrivateKeyByteArray(int randomValue)

{

this.randomPrivateKeyByteArray = new byte[this.privateKeyByteArray.Length];

this.randomPrivateKeyInitialValueByteArray = new byte[this.privateKeyInitialValueByteArray.Length];

for(int i = 0; i < this.privateKeyByteArray.Length; i++)

{

int value = (int)this.privateKeyByteArray[i];

this.randomPrivateKeyByteArray[i] = Convert.ToByte(value / randomValue);

}

for(int i = 0; i < this.privateKeyInitialValueByteArray.Length; i++)

{

int value = (int)this.privateKeyInitialValueByteArray[i];

this.randomPrivateKeyInitialValueByteArray[i] = Convert.ToByte(value / randomValue);

}

#endregion

#region 암호화 풀기 - Decrypt(messageEncrypted)

/// <summary>

/// 암호화 풀기

/// </summary>

/// <param name="messageEncrypted">암호화 메시지</param>

/// <returns>메시지</returns>

private string Decrypt(string messageEncrypted)

{

string message = null;

byte[] messageEncryptedByteArrat = Convert.FromBase64String(messageEncrypted);

message = UTF8Encoding.UTF8.GetString

(

this.tripleDESCryptoServiceProvider.CreateDecryptor

(

this.privateKeyByteArray,

this.privateKeyInitialValueByteArray

).TransformFinalBlock(messageEncryptedByteArrat, 0, messageEncryptedByteArrat.Length)

);

SetRandomPrivateKeyByteArray(Convert.ToInt32(message.Substring(0, 1)));

messageEncryptedByteArrat = Convert.FromBase64String(message.Substring(1, message.Length - 1));

message = UTF8Encoding.UTF8.GetString

(

this.tripleDESCryptoServiceProvider.CreateDecryptor

(

this.randomPrivateKeyByteArray,

this.randomPrivateKeyInitialValueByteArray

).TransformFinalBlock(messageEncryptedByteArrat, 0, messageEncryptedByteArrat.Length)

);

return message;

}

#endregion

#region 메시지 수신하기 - ReceiveMessage()

/// <summary>

/// 메시지 수신하기

/// </summary>

private void ReceiveMessage()

{

try

{

while(true)

{

if(this.networkStream.CanRead)

{

string messageEncrypted = this.streamReader.ReadLine();

if(messageEncrypted.Length > 0)

{

string message = Decrypt(messageEncrypted);

AddMessageTextBoxData(message);

}

catch

{

}

#endregion

}

TestSolution.zip

[C#/COMMON] 방화벽 TCP 포트 열기/닫기

■ 방화벽에서 TCP 포트를 열고 닫는 방법을 보여준다. ▶ 방화벽 TCP 포트 열기/닫기 예제 (C#)


OpenFirewallTCPPort("TEST SERVER", 9999);

CloseFirewallTCPPort(9999);

OpenFirewallTCPPort("TEST SERVER", 9999);

CloseFirewallTCPPort(9999);

▶ 방화벽 TCP 포트 열기/닫기 (C#)

[C#/COMMON] 타임 서버에서 정보 구하기

■ 타임 서버에서 정보를 구하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.IO;
using System.Net.Sockets;

TcpClient tcpClient = new TcpClient("time-a.nist.gov", 13);

if(tcpClient.Connected)
{
    NetworkStream networkStream = tcpClient.GetStream();

    StreamReader streamReader = new StreamReader(networkStream);

    string result = streamReader.ReadToEnd().Trim();

    Console.WriteLine(result);
}
else
{
    Console.WriteLine("Failed to connect...");
}

using System;

using System.IO;

using System.Net.Sockets;

TcpClient tcpClient = new TcpClient("time-a.nist.gov", 13);

if(tcpClient.Connected)

{

NetworkStream networkStream = tcpClient.GetStream();

StreamReader streamReader = new StreamReader(networkStream);

string result = streamReader.ReadToEnd().Trim();

Console.WriteLine(result);

}

else

{

Console.WriteLine("Failed to connect...");

}

[C#/COMMON] TCP 데이터 수신하기

■ TCP 데이터를 수신하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Net.Sockets;
using System.Threading;

#region TCP 데이터 수신하기 - ReceiveTCPData(socket, bufferByteArray, offset, receiveSize, timeOut)

/// <summary>
/// TCP 데이터 수신하기
/// </summary>
/// <param name="socket">소켓</param>
/// <param name="bufferByteArray">버퍼 목록</param>
/// <param name="offset">오프셋</param>
/// <param name="receiveSize">수신 크기</param>
/// <param name="timeOut">타임 아웃</param>
public static void ReceiveTCPData(Socket socket, byte[] bufferByteArray, int offset, int receiveSize, int timeOut)
{
    int startTickCount = Environment.TickCount;
    int countReceived  = 0;

    do
    {
        if(Environment.TickCount > startTickCount + timeOut)
        {
            throw new TimeoutException();
        }

        try
        {
            countReceived += socket.Receive
            (
                bufferByteArray,
                offset + countReceived,
                receiveSize - countReceived,
                SocketFlags.None
            );
        }
        catch(SocketException socketException)
        {
            if(socketException.SocketErrorCode == SocketError.WouldBlock ||
               socketException.SocketErrorCode == SocketError.IOPending  ||
               socketException.SocketErrorCode == SocketError.NoBufferSpaceAvailable)
            {
                Thread.Sleep(30);
            }
            else
            {
                throw socketException;
            }
        }
    }
    while(countReceived < receiveSize);
}

#endregion

using System;

using System.Net.Sockets;

using System.Threading;

#region TCP 데이터 수신하기 - ReceiveTCPData(socket, bufferByteArray, offset, receiveSize, timeOut)

/// <summary>

/// TCP 데이터 수신하기

/// </summary>

/// <param name="socket">소켓</param>

/// <param name="bufferByteArray">버퍼 목록</param>

/// <param name="offset">오프셋</param>

/// <param name="receiveSize">수신 크기</param>

/// <param name="timeOut">타임 아웃</param>

public static void ReceiveTCPData(Socket socket, byte[] bufferByteArray, int offset, int receiveSize, int timeOut)

{

int startTickCount = Environment.TickCount;

int countReceived = 0;

{

if(Environment.TickCount > startTickCount + timeOut)

{

throw new TimeoutException();

}

try

{

countReceived += socket.Receive

(

bufferByteArray,

offset + countReceived,

receiveSize - countReceived,

SocketFlags.None

);

}

catch(SocketException socketException)

{

if(socketException.SocketErrorCode == SocketError.WouldBlock ||

socketException.SocketErrorCode == SocketError.IOPending ||

socketException.SocketErrorCode == SocketError.NoBufferSpaceAvailable)

{

Thread.Sleep(30);

}

else

{

throw socketException;

}

while(countReceived < receiveSize);

}

#endregion

[C#/COMMON] TCP 데이터 전송하기

■ TCP 데이터를 전송하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Net.Sockets;
using System.Threading;

#region TCP 데이터 전송하기 - SendTCPData(socket, bufferByteArray, offset, transferSize, timeOut)

/// <summary>
/// TCP 데이터 전송하기
/// </summary>
/// <param name="socket">소켓</param>
/// <param name="bufferByteArray">버퍼 바이트 배열</param>
/// <param name="offset">오프셋</param>
/// <param name="nSize">전송 크기</param>
/// <param name="timeOut">타임 아웃</param>
public void SendTCPData(Socket socket, byte[] bufferByteArray, int offset, int transferSize, int timeOut)
{
    int startTickCount = Environment.TickCount;
    int countSent      = 0;

    do
    {
        if(Environment.TickCount > startTickCount + timeOut)
        {
            throw new TimeoutException();
        }

        try
        {
            countSent += socket.Send(bufferByteArray, offset + countSent, transferSize - countSent, SocketFlags.None);
        }
        catch(SocketException socketException)
        {
            if(socketException.SocketErrorCode == SocketError.WouldBlock ||
               socketException.SocketErrorCode == SocketError.IOPending  ||
               socketException.SocketErrorCode == SocketError.NoBufferSpaceAvailable)
            {
                Thread.Sleep(30);
            }
            else
            {
                throw socketException;
            }
        }
    }
    while(countSent < transferSize);
}

#endregion

using System;

using System.Net.Sockets;

using System.Threading;

#region TCP 데이터 전송하기 - SendTCPData(socket, bufferByteArray, offset, transferSize, timeOut)

/// <summary>

/// TCP 데이터 전송하기

/// </summary>

/// <param name="socket">소켓</param>

/// <param name="bufferByteArray">버퍼 바이트 배열</param>

/// <param name="offset">오프셋</param>

/// <param name="nSize">전송 크기</param>

/// <param name="timeOut">타임 아웃</param>

public void SendTCPData(Socket socket, byte[] bufferByteArray, int offset, int transferSize, int timeOut)

{

int startTickCount = Environment.TickCount;

int countSent = 0;

{

if(Environment.TickCount > startTickCount + timeOut)

{

throw new TimeoutException();

}

try

{

countSent += socket.Send(bufferByteArray, offset + countSent, transferSize - countSent, SocketFlags.None);

}

catch(SocketException socketException)

{

if(socketException.SocketErrorCode == SocketError.WouldBlock ||

socketException.SocketErrorCode == SocketError.IOPending ||

socketException.SocketErrorCode == SocketError.NoBufferSpaceAvailable)

{

Thread.Sleep(30);

}

else

{

throw socketException;

}

while(countSent < transferSize);

}

#endregion

[C#/COMMON] TCP 포트 이용 가능 여부 조사하기

■ TCP 포트 이용 가능 여부를 조사하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System.Net.NetworkInformation;

#region TCP 포트 이용 가능 여부 조사하기 - IsAvailableTCPPort(port)

/// <summary>
/// TCP 포트 이용 가능 여부 조사하기
/// </summary>
/// <param name="port">포트</param>
/// <returns>TCP 포트 이용 가능 여부</returns>
public static bool IsAvailableTCPPort(int port)
{
    bool isAvailable = true;

    IPGlobalProperties ipGlobalProperties = IPGlobalProperties.GetIPGlobalProperties();

    TcpConnectionInformation[] tcpConnectionInformationArray = ipGlobalProperties.GetActiveTcpConnections();

    foreach(TcpConnectionInformation tcpConnectionInformation in tcpConnectionInformationArray)
    {
        if(tcpConnectionInformation.LocalEndPoint.Port == port)
        {
            isAvailable = false;

            break;
        }
    }

    return isAvailable;
}

#endregion

using System.Net.NetworkInformation;

#region TCP 포트 이용 가능 여부 조사하기 - IsAvailableTCPPort(port)

/// <summary>

/// TCP 포트 이용 가능 여부 조사하기

/// </summary>

/// <param name="port">포트</param>

/// <returns>TCP 포트 이용 가능 여부</returns>

public static bool IsAvailableTCPPort(int port)

{

bool isAvailable = true;

IPGlobalProperties ipGlobalProperties = IPGlobalProperties.GetIPGlobalProperties();

TcpConnectionInformation[] tcpConnectionInformationArray = ipGlobalProperties.GetActiveTcpConnections();

foreach(TcpConnectionInformation tcpConnectionInformation in tcpConnectionInformationArray)

{

if(tcpConnectionInformation.LocalEndPoint.Port == port)

{

isAvailable = false;

break;

}

return isAvailable;

}

#endregion