82 / 82 / 24
Регистрация: 30.09.2011
Сообщений: 404
|
|
21.08.2012, 21:15
|
4
|
Server
| C# | 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
| using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
namespace TcpServer
{
class SocketServer
{
private Socket server;
private IPEndPoint ip;
private List<Thread> thread_list;
private int max_conn;
public SocketServer(string ip, Int32 port)
{
this.max_conn = 2;
this.thread_list = new List<Thread>();
this.ip = new IPEndPoint(IPAddress.Parse(ip), port);
this.server = new Socket(this.ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
this.server.Bind(this.ip);
this.server.Listen(this.max_conn);
}
public void Start()
{
for (int i = 0; i < this.max_conn; i++)
{
Thread th = new Thread(new ThreadStart(Listening));
th.Start();
thread_list.Add(th);
}
}
public void Dispose()
{
foreach (Thread th in thread_list)
{
th.Abort();
}
server.Close();
}
private void Listening()
{
while (true)
{
try
{
using (Socket client = this.server.Accept())
{
Console.WriteLine("New connection: " + client.RemoteEndPoint.ToString());
client.Blocking = true;
while (client.Connected)
{
//тут обрабатываются все взаимодействия клиента с сервером
string message = Receive(client);
Console.WriteLine("receive: " + message);
Send(message, client);
}
}
}
catch (SocketException ex)
{
}
}
}
private string Receive(Socket handler)
{
string message = String.Empty;
byte[] GetBytes = new byte[1024];
int b = handler.Receive(GetBytes);
message = Encoding.UTF8.GetString(GetBytes, 0, b);
return message;
}
public void Send(string message, Socket handler)
{
byte[] tosend = Encoding.UTF8.GetBytes(message);
handler.Send(tosend, 0, tosend.Length, SocketFlags.None);
}
}
}
//example how use
static void Main(string[] args)
{
SocketServer server = new SocketServer("192.168.1.3", 12000);
server.Start();
} |
|
Client
| C# | 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
| using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Text;
namespace TcpClient
{
class SocketClient
{
private Socket client;
private IPEndPoint ip;
public SocketClient(string ip, Int32 port)
{
this.ip = new IPEndPoint(IPAddress.Parse(ip), port);
this.client = new Socket(this.ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public void Connect()
{
this.client.Connect(this.ip);
}
public void Send(string message)
{
byte[] tosend = Encoding.UTF8.GetBytes(message);
this.client.Send(tosend, 0, tosend.Length, SocketFlags.None);
}
public string Receive()
{
string message = String.Empty;
byte[] GetBytes = new byte[1024];
int b =this.client.Receive(GetBytes);
message = Encoding.UTF8.GetString(GetBytes, 0, b);
return message;
}
public void Disconnect()
{
this.client.Disconnect(false);
}
}
}
///example how use
static void Main(string[] args)
{
SocketClient client = new SocketClient("192.168.1.3", 12000);
client.Connect();
client.Send("Hello Server");
client.Receive();
Console.Read();
client.Disconnect();
} |
|
Держи, правда без коментов, но думаю разберешься.
2
|
(
