这样：
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <netdb.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <pthread.h>
#define MAXLINE 100;
void *threadsend(void *vargp);
void *threadrecv(void *vargp);
int main()
{
int *clientfdp;
clientfdp = (int *)malloc(sizeof(int));
*clientfdp = socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in serveraddr;
struct hostent *hp;
bzero((char *)&serveraddr,sizeof(serveraddr));
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(15636);
serveraddr.sin_addr.s_addr = inet_addr("127.0.0.1");
if(connect(*clientfdp,(struct sockaddr *)&serveraddr,sizeof(serveraddr)) < 0){
printf("connect error\n");
exit(1);
}
pthread_t tid1,tid2;
printf("connected\n");
while(1){
pthread_create(&tid1,NULL,threadsend,clientfdp);
pthread_create(&tid2,NULL,threadrecv,clientfdp);
}
return EXIT_SUCCESS;
}
void *threadsend(void * vargp)
{
//pthread_t tid2;
int connfd = *((int *)vargp);
int idata;
char temp[100];
while(1){
//printf("me: \n ");
fgets(temp,100,stdin);
send(connfd,temp,100,0);
printf(" client send OK\n");
}
printf("client send\n");
return NULL;
}
void *threadrecv(void *vargp)
{
char temp[100];
int connfd = *((int *)vargp);
while(1){
int idata = 0;
idata = recv(connfd,temp,100,0);
if(idata > 0){
printf("server :\n%s\n",temp);
}
}
return NULL;
}
扩展资料：
注意事项
linux下编译多线程代码时，shell提示找不到 pthread_create函数，原因是 pthread.h不是linux系统默认加载的库文件，应该使用类似如下gcc命令进行编译：
gcc echoserver.c -lpthread -o echoserver
只要注意 -lpthread参数就可以了。
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<unistd.h>
#include<sys/time.h>
#defineBUFLEN1024
#definePORT6666
#defineLISTNUM20
intmain()
{
intsockfd,newfd;
structsockaddr_ins_addr,c_addr;
charbuf[BUFLEN];
socklen_tlen;
unsignedintport,listnum;
fd_setrfds;
structtimevaltv;
intretval,maxfd;
/*建立socket*/
if((sockfd=socket(PF_INET,SOCK_STREAM,0))==-1){
perror("socket");
exit(errno);
}else
printf("socketcreatesuccess!\n");
memset(&s_addr,0,sizeof(s_addr));
s_addr.sin_family=AF_INET;
s_addr.sin_port=htons(PORT);
s_addr.sin_addr.s_addr=htons(INADDR_ANY);
/*把地址和端口帮定到套接字上*/
if((bind(sockfd,(structsockaddr*)&s_addr,sizeof(structsockaddr)))==-1){
perror("bind");
exit(errno);
}else
printf("bindsuccess!\n");
/*侦听本地端口*/
if(listen(sockfd,listnum)==-1){
perror("listen");
exit(errno);
}else
printf("theserverislistening!\n");
while(1){
printf("*****************聊天开始***************\n");
len=sizeof(structsockaddr);
if((newfd=accept(sockfd,(structsockaddr*)&c_addr,&len))==-1){
perror("accept");
exit(errno);
}else
printf("正在与您聊天的客户端是：%s:%d\n",inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port));
while(1){
FD_ZERO(&rfds);
FD_SET(0,&rfds);
maxfd=0;
FD_SET(newfd,&rfds);
/*找出文件描述符集合中最大的文件描述符*/
if(maxfd<newfd)
maxfd=newfd;
/*设置超时时间*/
tv.tv_sec=6;
tv.tv_usec=0;
/*等待聊天*/
retval=select(maxfd+1,&rfds,NULL,NULL,&tv);
if(retval==-1){
printf("select出错，与该客户端连接的程序将退出\n");
break;
}elseif(retval==0){
printf("waiting...\n");
continue;
}else{
/*用户输入信息了*/
if(FD_ISSET(0,&rfds)){
/******发送消息*******/
memset(buf,0,sizeof(buf));
/*fgets函数：从流中读取BUFLEN-1个字符*/
fgets(buf,BUFLEN,stdin);
/*打印发送的消息*/
//fputs(buf,stdout);
if(!strncasecmp(buf,"quit",4)){
printf("server请求终止聊天!\n");
break;
}
len=send(newfd,buf,strlen(buf),0);
if(len>0)
printf("\t消息发送成功：%s\n",buf);
else{
printf("消息发送失败!\n");
break;
}
}
/*客户端发来了消息*/
if(FD_ISSET(newfd,&rfds)){
/******接收消息*******/
memset(buf,0,sizeof(buf));
/*fgets函数：从流中读取BUFLEN-1个字符*/
len=recv(newfd,buf,BUFLEN,0);
if(len>0)
printf("客户端发来的信息是：%s\n",buf);
else{
if(len<0)
printf("接受消息失败！\n");
else
printf("客户端退出了，聊天终止！\n");
break;
}
}
}
}
/*关闭聊天的套接字*/
close(newfd);
/*是否退出服务器*/
printf("服务器是否退出程序：y->是；n->否?");
bzero(buf,BUFLEN);
fgets(buf,BUFLEN,stdin);
if(!strncasecmp(buf,"y",1)){
printf("server退出!\n");
break;
}
}
/*关闭服务器的套接字*/
close(sockfd);
return0;
}
扩展资料
C语言编写一个简单的ATM系统
#include<stdio.h>
intchoice;
intshow_menu();
doubleget_money();
voiddeposit(double);
voidwithdraw(double);
doubleaccount=0.0;
intmain(intargc,constchar*argv[])
{
system("COLOR5f");
show_menu();
doubletemp;
while(choice!=0)
{
system("cls");
switch(choice)
{
case1:
printf("您的当前余额为:%.2f\n",get_money());
break;
case2:
printf("请输入您的存款金额:\n");
scanf("%lf",&temp);
deposit(temp);
printf("您的当前余额为:%.2f\n",get_money());
break;
case3:
printf("您的当前余额为:%.2f\n",get_money());
printf("请输入您的取款金额:\n");
scanf("%lf",&temp);
withdraw(temp);
printf("您的当前余额为:%.2f\n",get_money());
break;
default:
break;
}
getchar();
choice=show_menu();
}
printf("欢迎您下次再来中国银行为您提供的服务，再见！\n");
return0;
}
intshow_menu()
{
printf("*****欢迎使用中国银行行为为您提供的服务******\n");
printf("\n1.查询账户余额2.存款3.取款0.退出\n");
printf("\n请选择服务种类：");
scanf("%d",&choice);
returnchoice;
}
doubleget_money()
{
returnaccount;
}
voiddeposit(doublemoney)
{
account=account+money;
}
voidwithdraw(doublemoney)
{
if(account<money)
printf("抱歉，余额不足，不能取%.2f这么多钱!\n",money);
else
account=account-money;
}
本回答被网友采纳客户端:
客户端编程思路
1.创建套接字socket
2.发送连接请求
3.请求连接后,进行通信操作
4.释放套接字资源
*/
#define _CRT_SECURE_NO_WARNINGS
#include <winsock.h>
#include <stdio.h>
#include <stdlib.h>
#include <windows.h>
#include <conio.h>
#pragma comment(lib,"ws2_32.lib")
int main()
{
//初始化套接字库
WSADATA data;
WORD v = MAKEWORD(2, 0);
WSAStartup(v, &data);
char str[1024] = { 0 };//接受
char arr[1024] = { 0 };
char put[1024] = { 0 };//输出
//1.创建套接字库
SOCKET s = socket(AF_INET, SOCK_STREAM, 0);
//2.绑定地址
//2.1 地址和端口处理
sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_port = htons(75);
addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
printf("客户端启动:\n");
//客户端:connect
connect(s, (sockaddr *)&addr, sizeof(addr));
//send recv
while (1)
{
::recv(s, str, sizeof(str), 0);
if (str != nullptr)
{
printf("服务器说:%s\n", str);
//fflush(stdin);
//getchar();
}
printf("请输入聊天信息：");
scanf("%s", arr);
strcpy(put, arr);
::send(s, put, sizeof(put), 0);
fflush(stdin);
//break;
//getchar();
}
//关闭
closesocket(s);
WSACleanup();
if (getchar())
{
return 0;
}
else
{
Sleep(100);
}
return 0;
}
服务器端:
服务器编程思路:
初始化套接字库
1.创建套接字socket---2个
地址处理以及端口处理
2.套接字绑定本地的地址和端口
3.把套接字设置为监听状态---等待接受客户端消息
4.接受消息,返回一个用连接的新的套接字
5.新套接字用通信
6.关闭套接字
*/
#define _CRT_SECURE_NO_WARNINGS
#include <winsock.h> //包含头文件
#include <stdlib.h>
#include <stdio.h>
#include <conio.h>
//加载库
#pragma comment(lib,"ws2_32.lib")//显示加载套接字库
int main()
{
//初始化套接字库 ---WSAStartup;
WSADATA data; //结构体对象
WORD v = MAKEWORD(2, 0);
::WSAStartup(v, &data);
//1.创建套接字socket-- - 2个
SOCKET s, s2;
//家族:ip地址IPv4 IPv6
//协议类型
//用户不确定什么方式 传0
s = ::socket(AF_INET, SOCK_STREAM, 0);
//地址处理以及端口处理
sockaddr_in addr, addr2;
int size = sizeof(addr2);
addr.sin_family = AF_INET;
addr.sin_port = htons(75); //htons 转换为u_short
//设置主机地址
addr.sin_addr.S_un.S_addr = INADDR_ANY; //INADDR_ANY 任何ip都可以接入
//2.套接字绑定本地的地址和端口
//bind(SOCKET s,const sockaddr* addr,int namelen)
::bind(s, (sockaddr *)&addr, sizeof(addr));
//3.监听
::listen(s, 5);
printf("服务器端已启动:\n");
char arr[1023] = { 0 };
char str[1024] = { 0 };
char put[1024] = { 0 };
//connect(s2, (sockaddr *)&addr, sizeof(addr));
while (true)
{
//4.接受消息,返回一个用连接的新的套接字
//accept(SOCKET s,sockaddr* addr,int *namelen)
s2 = ::accept(s, (sockaddr *)&addr2, &size);
printf("%s已经连上.\n", inet_ntoa(addr2.sin_addr));
if (s2 != NULL)
{ // 5.新套接字用通信
//inet_ntoa讲地址转换为字符串
//send(SOCKET s,char *buffer,size_t size,int flags)
while (1)
{
printf("请输入聊天信息： ");
//I love you ----字符串处理
scanf("%s", arr);
strcpy(str, arr);
::send(s2, str, sizeof(str), 0);
fflush(stdin);
recv(s2, put, sizeof(put), 0);
printf("客户端说:%s\n", put);
fflush(stdin);
//break;
}
getchar();
}
// 6.关闭套接字
closesocket(s);
closesocket(s2);
WSACleanup();
if (getchar())
{
return 0;
}
else
{
::Sleep(100);
}
}
system("pause");
return 0;
}
可以实现简单的局域网聊天.如果想换成公网,需要做地址映射.
这是C语言中比较重要的TCP/IP 通信编程
本回答被提问者采纳1.
客户端连接服务器（登陆，上传相应的数据（起码有聊天室编号））
2.
客户端发生消息给服务器（消息+聊天室编号）
3.
服务器根据客户端上传的聊天室编号广播消息
4.
客户端接受服务器传来的消息
用到的技术就是socket编程（应该有其他的现成的框架，不过我用得比较多的是java，不清楚c的），如果还想做个界面的话，可以用qt做，或者MFC，应该还有其他可选方式，不过我不知道~~~。
上面只是简单的，你要做完备的还有很多问题需要考虑，比如说加密数据，优化使其能容纳较多的用户，服务器崩溃时的处理方案等等。