Socket 入门- 客户端回射程序

结果输出:
------------------------------------------------------
客户端:
[email protected]:~/Public/C$ ./postBackCli.out 127.0.0.1
connect OK
aaa
aaa
bbbbbbbbbbbbbbbbbbbbbbbbbbbbb
bbbbbbbbbbbbbbbbbbbbbbbbbbbbb
c
c
#
close OK
[email protected]:~/Public/C$ 
------------------------------------------------------
服务器端:
[email protected]:~/Public/C$ ./postBackSrv.out 
======waiting for client‘s request======
from:127.0.0.1,port:45050
---------华丽的分割线---------
postBackCli.c

//main函数中详细注释可查看博主--获取服务器时间实例--博文,内有较详细注释
//部分细节写的代码较草率,博主新入门,前辈勿喷
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h> 

#define MAXLINE 4096
void str_cli(FILE *fp,int sockfd);

int main(int argc, char** argv)
{
    int sockfd, n,rec_len;
    char recvline[4096], sendline[4096];
    char buf[MAXLINE];
    struct sockaddr_in servaddr; 

    if( argc != 2){
    printf("usage: ./client \n");
    exit(0);
    } 

    if( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
    printf("create socket error: %s(errno: %d)\n", strerror(errno),errno);
    exit(0);
    } 

    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_port = htons(8000);
    if( inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0){
    printf("inet_pton error for %s\n",argv[1]);
    exit(0);
    } 

    if( connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){
    printf("connect error: %s(errno: %d)\n",strerror(errno),errno);
    exit(0);
    }
    printf("connect OK\n");
    str_cli(stdin,sockfd);
    close(sockfd);
    printf("close OK\n");
    exit(0);
}
//回射处理函数
void str_cli(FILE *fp,int sockfd)
{
    char sendline[MAXLINE],recvline[MAXLINE];//定义两个缓冲区
    while (fgets(sendline,MAXLINE,fp)!= NULL)//从标准输入输入到sendline中
    {
      if(sendline[0] == ‘#‘)break;//如果输入#则退出循环,同时结束本次回射程序
      write(sockfd,sendline,strlen(sendline));//将sendline缓冲区中的数据写到"套接字"
      read(sockfd,recvline,MAXLINE);//从套接字读数据到recvline中
      fputs(recvline,stdout);//从recvline缓冲区读出到标准输出中
      bzero(recvline,sizeof(recvline));//清空接受缓冲区,每次都是最新的数据【需注意】
    }
}

  postBackSrv.c

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#define DEFAULT_PORT 8000 //默认端口
#define MAXLINE 4096
void str_echo(int sockfd);
int main(int argc, char** argv)
{
    int socket_fd, connect_fd;
    struct sockaddr_in servaddr,cliaddr;
    char buff[MAXLINE],temp[MAXLINE];
    int n;
    uint32_t len;
     //初始化Socket
    if( (socket_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
    {
    printf("create socket error: %s(errno: %d)\n",strerror(errno),errno);
    exit(0);
    }
    //初始化
    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//IP地址设置成INADDR_ANY,让系统自动获取本机的IP地址。
    servaddr.sin_port = htons(DEFAULT_PORT);//设置的端口为DEFAULT_PORT 

    //将本地地址绑定到所创建的套接字上
    if( bind(socket_fd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1){
    printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno);
    exit(0);
    }
    //开始监听是否有客户端连接
    if( listen(socket_fd, 10) == -1){
    printf("listen socket error: %s(errno: %d)\n",strerror(errno),errno);
    exit(0);
    }
    printf("======waiting for client‘s request======\n");
    while(1){
    len=sizeof(cliaddr);
    //阻塞直到有客户端连接
        connect_fd = accept(socket_fd, (struct sockaddr *)&cliaddr,&len);

    //向客户端发送回应数据
        if(!fork())//进入子进程,在子进程服务终止时会给父进程发送一个SIGCHLD信号,父进程未处理,子进程进入僵死状态,必须清理僵死状态,这里牵扯Unix信号的处li.
    {    //子进程在其内部关闭监听套接字
        close(socket_fd);
               str_echo(connect_fd);
        //输出客户协议信息
        printf("\nfrom:%s,port:%d\n",(char *)inet_ntop(AF_INET,&cliaddr.sin_addr,temp,sizeof(temp)),ntohs(cliaddr.sin_port));
     close(connect_fd);
     exit(0);
      }
        close(connect_fd);
    }
    close(socket_fd);
}
void str_echo(int sockfd)
{
    ssize_t n;
    char buf[MAXLINE];
    while(( n=read(sockfd,buf,MAXLINE))>0)
      write(sockfd,buf,n);
    if(n<0 && errno==EINTR)
     perror("str_echo:red error");
}

  

时间: 2024-10-06 11:07:47

Socket 入门- 客户端回射程序的相关文章

服务器客户端回射程序-自己设计包的结构

这次是个点对点,不过我自己设计包,包中包括发送的字符串的长度,和实际的字符串,使用结构体来表示. 客户端跟服务器在接收报文时,首先接收字符串的长度这一数值,然后将这一数值作为参数传入readn接收固定长度的字节数字符串. 看代码,首先是服务器端: 1 /*使用发送固定字节数报文的点对点聊天程序*/ 2 #include<stdio.h> 3 #include<unistd.h> 4 #include<sys/types.h> 5 #include<sys/sock

回射程序改进3——消息的群发

前文列表: 简单的回射程序 回射程序改进1 回射程序改进2--群发消息(fork)错误的尝试 目的: 设计一个C/S程序,客户端发送/接收消息,服务端将从客户端接收到的消息群发给其它已连接套接字,产生 类似群聊的效果 相对于之前的改进: 1.客户端可以在服务端终止后得到通知 2.客户端使用shutdown()函数处理批量输入产生的问题 3.服务端使用select()函数管理套接字(单进程),而非使用fork()让每个子进程管理一个套接字(多进程) select函数介绍 程序代码: 客户端: 1

unp TCP 客户端服务器回射程序中对SIGCHLD信号的处理

第五章中,有一个例子模拟客户端并发的终止TCP连接,服务器捕捉并处理SIGCHLD信号并调用waitpid函数防止僵死进程的出现.信号处理函数中核心的一句是: 1 while ( (pid = waitpid(-1, &statloc, WNOHANG)) > 0 ) 2 { 3 printf("wait child pid:%ld\n",(long)pid); 4 } 这是在使用wait函数时不能解决N个子进程同时终止时导致只有1个子进程被wait而其他N-1个子进程变

linux支持并发的服务器回射程序实例

实例一:不支持并发,单服务器---单客户端 /************************************************************************* > File Name: ser01.c > Author: > Mail: > Created Time: 2015年11月22日 星期日 10时22分17秒 *****************************************************************

自己封装一个readline函数实现服务器客户端回射

实现的功能:一次只能读取一行,客户端输入之后,一回车,马上字符串传到服务器端并显示在终端,然后服务器端将字符串又传回给客户端. 服务器端可以接收多个客户端的连接请求,并fork一个子进程来进行服务. (1)封装一个只能访问套接字描述符的readline函数 (2)服务器端启动SO_REUSEADDR套接字选项,以便服务器端不必等待TIME_WAIT状态 这是服务器端代码: 1 #include<unistd.h> 2 #include<sys/types.h> 3 #include

UNIX网络编程卷1 回射客户程序 TCP客户程序设计范式

本文为senlie原创,转载请保留此地址:http://blog.csdn.net/zhengsenlie 下面我会介绍同一个使用 TCP 协议的客户端程序的几个不同版本,分别是停等版本.select 加阻塞式 I/O 版本. 非阻塞式 I/O 版本.fork 版本.线程化版本.它们都由同一个 main 函数调用来实现同一个功能,即回射程序客户端. 它从标准输入读入一行文本,写到服务器上,读取服务器对该行的回射,并把回射行写到标准输出上. 其中,非阻塞式 I/O 版本是所有版本中执行速度最快的,

第十篇:基于TCP的一对回射客户/服务器程序及其运行过程分析( 上 )

前言 本文将讲解一对经典的客户/服务器回射程序,感受网络编程的大致框架( 该程序稍作改装即可演变成各种提供其他服务的程序 ):同时,还将对其运行过程加以分析,观察程序背后协议的执行细节,学习调试网络程序的技巧. 客户端 1 #include "unp.h" 2 3 void str_cli(FILE *fp, int sockfd); 4 5 int 6 main(int argc, char **argv) 7 { 8 int sockfd; 9 struct sockaddr_in

第十一篇:基于TCP的一对回射客户/服务器程序及其运行过程分析( 下 )

执行分析 1. 打开服务器进程: 2. 执行netstat -a命令观察当前的连接状态: 第1条连接记录说明:绑定了本地主机的任意IP,端口为9877,目前处于监听状态. 3. 打开客户进程: 4. 执行netstat -a命令观察当前的连接状态,发现了两个新的连接: 以及 上面一个连接说明一个连接到服务器的连接,客户端临时端口是32818,目的端口正是先前的9877,连接状态为已建立,对应已连接套接字: 下面一个连接说明一个连接到客户端的连接,服务端端口为9877,目的端口是32818,这个连

第十二篇:并发回射服务器的具体实现及其中僵尸子进程的清理( 上 )

前言 本文将分为两个部分,第一部分具体实现一对并发回射服务器/客户程序( 看过前面那篇文章的这部分可不看 重复了 ):第二部分为服务器添加僵尸子进程自动清理机制. 那么服务器具体怎么实现并发?怎么会有僵尸进程?僵尸进程又是什么?如何处理这些僵尸进程 ... 本文将为你一一解惑. 回射并发服务器 功能:接收用户发送过来的数据后再发送回用户,且能同时处理多个用户请求. 大体思路:每当收到用户请求,服务器就fork一个子进程,让子进程去处理客户请求. 实现代码: 1 #include "unp.h&q