Всё, что касается сервера.
Вот функция, которая запускает сервер:
| Код |
//почти все переменные глобальные
function TPlayForm.StartServer: boolean;
var
errId: DWORD;
begin
Result:= false;
serverSocket:= socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if serverSocket = INVALID_SOCKET then
begin
MessageBoxExA(Handle, 'Couldn`t create socket', 'Error', MB_ICONERROR, 0);
exit;
end;
ZeroMemory(@servAddr, SizeOf(servAddr));
servAddr.sin_port:= htons(serverPort);
servAddr.sin_family:= AF_INET;
servAddr.sin_addr.S_addr:= INADDR_ANY;
if bind(serverSocket, @servAddr, SizeOf(servAddr)) = SOCKET_ERROR then
begin
MessageBoxExA(Handle, PChar('Couldn`t bind port ' + IntToStr(serverPort)),
'Error', MB_ICONERROR, 0);
exit;
end;
if listen(serverSocket, 1) = SOCKET_ERROR then
begin
MessageBoxExA(Handle, PChar('Couldn`t listen on port ' + IntToStr(serverPort)),
'Error', MB_ICONERROR, 0);
exit;
end;
WSAAsyncSelect(serverSocket, PlayForm.Handle, WM_NETWORK,
FD_ACCEPT or FD_WRITE or FD_READ or FD_CLOSE);
Result:= true;
end;
|
Вот процедура, которая выполняется, когда окно приходит сообщение WM_NETWORK:
| Код |
procedure TPlayForm.DispatchSocketEvent(var Msg: TMessage);
var
inPacket: TPacket;
addrLen: integer;
begin
ZeroMemory(@inPacket, PACKET_SIZE);
case WSAGetSelectEvent(Msg.LParam) of
FD_ACCEPT:
begin
clientSocket:= TSocket(Msg.WParam);
addrLen:= SizeOf(clientAddr);
clientSocket:= Accept(clientSocket, clientAddr, addrLen);
end;
FD_WRITE:
begin
end;
FD_READ:
begin
recv(serverSocket, inPacket, PACKET_SIZE, 0);
DispatchPacket(d);
end;
FD_CLOSE:
begin
end;
end;
end;
|
Вот код процедуры DispatchPacket:
| Код |
procedure TPlayForm.DispatchPacket(Packet: TPacket);
var
newPacket: TPacket;
begin
if Packet.u_Magic <> $0D then exit;
ZeroMemory(@newPacket, SizeOf(newPacket));
newPacket.u_Magic:= $0D;
//обработка пакета
case Packet.u_Type of
PT_HELO:
begin
playing:= true;
if serverStarted then
begin
newPacket.u_Type:= PT_HELO;
send(clientSocket, newPacket, SizeOf(newPacket), 0);
end;
end;
PT_CHAT:
begin
ChatMemo.Lines.Add(Packet.c_Text);
end;
PT_PING:
begin
newPacket.u_Type:= PT_PONG;
send(clientSocket, newPacket, SizeOf(newPacket), 0);
end;
PT_PONG:
begin
end;
//ну и тут обработчик для этих констант, пока всё пусто
//...
end;
end;
|
Теперь всё, что касается по поводу клиента.
Подключение к серверу:
| Код |
function TPlayForm.ConnectToServ: boolean;
begin
Result:= false;
ZeroMemory(@servAddr, sizeof(servAddr));
clientSocket:= socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
servAddr.sin_family:= AF_INET;
servAddr.sin_port:= htons(serverPort);
servAddr.sin_addr.S_addr:= inet_addr(PChar(serverIP));
WSAAsyncSelect(clientSocket, Handle, WM_NETWORK,
FD_ACCEPT or FD_WRITE or FD_READ or FD_CLOSE);//т.е. используем одну процедуру и для сервера и для клиента.
connect(clientSocket, @servAddr, sizeof(servAddr));
Result:= true;
end;
|
А вот код, с помощью которого я посылаю:
| Код |
var
sendPacket: TPacket;
msg: String;
begin
//...
ZeroMemory(@sendpacket, SizeOf(sendPacket));
sendPacket.u_Magic:= $0D;
sendPacket.u_Type:= PT_CHAT;
msg:= MessageEdit.Text;
if Length(msg) = 0 then exit;
lstrcpy(sendPacket.c_Text, PChar(msg));
if send(clientSocket, sendPacket, SizeOf(sendPacket), 0) = SOCKET_ERROR then
//...
//...
end;
|
Ну вот так..=) |
)