c如何用上scoket编程

feijing

浏览: 20565 次
性别:

最近访客更多访客>>

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

scoket编程

/*客户端*/
#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdio.h>
include <stdlib.h>
#include <string.h>
#include <errno.h>

#define PORT 1025
#define BUF_SIZE 1024

# define URL www.feinews.net

int main(int argc,char **argv[])
{
    struct sockaddr_in ser_addr,cli_addr;
//    char buffer[128];
    int sockfd;
    int nRecv,nSend;
//    char hello[] = "Hello!这是客户端!\n";
    char chat_buf[BUF_SIZE];
    fd_set readfds;
    int maxfd;
    int nSel;

    sockfd = socket(AF_INET,SOCK_STREAM,0);

    bzero(&cli_addr,sizeof(struct sockaddr_in));
    cli_addr.sin_family = AF_INET;
//    cli_addr.sin_port = htons(PORT - 1);
    cli_addr.sin_port = htons(0);
//    cli_addr.sin_addr.s_addr = inet_addr(argv[1]);
    cli_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    if(bind(sockfd,(struct sockaddr *)&cli_addr,sizeof(cli_addr)) < 0)
    {
        fprintf(stdout,"Bind Error:%s\n",strerror(errno));
        exit(1);
    }

    bzero(&ser_addr,sizeof(ser_addr));
    ser_addr.sin_family = AF_INET;
    ser_addr.sin_port = htons(PORT);
    ser_addr.sin_addr.s_addr = inet_addr(argv[1]);
    if(connect(sockfd,(struct sockaddr *)&ser_addr,sizeof(ser_addr)) < 0)
    {
        fprintf(stdout,"Connect Error:%s\n",strerror(errno));
        exit(1);
    }

    while(1)
    {
        FD_ZERO(&readfds);
        FD_SET(0,&readfds);
        FD_SET(sockfd,&readfds);
        maxfd = 0;
        maxfd = (maxfd > sockfd ? maxfd : sockfd) + 1;

        nSel = select(maxfd,&readfds,NULL,NULL,NULL);
        if(FD_ISSET(0,&readfds))
        {
            bzero(chat_buf,BUF_SIZE);
            if(fgets(chat_buf,BUF_SIZE,stdin) > 0)
            nSend = send(sockfd,chat_buf,BUF_SIZE,0);
        }
        if(FD_ISSET(sockfd,&readfds))
        {
            bzero(chat_buf,BUF_SIZE);
            nRecv = recv(sockfd,chat_buf,BUF_SIZE,0);
            chat_buf[nRecv] = '\0';
            printf("IP->%s : %s\n",inet_ntoa(cli_addr.sin_addr.s_addr),chat_buf);
        }

    }
    close(sockfd);

/*    nRecv = recv(sockfd,buffer,128,0);
    if(nRecv < 0)
    {
        fprintf(stdout,"Recv Error:%s\n",strerror(errno));
        exit(1);
    }
    buffer[nRecv] = '\0';
    printf("I have received:%s\n",buffer);

    nSend = send(sockfd,hello,strlen(hello),0);
    if(nSend < 0)
    {
        fprintf(stdout,"Send Error:%s\n",strerror(errno));
        exit(1);
    }
    close(sockfd);*/
}
服务器端

#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdio.h>
include <stdlib.h>
#include <string.h>
#include <errno.h>

#define PORT 8888
#define WITE_QUEUE 5
#define BUF_SIZE 1024

int main()
{
struct sockaddr_in ser_addr,cli_addr;
int sockfd,Newsockfd;
int len_cli_addr;
//    char hello[] = "Hello,这是服务器!\n";
    char chat_buf[BUF_SIZE];
//    char buffer[128];
    int nSend,nRecv;
    fd_set readfds;
    int maxfd;
    int nSel;
    int pid;

sockfd = socket(AF_INET,SOCK_STREAM,0);
if(sockfd < 0)
{
fprintf(stdout,"Soket Error:%s\n",strerror(errno));
exit(1);
}

bzero(&ser_addr,sizeof(struct sockaddr_in));
ser_addr.sin_family = AF_INET;
ser_addr.sin_port = htons(PORT);
ser_addr.sin_addr.s_addr = htonl(INADDR_ANY);

if(bind(sockfd,(struct sockaddr *)&ser_addr,sizeof(struct sockaddr_in)) < 0)
{
fprintf(stdout,"Bind Error:%s\n",strerror(errno));
exit(1);
}

if(listen(sockfd,WITE_QUEUE) < 0)
{
     fprintf(stdout,"Listen Error:%s\n",strerror(errno));
        exit(1);
}

    while(1)
    {
        len_cli_addr = sizeof(struct sockaddr_in);
        Newsockfd = accept(sockfd,(struct sockaddr *)&cli_addr,&len_cli_addr);
        if(Newsockfd < 0)
        {
            fprintf(stdout,"Accpet Error:%s\n",strerror(errno));
            exit(1);
        }
        pid = fork();
        if(pid > 0)
        {
            close(Newsockfd);
            continue;
        }
        if(pid == 0)
        {
            printf("IP来自: %s\n",inet_ntoa(cli_addr.sin_addr.s_addr));
            while(1)
            {
                FD_ZERO(&readfds);
                FD_SET(0,&readfds);
                FD_SET(Newsockfd,&readfds);
                maxfd = 0;
                maxfd = (maxfd > Newsockfd ? maxfd : Newsockfd) + 1;

                nSel = select(maxfd,&readfds,NULL,NULL,NULL);
                if(FD_ISSET(Newsockfd,&readfds))
                {
                    bzero(chat_buf,BUF_SIZE);
                    nRecv = recv(Newsockfd,chat_buf,BUF_SIZE,0);
                    chat_buf[nRecv] = '\0';
                    printf("IP->%s : %s\n",inet_ntoa(cli_addr.sin_addr.s_addr),chat_buf);
                }
                if(FD_ISSET(0,&readfds))
                {
                    bzero(chat_buf,BUF_SIZE);
                    if(fgets(chat_buf,BUF_SIZE,stdin) > 0)
                    nSend = send(Newsockfd,chat_buf,BUF_SIZE,0);
                    sleep(1);
                }
            }//while(1)
            close(Newsockfd);
        }//if(pid==0)
        if(pid < 0)
        {
            printf("Fork Error!\n");
            exit(1);
        }
    }
    close(sockfd);
/*
        printf("IP来自: %s\n",inet_ntoa(cli_addr.sin_addr.s_addr));


        nSend = send(Newsockfd,hello,strlen(hello),0);
        if(nSend < 0)
        {
            fprintf(stdout,"Send Error:%s\n",strerror(errno));
            exit(1);
        }

        nRecv = recv(Newsockfd,buffer,128,0);
        if(nRecv < 0)
        {
            fprintf(stdout,"Received Error:%s\n",strerror(errno));
            exit(1);
        }
        buffer[nRecv] = '\0';
        printf("%s\n",buffer);
        close(Newsockfd);
    }
    close(sockfd);*/
}

分享到：