[ARTIK 050] TCP Client

1. 개요

  Server(PC)와 Client(ARTIK 050)이 연결이 되면 Client가 Server에게 'ping'이라는 메세지를 보내고 Server가 메세지를 받으면 Client에게 응답으로 'pong'이라는 메세지를 보냅니다.

2. Source Code(PC) - TCP Server

 #include <stdio.h> #include <stdlib.h> #include <WinSock2.h> #include <windows.h> #if defined(_WIN32) #define _CRT_SECURE_NO_WARNINGS #define WIN32_LEAN_AND_MEAN #pragma comment(lib, "Ws2_32.lib") #define sleep(sec) Sleep((sec)*1000) #endif typedef unsigned long long u64; u64 GetMicroCounter(); #define BUF_SIZE 100 int main(int argc, char **argv) { u64 start, end; WSADATA wsaData; struct sockaddr_in local_addr; SOCKET s_listen; if (argc != 2) { printf("Command parameter does not right.\n"); exit(1); } WSAStartup(MAKEWORD(2, 2), &wsaData); if ((s_listen = socket(AF_INET, SOCK_STREAM, 0)) < 0) { printf("Socket Creat Error.\n"); exit(1); } memset(&local_addr, 0, sizeof(local_addr)); local_addr.sin_family = AF_INET; local_addr.sin_addr.s_addr = htonl(INADDR_ANY); local_addr.sin_port = htons(atoi(argv[1])); if (bind(s_listen, (SOCKADDR *)&local_addr, sizeof(local_addr)) == SOCKET_ERROR) { printf("Socket Bind Error.\n"); exit(1); } if (listen(s_listen, 5) == SOCKET_ERROR) { printf("Socket Listen Error.\n"); exit(1); } printf("This server is listening... \n"); struct sockaddr_in client_addr; int len_addr = sizeof(client_addr); SOCKET s_accept; char buf[BUF_SIZE]; int Bytes; char *msg = "pong\n"; int sendBytes; s_accept = accept(s_listen, (SOCKADDR *)&client_addr, &len_addr); if (s_accept) { printf("Connection Request from Client [IP:%s, Port:%d] has been Accepted\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); Bytes = recv(s_accept, buf, BUF_SIZE, 0); printf("%s\n", buf); sendBytes = send(s_accept, msg, sizeof(msg), 0); Sleep(5000); closesocket(s_accept); } closesocket(s_listen); WSACleanup(); return 0; }

3. Souce Code(ARTIK 050) - TCP Client

  파라메터는 <Server IP> <port> 2개 입력해 주시면 됩니다.

wiced_result_t result; wiced_packet_t* packet; wiced_packet_t* rx_packet; char* tx_data; char* rx_data; uint16_t rx_data_length; uint16_t available_data_length; /* Create the TCP packet. Memory for the tx_data is automatically allocated */ if (wiced_packet_create_tcp(&tcp_client_socket, TCP_PACKET_MAX_DATA_LENGTH, &packet, (uint8_t**)&tx_data, &available_data_length) != WICED_SUCCESS) { WPRINT_APP_INFO(("TCP packet creation failed\n")); return WICED_ERROR; } /* Write the message into tx_data" */ sprintf(tx_data, "%s", "ping\n"); /* Set the end of the data portion */ wiced_packet_set_data_end(packet, (uint8_t*)tx_data + strlen(tx_data)); /* Send the TCP packet */ if (wiced_tcp_send_packet(&tcp_client_socket, packet) != WICED_SUCCESS) { WPRINT_APP_INFO(("TCP packet send failed\n")); /* Delete packet, since the send failed */ wiced_packet_delete(packet); return WICED_ERROR; } /* Receive a response from the server and print it out to the serial console */ result = wiced_tcp_receive(&tcp_client_socket, &rx_packet, TCP_CLIENT_RECEIVE_TIMEOUT); if( result != WICED_SUCCESS ) { WPRINT_APP_INFO(("TCP packet reception failed\n")); /* Delete packet, since the receive failed */ wiced_packet_delete(rx_packet); return WICED_ERROR; } /* Get the contents of the received packet */ wiced_packet_get_data(rx_packet, 0, (uint8_t**)&rx_data, &rx_data_length, &available_data_length); /* Null terminate the received string */ rx_data[rx_data_length] = '\x0'; printf("%s\n",rx_data); wiced_packet_delete(packet); wiced_packet_delete(rx_packet); return WICED_SUCCESS;

4. 결과

5. 소스 저장소

• https://github.com/cckr2/ARITK