php로 tcp 소켓 서버 만들기

Author: jacking75

php_tcp_server/README.md

@@ -0,0 +1,4 @@
+# PHP TCP 서버 개발 기술 R&D
+  
+
+  

php_tcp_server/binaryData.md

@@ -0,0 +1,73 @@
+# 바이너리 데이터 다루기
+[이 문서](https://www.slideshare.net/yoyayoya1/php-10133775 )를 정리  
+  
+PHP에서는 String 타입으로 바이너리 데이터를 다룰 수 있다.  
+PHP는 String 타입에 대해서 문자로서 특별한 것을 하지 않는다.  
+PHP에서 문자열 타입은 바이트 배열과 정수 값(버퍼 길이)로 구현되어 있다. 바이트 열을 문자열로 변환하는 방법에 대해서는 어떤 정보도 가지고 있지 않고, 완전하게 프로그래머에게 맡긴다. 
+바이너리 데이터 조작은 `str` 계열의 함수를 사용한다.  
+    
+    
+## 바이너리와 정수 값 상호 변환
+바이너리 -> 정수 값 (빅엔디언)   
+```
+// 2바이트
+$b = unpack('n', $a)
+
+// 4바이트
+$b = unpack('N', $a)
+```
+  
+바이너리 -> 정수 값 (리틀엔디언)   
+```
+// 2바이트
+$b = unpack('v', $a)
+
+// 4바이트
+$b = unpack('V', $a)
+```
+  
+pack은 `unsigned`로 처리한다.  
+  
+
+## 사용 예 
+![pack](./images/001.png)    
+  
+![pack](./images/002.png)      
+  
+
+### GIF 파일 데이터 변환 예
+파일의 선두에서  
+```
+47 49 46 38 39 61 78 00 5A 00
+```
+와 같은 데이터다 저장되어 있다면  
+```
+$fp = fopen( 'sample.gif', 'rb' );
+$data = fread( $fp, 10 );
+
+$format = 'a3signature/a3version/vwidth/vheight';
+$info = unpack( $format, $data );
+```
+  
+이렇게 하면 unpack()이 반환하는 배열에는 아래와 같은 데이터가 저장되어 있다  
+```
+Array
+(
+    [signature] => GIF  // 47 49 46
+    [version] => 89a    // 38 39 61
+    [width] => 120      // 78 00 (0x0078 = 120)
+    [height] => 90      // 5A 00 (0x005A = 90)
+)
+```
+  
+  
+
+## 포맷 문자열
+![pack](./images/003.png)      
+  
+
+## 참고 글
+- [How to work with binary data in PHP](https://blog-en.openalfa.com/how-to-work-with-binary-data-in-php )
+- [PHP pack API](https://www.php.net/manual/ja/function.pack.php )
+- [PHP unpack API](https://www.php.net/manual/ja/function.unpack.php )  
+- [mdurrant/php-binary-reader](https://github.com/mdurrant/php-binary-reader )  

php_tcp_server/codes/csharp_TcpNetworkDummy/NPSBDummyLib/AsyncSocket.cs

@@ -0,0 +1,110 @@
+using System;
+using System.Net.Sockets;
+using System.Threading.Tasks;
+
+namespace NPSBDummyLib
+{
+    public class AsyncSocket
+    {
+        Socket Conn = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
+       
+        bool IsConnectToDisconnected = false;
+
+        string LastExceptionMessage;
+
+
+        public bool IsConnected() { return Conn != null && Conn.Connected; }
+                
+
+        public async Task<(bool,int,string)> ConnectAsync(string ip, int port)
+        {
+            try
+            {
+                Conn.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
+                await Conn.ConnectAsync(ip, port);
+                
+                Conn.NoDelay = true;
+                
+                DummyManager.DummyConnected();
+
+                IsConnectToDisconnected = false;
+                return (true, 0, "");
+            }
+            catch (Exception ex)
+            {
+                var sockEx = (SocketException)ex;
+                LastExceptionMessage = sockEx.Message;
+                return (false, sockEx.ErrorCode, sockEx.Message);
+            }
+        }
+        
+        public (int, string) Receive(int bufferSize, byte[] buffer)
+        {
+            // 대기조건. 시간, 원하는 패킷, 횟수
+            try
+            {
+                if (Conn.Poll(100, SelectMode.SelectRead) == false)
+                {                    
+                    return (0, "");
+                }
+
+                var size = Conn.Receive(buffer);
+                return (size, "");                    
+            }
+            catch (Exception ex)
+            {
+                // 더미가 끊은 것이므로 에러가 아니다
+                if (IsConnectToDisconnected)
+                {
+                    return (0, "");
+                }
+
+                LastExceptionMessage = ex.Message;
+                Close();
+                return (-1, ex.Message);
+            }
+        }
+                
+        public string Send(int bufferSize, byte[] buffer)
+        {
+            try
+            {
+                Conn.Send(buffer);
+                return "";
+            }
+            catch (Exception ex)
+            {
+                LastExceptionMessage = ex.Message;
+                Close();
+                return ex.Message;
+            }            
+        }
+
+        public Int64 Close()
+        {
+            Int64 currentCount = 0;
+
+            try
+            {
+                IsConnectToDisconnected = true;
+
+                Conn.LingerState = new LingerOption(false, 0);
+                //Conn.Close();
+                Conn.Disconnect(true);
+                Conn.Dispose();
+
+                Conn = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
+            }
+            catch(Exception ex)
+            {
+                LastExceptionMessage = ex.Message;
+            }
+            finally
+            {
+                currentCount = DummyManager.DummyDisConnected();
+            }
+
+            return currentCount;
+        }
+    }
+}

php_tcp_server/codes/csharp_TcpNetworkDummy/NPSBDummyLib/Dummy.cs

@@ -0,0 +1,84 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace NPSBDummyLib
+{
+    public partial class Dummy
+    {
+        public Int32 Index { get; private set; }
+
+        public Int32 Number { get; private set; }
+
+        public bool IsRun { get; private set; }
+                  
+        public UInt64 CurActionRepeatCount = 0;
+
+        string LastExceptionMessage;
+
+        DummyScenarioResult ScenarioResult = new DummyScenarioResult();
+
+        List<string> ActionHistory = new List<string>(); // 더미의 행동 이력
+
+
+        public string GetUserID() => $"User_{Number}";
+
+        public bool IsSuccessScenarioResult() => ScenarioResult.IsSuccess;
+
+        public string GetScenarioResult() => ScenarioResult.Result;
+
+        public void Init(Int32 index, Int32 number)
+        {
+            Index = index;
+            Number = number;
+            ClientSocket = new AsyncSocket();
+            RecvPacketInfo.Init(DummyManager.Config.PacketSizeMax);
+        }
+                
+   
+        public void AddActionDesc(string desc) => ActionHistory.Add($"[{DateTime.Now}] {desc}");
+  
+        public void SetScenarioResult(bool isSuccess, string result)
+        {
+            ScenarioResult.IsSuccess = isSuccess;
+            ScenarioResult.Result = result;
+        }
+
+        public void StartScenario()
+        {
+            ActionHistory.Clear();
+            CurActionRepeatCount = 0;
+            ScenariActionMaxWaitTimeSec = 0;
+            IsRun = true;            
+        }
+
+        
+
+        Int64 ScenariActionMaxWaitTimeSec = 0;
+
+        public void SetScenariActionMaxWaitTime(Int64 timeSec) => ScenariActionMaxWaitTimeSec = timeSec;
+
+        public bool IsOverScenariActionMaxWaitTimeThenStop(Int64 curTimeSec)
+        {
+            // 단순하게 변수의 값을 읽어서 체크 하는 것이라서 스레드 세이프하지 않아도 괜찮다
+            if (ScenariActionMaxWaitTimeSec == 0 || curTimeSec < ScenariActionMaxWaitTimeSec)
+            {
+                return false;
+            }
+
+            AddActionDesc($"[실패] 시나리오 액션의 최대 대기 시간을 넘었음");
+            IsRun = false;
+            return true;
+        }
+    }
+             
+
+    public class DummyScenarioResult
+    {
+        public bool IsSuccess;
+        public string Result;
+    }
+   
+    
+}