【测试】用socket网络编程写了个聊天程序

附上源码：
[socket_def.inc]
const domain=AF_INET;
_type=SOCK_STREAM;
protocol=IPPROTO_TCP;
var sockfd:longint;
const backlog:longint=100;
const ports=9313;//服务器端口
portc=8795;//客户端端口
const ips=699574464;//服务器IP
ipc=749906112;//客户端IP
var addrs:TInetSockAddr=(family:domain;port:ports;addr:ips);
addrc:TInetSockAddr=(family:domain;port:portc;addr:ipc);
const addrlens:longint=sizeof(addrs);
addrlenc:longint=sizeof(addrc);
const flags=0;
var sockin,sockout:text;
var buff:string;
[socket_service.pas]
program socket_service;
uses sockets;
{$I socket_def.inc}
var addrlen:longint;
begin
sockfd:=socket(domain,_type,protocol);
bind(sockfd,addrs,addrlens);
listen(sockfd,backlog);
accept(sockfd,addrc,sockin,sockout);
reset(sockin);
rewrite(sockout);
writeln('Service online. Please type in message.');
repeat
write('Service send: ');
readln(buff);
writeln(sockout,buff);
write('Client recv: ');
readln(sockin,buff);
writeln(buff);
until false;
close(sockout);
close(sockin);
end.
[socket_client.pas]
program so_cket_client;
uses sockets;
{$I socket_def.inc}
begin
sockfd:=socket(domain,_type,protocol);
bind(sockfd,addrc,addrlenc);
connect(sockfd,addrs,sockin,sockout);
reset(sockin);
rewrite(sockout);
writeln('Client online. Please wait for message.');
repeat
write('Service recv: ');
readln(sockin,buff);
writeln(buff);
write('Client send: ');
readln(buff);
writeln(sockout,buff);
until false;
close(sockout);
close(sockin);
end.

四川禧凑淼商贸有限公司

代理销售pascal全系列产品，我们的专业你的需求，原装进口，品质保证，交货及时，质量保证，欢迎咨询!

2024-11-25 07:44广告

立即查看

前排围观

加了个多线程，目前支持读取消息同时发送消息。
注意socketsh.inc里有个{$ifdef legacysocket}编译开关需要关掉，否则所有socket有关的函数都必须加fp，比如bind()要用fpbind()。
[socket_def.inc]
uses sockets,windows;
var tid:longword;
var sendthread,recvthread:boolean;
const domain=AF_INET;
_type=SOCK_STREAM;
protocol=IPPROTO_TCP;
var sockfd:longint;
const backlog:longint=100;
const ports=9313;//服务器端口
portc=8795;//客户端端口
const ips=749906112;//服务器IP
ipc=699574464;//客户端IP
var addrs:TInetSockAddr=(family:domain;port:ports;addr:ips);
addrc:TInetSockAddr=(family:domain;port:portc;addr:ipc);
const addrlens:longint=sizeof(addrs);
addrlenc:longint=sizeof(addrc);
const flags=0;
var sockin,sockout:text;
var buff:string;
procedure sendmessage;
begin
sendthread:=true;
readln(buff);
writeln(sockout,buff);
sendthread:=false;
end;
procedure recvmessage;
begin
recvthread:=true;
readln(sockin,buff);
writeln(buff);
recvthread:=false;
end;
[socket_service.pas]
program socket_service;
{$I socket_def.inc}
begin
sockfd:=socket(domain,_type,protocol);
bind(sockfd,addrs,addrlens);
listen(sockfd,backlog);
accept(sockfd,addrc,sockin,sockout);
reset(sockin);
rewrite(sockout);
writeln('Service online. Please type in message.');
repeat
if not sendthread then createthread(nil,0,@sendmessage,nil,0,tid);
if not recvthread then createthread(nil,0,@recvmessage,nil,0,tid);
sleep(1);
until buff='end';
close(sockout);
close(sockin);
end.
[socket_client.pas]
program so_cket_client;
{$I socket_def.inc}
begin
sockfd:=socket(domain,_type,protocol);
//bind(sockfd,addrc,addrlenc);
while not connect(sockfd,addrs,sockin,sockout) do ;
reset(sockin);
rewrite(sockout);
writeln('Client online. Please wait for message.');
repeat
if not sendthread then createthread(nil,0,@sendmessage,nil,0,tid);
if not recvthread then createthread(nil,0,@recvmessage,nil,0,tid);
sleep(1);
until buff='end';
close(sockout);
close(sockin);
end.