- 論壇徽章:
- 0
|
情景：客戶端通過socket向服務(wù)器發(fā)送 開始標志0x02+命令+數(shù)據(jù) +結(jié)束標志0x03
例如：2NEW|20130716001|M3
主要問題是：客戶端發(fā)送的數(shù)據(jù)長度是未知的，我現(xiàn)在的程序一次能接收的數(shù)據(jù)長度是定義好的，比如512,1024。我想做到結(jié)束不定長度的數(shù)據(jù)，檢測到結(jié)束標志0x03的時候才結(jié)束。
我現(xiàn)在的程序是阻塞的。請高手幫我看下，下面是我現(xiàn)在的程序，需要怎么修改才可以實現(xiàn)我說的功能，給個思路也可以。
main.c- #include <stdio.h>
- #include <pthread.h>
- #include "socket.h"
- int main(int argc, char *argv[])
- {
- pthread_t t;
- pthread_create(&t,NULL,mysocket,NULL); //socket
-
- while(1)
- {}
- return 0;
- }
- #include "socket.h"
- #include <stdio.h>
- #include <stdlib.h>
- #include <string.h>
- #include <sys/socket.h> /* socket definitions */
- #include <sys/types.h> /* socket types */
- #include <arpa/inet.h> /* inet (3) funtions */
- #include <unistd.h> /* misc. UNIX functions */
- /*******************************************************
- * 函數(shù)名稱：mysocket
- * 參數(shù)列表：void* args
- * 返回值： NULL
- * 函數(shù)功能：socket線程函數(shù)
- *******************************************************/
- void* mysocket(void* args)
- {
- unsigned char buf[MAX_LINE];
- unsigned char addr_p[INET_ADDRSTRLEN];
- unsigned int n,i,ret;
- int list_s; /* listening socket */
- int conn_s; /* connection socket */
- socklen_t len;
- short int port; /* port number */
- struct sockaddr_in servaddr; /* socket address structure */
- struct sockaddr_in clenaddr; /* socket address structure */
- /*清空結(jié)構(gòu)體*/
- memset(&servaddr,0,sizeof(servaddr));
- /* Set all bytes in socket address structure to
- zero, and fill in the relevant data members */
- memset(&servaddr, 0, sizeof(servaddr));
- servaddr.sin_family = AF_INET;
- servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
- servaddr.sin_port = htons(MYPORT);
- /* Create the listening socket */
- if ( (list_s = socket(AF_INET, SOCK_STREAM, 0)) < 0 ) {
- perror("create socket error:");
- }
- /*允許地址立即重用*/
- unsigned int bReuseaddr = 0x01;
- setsockopt(list_s,SOL_SOCKET,SO_REUSEADDR,(void *)&bReuseaddr,sizeof(bReuseaddr));
- /* Bind our socket addresss to the
- listening socket, and call listen() */
- if( bind(list_s, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) {
- perror("bind socket error:");
- }
- if ( listen(list_s, 10) < 0 ) {
- perror("listen socket error:");
- }
- printf("waiting ...\n");
- while(1)
- {
- len = sizeof(struct sockaddr_in);
- /* Wait for a connection, then accept() it */
- conn_s = accept(list_s, (struct sockaddr *) &clenaddr, &len);
- if(conn_s < 0) {
- perror("accept socket error:");
- }
- memset( buf, '\0', MAX_LINE );
- n = read(conn_s, buf, MAX_LINE);
- inet_ntop(AF_INET, &clenaddr.sin_addr, addr_p, sizeof(addr_p));
- printf("client IP is %s, port is %d\n", addr_p, ntohs(servaddr.sin_port));
- printf("read n = %d \n",n);
- if(n == 0){
- printf("no message! \n");
- close(conn_s);
- break;
- }
- printf("%s\n",buf);
- close(conn_s);
- }
- if(close(list_s) == -1){
- perror("fail to close");
- exit(1);
- }
- return NULL;
- }
- #ifndef _SOCKET_H
- #define _SOCKET_H
- #define MAX_LINE 8
- #define MYPORT 8000
- void* mysocket(void* args);
- #endif
客戶端：
client.c- #include <stdio.h>
- #include <sys/socket.h>
- #include <arpa/inet.h>
- #include <string.h>
- #include <stdlib.h>
- #define DEST_IP "127.0.0.1"
- #define DEST_PORT 8000
- int main(int argc, char *argv[])
- {
- struct sockaddr_in sin;
- int sfd,n,i;
- char *str = "1234567890";
- bzero( &sin, sizeof( sin ) );
- sin.sin_family = AF_INET;
- sin.sin_addr.s_addr = inet_addr( DEST_IP );
- sin.sin_port = htons( DEST_PORT );
- sfd = socket( AF_INET, SOCK_STREAM, 0 );
- connect( sfd, (struct sockaddr *)&sin, sizeof(sin));
- write( sfd, str, strlen( str ) );
- close(sfd);
- return 0;
- }
|
|
免費注冊
發(fā)表于 2013-07-18 11:20
