7天rtos网络编程第3~5day 作业

发布于 2018-10-19 18:46:29 浏览：1244 订阅该版

* 本帖最后由 wo4fisher 于 2018-10-19 18:48 编辑 *

1、要求： 通过编程实现：1）. 使用 login 命令登录上服务器聊天室，并将服务器返回的信息通过串口打印 出来2）. 使用 say 命令通知服务器你的个人姓名和作业时间 “My name is Yqiu, I'm doingthis job at 20180730”，并将服务器返回的信息打印出来3）. 使用 look 命令查看聊天室人员，并将服务器返回的信息打印出来4）. 使用 who 命令查看我是谁，并将服务器返回的信息打印出来5）. 使用 say 命令告诉服务器我看到有哪些人在聊天室6）. 使用 say 命令告诉服务器我准备退出了7）. 使用 logout 退出聊天室2、思路：使用tcp client的方式实现与聊天室的socket通信3、具体步骤：1）.创建一个socket2）.与服务器端建立连接3）.连接成功的话，用login登陆4）.say....聊天5）.用look查询6）.用who查询7）.logout4、实现：1）```#include <rtthread.h>
#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */
#include <netdb.h>
#include <string.h>
#include <stdio.h>
#include <finsh.h>

#define BUFSZ   1024

/* 指向线程控制块的指针 */
static rt_thread_t tid1 = RT_NULL;

static int sock = 0;
char *recv_data;
static char send_data[100] = {0};
int ret;

/* tcpClient thread entry*/
static void thread_tcpClient_entry(void* parameter) {
 int bytes_received;
 /* 分配用于存放接收数据的缓冲 */
 recv_data = rt_malloc(BUFSZ);
 if (recv_data == RT_NULL) {
 rt_kprintf("No memory ");
 return;
 }

while(1) {
 /* 从sock连接中接收最大BUFSZ - 1字节数据 */
 bytes_received = recv(sock, recv_data, BUFSZ - 1, 0);
 if (bytes_received < 0) {
 /* 接收失败，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" received error,close the socket. ");

/* 释放接收缓冲 */
 rt_free(recv_data);
 rt_thread_delete(tid1);
 } else if (bytes_received == 0) {
 /* 默认 recv 为阻塞模式，此时收到0认为连接出错，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" received error,close the socket. ");

/* 释放接收缓冲 */
 rt_free(recv_data);
 rt_thread_delete(tid1);
 }
 /* 有接收到数据，把末端清零 */
 recv_data[bytes_received] = '\0';
 /* 在控制终端显示收到的数据 */
 rt_kprintf(" bytes_received=%d,Received data = %s ", bytes_received,recv_data);
 }
}

/* 聊天客户端初始化：新建socket，成功建立连接，并发出初始帧信息，创建接收线程 */
static int rt_tcpclient_init(void) {
        
        struct hostent *host;
        struct sockaddr_in server_addr;
        const char *url;
        int port;

url = "183.193.243.90";//"192.168.67.226";//argv[1];
        port =5000; //strtoul(argv[2], 0, 10);

/* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
        host = gethostbyname(url);

/* 分配用于存放接收数据的缓冲 */
 recv_data = rt_malloc(BUFSZ);
 if (recv_data == RT_NULL) {
 rt_kprintf("No memory ");
 return 0;
 }

/* 创建一个socket，类型是SOCKET_STREAM，TCP类型 */
 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
 /* 创建socket失败 */
 rt_kprintf("Socket error ");

/* 释放接收缓冲 */
                rt_free(recv_data);
                return 0;
        }

/* 初始化预连接的服务端地址 */
        server_addr.sin_family = AF_INET;
        server_addr.sin_port = htons(port);
        server_addr.sin_addr = *((struct in_addr *)host->h_addr);
        rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

/* 连接到服务端 */
 if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) {
 /* 连接失败 */
 rt_kprintf("Connect fail! ");
 closesocket(sock);

/*释放接收缓冲 */
 rt_free(recv_data);
 return 0;
 } else {
 rt_kprintf("Connect success! ");
 }
 
 /* 创建线程1 */
 tid1 = rt_thread_create("tcpClient",
 thread_tcpClient_entry, (void*)1, /* 线程入口是thread_entry, 入口参数是1 */
 1024, 20, 5); //THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE 
 if (tid1 != RT_NULL){
 rt_kprintf("tcpclient thread init ok,connect tcp server success ");
 rt_thread_startup(tid1);
 }
 else
 return -1;

return 0;
}

void login(int argc, char **argv) {
        const char *usrID;

usrID = argv[1];
 sprintf(send_data, "login %s ", usrID);