1  public class SocketServer
  2     {
  3         //通过winform控件进行后台处理，CADAPI不支持多线程
  4         static Control syncCtrl;
  5         //承载接收数据
  6         private static byte[] result = new byte[1024];
  7         //端口
  8         private static int myProt = 8885;
  9 
 10         private static Socket serverSocket;
 11 
 12         delegate void FinishedProcessingDelegate();
 13         public static void InitSocket()
 14         {
 15             //创建控件
 16             syncCtrl = new Control();
 17             syncCtrl.CreateControl();
 18             //创建通讯对象
 19             serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 20             //绑定IP地址：端口
 21             serverSocket.Bind(new IPEndPoint(IPAddress.Any, myProt));
 22             //设定最多10个排队连接请求
 23             serverSocket.Listen(10);   
 24             //通过Clientsoket发送数据
 25             Thread myThread = new Thread(ListenClientConnect);
 26             myThread.Start();
 27         }
 28         /// <summary>
 29         /// 监听客户端连接
 30         /// </summary>
 31         private static void ListenClientConnect()
 32         {
 33             while (true)
 34             {
 35                 Socket clientSocket = serverSocket.Accept();
 36                 try
 37                 {
 38                     
 39                     clientSocket.Send(Encoding.UTF8.GetBytes("我是牛魔王"));
 40                     Thread receiveThread = new Thread(ReceiveMessage);
 41                     receiveThread.Start(clientSocket);
 42                 }
 43                 catch (Exception)
 44                 {
 45 
 46                     clientSocket.Shutdown(SocketShutdown.Both);
 47                     clientSocket.Close();
 48                 }
 49               
 50             }
 51         }
 52 
 53         /// <summary>
 54         /// 接收消息
 55         /// </summary>
 56         /// <param name="clientSocket"></param>
 57         private static void ReceiveMessage(object clientSocket)
 58         {
 59             Socket myClientSocket = (Socket)clientSocket;
 60             while (true)
 61             {
 62                 try
 63                 {
 64                     //通过clientSocket接收数据
 65                     int receiveNumber = myClientSocket.Receive(result);
 66                     if (receiveNumber>0)
 67                     {
 68                         //获取文件名称
 69                         string filePath = Encoding.UTF8.GetString(result, 0, receiveNumber);
 70                         //判断文件是否存在
 71                         if (FileOperate.FileExists(filePath))
 72                         {
 73                             FileStandardization.filePathByJava = filePath;
 74                             if (syncCtrl.InvokeRequired)
 75                             {
 76                                 syncCtrl.Invoke(new FinishedProcessingDelegate(FileStandardization.TransMianByJava));
 77                             }
 78                             myClientSocket.Send(Encoding.UTF8.GetBytes("我是牛魔王:处理结果是" + FileStandardization.resultJava));
 79                             FileOperate.Log(SystemData.logPath, "我是牛魔王，文件处理完成：" + filePath);
 80                         }
 81                         else
 82                         {
 83                             myClientSocket.Send(Encoding.UTF8.GetBytes("我是牛魔王:文件不存在"));
 84                         }
 85                     }
 86                     else
 87                     {
 88                         FileOperate.Log(SystemData.logPath, "没有收到数据了");
 89                         myClientSocket.Shutdown(SocketShutdown.Both);
 90                         myClientSocket.Close();
 91                         break;
 92                     }
 93                    
 94                    
 95                 }
 96                 catch (Exception ex)
 97                 {
 98                     FileOperate.Log(SystemData.logPath,"文件处理异常："+ex.Message);
 99                     myClientSocket.Shutdown(SocketShutdown.Both);
100                     myClientSocket.Close();
101                     break;
102                 }
103             }
104         }
105 
106     }

 1  class Program
 2     {
 3         private static byte[] result = new byte[1024];
 4         static void Main(string[] args)
 5         {
 6             //设定服务器IP地址
 7             IPAddress ip = IPAddress.Parse("10.19.10.237");
 8             //IPAddress ip = IPAddress.Parse("127.0.0.1");
 9             Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
10             try
11             {
12                 clientSocket.Connect(new IPEndPoint(ip, 8885)); //配置服务器IP与端口
13                 Console.WriteLine("连接服务器成功");
14             }
15             catch
16             {
17                 Console.WriteLine("连接服务器失败，请按回车键退出！");
18                 return;
19             }
20             //通过clientSocket接收数据
21             int receiveLength = clientSocket.Receive(result);
22             Console.WriteLine("接收服务器消息：{0}", Encoding.UTF8.GetString(result, 0, receiveLength));
23             //通过 clientSocket 发送数据
24             for (int i = 0; i < 13; i++)
25             {
26                 try
27                 {
28                     Thread.Sleep(1000);    //等待1秒钟
29                     string sendMessage = "C:\\Users\\Administrator\\Desktop\\原始CAD文件\\14412-kujiale.dxf";
30                     clientSocket.Send(Encoding.UTF8.GetBytes(sendMessage));
31                     Console.WriteLine("向服务器发送消息：{0}" + sendMessage);
32                     receiveLength = clientSocket.Receive(result);
33                     Console.WriteLine("接收服务器消息：{0}", Encoding.UTF8.GetString(result, 0, receiveLength));
34                 }
35                 catch
36                 {
37                     clientSocket.Shutdown(SocketShutdown.Both);
38                     clientSocket.Close();
39                     break;
40                 }
41             }
42             clientSocket.Shutdown(SocketShutdown.Both);
43             clientSocket.Close();
44             Console.WriteLine("发送完毕，按回车键退出");
45             Console.ReadLine();
46         }
47     }