?? npcserver.c
字號:
#include <stdio.h>#include <strings.h>#include <sys/types.h>#include <sys/socket.h>#include <sys/time.h>#include <sys/stat.h>#include <netinet/in.h>#include <arpa/inet.h>#include <stdlib.h>#include <unistd.h>#include <fcntl.h>#include <netdb.h>#include <errno.h>#include "autil.h"#include "util.h"#include "net.h"#include "char.h"#include "char_base.h"#include "log.h"#include "handletime.h"#include "npcserver.h"#include "lssproto_serv.h"//#include "chatmagic.h"#include "lssproto_util.h"#ifdef _NPCSERVER_NEW#include "npcshandle.h"#define SEPARATOR ";"NPCMessC *NPCMess;static int AskListOK = 0;//Mserver NETProcint NSproto_DispatchMessage(int fd,char* encoded){ char funcname[1024]; if( NPCMESS_setChar( encoded) == FALSE ) return -1; memset( funcname, 0, sizeof( funcname)); if( NPCMESS_getChar( funcname, sizeof( funcname)) == FALSE ) { return 0; } if( !strcmp( funcname , "TEST" )){ char buf1[1024],buf2[1024],buf3[1024]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; if( NPCMESS_getChar( buf2, sizeof( buf2)) == FALSE ) return 0; if( NPCMESS_getChar( buf3, sizeof( buf3)) == FALSE ) return 0; return 0; }else if( !strcmp( funcname , "NPC_LOGIN" )){ char buf1[256]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; NPCS_NpcSLogin_recv( fd, buf1); }else if( !strcmp( funcname , "NPC_ASKLIST" )){ char buf1[4096]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; NPCS_AskNpcList_recv( fd, buf1); return 0; }else if( !strcmp( funcname , "NPCS_CREATE" )){ int dir, floor, x, y, image, npcsindex; char Name[256], buf1[256]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; npcsindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; memcpy( Name, buf1, strlen( buf1)+1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; dir = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; image = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; floor = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; x = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; y = atoi( buf1); if( NPCSERVER_CreateObjindexFromServer( fd, npcsindex, Name, image, dir, floor, x, y) == FALSE ){ } return 0; }else if( !strcmp( funcname , "NPC_TALKMESS" )){ char TalkMess[1024], buf1[1024]; int npcobjindex, charaindex, charobjindex, Color; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; npcobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charaindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; memcpy( TalkMess, buf1, strlen( buf1)+1 ); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; Color = atoi( buf1); NPCS_NpcTalkMess_recv( npcobjindex, charaindex, charobjindex, TalkMess, Color); }else if( !strcmp( funcname , "NPC_WINMESS") ){ int charaindex, charobjindex, npcobjindex; int seqno, windowtype, buttontype, page; char Token[1024], buf1[1024]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; npcobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charaindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; memcpy( Token, buf1, strlen( buf1)+1); Token[ strlen( Token)+1] = 0; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; seqno = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; windowtype = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; buttontype = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; page = atoi( buf1); NPCS_NpcWinMess_recv( npcobjindex, charaindex, charobjindex, Token, seqno, windowtype, buttontype, page); }else if( !strcmp( funcname , "NPC_CHECKFREE") ){ int charaindex, charobjindex, npcobjindex; char buf1[4096], freeMess1[4096]; if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; npcobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charaindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; charobjindex = atoi( buf1); if( NPCMESS_getChar( buf1, sizeof( buf1)) == FALSE ) return 0; memcpy( freeMess1, buf1, strlen( buf1)+1); NPCS_NpcCheckFreeMess_recv( npcobjindex, charaindex, charobjindex, freeMess1); }else{ } return 0;}void NPCS_NpcCheckFreeMess_recv( int npcobjindex, int charaindex, int charobjindex, char *CheckfreeMess){ if( NPCS_HandleCheckFreeMess( npcobjindex, charaindex, charobjindex, CheckfreeMess) == TRUE ){ }else { }}void NPCS_NpcWinMess_recv( int npcobjindex, int charaindex, int charobjindex, char *WinMess, int seqno, int windowtype, int buttontype, int page){ int fd = getfdFromCharaIndex( charaindex); if( CHAR_getWorkInt( charaindex, CHAR_WORKOBJINDEX) != charobjindex ) return; CHAR_setWorkInt( charaindex, CHAR_WORKSHOPRELEVANT, page); lssproto_WN_send( fd, windowtype, buttontype, seqno, npcobjindex, WinMess);}void NPCS_NpcWinMess_send( int npcobjindex, int npcindex, int charaindex, char *WinMess, int seqno, int select){ char buf[4096]; int charobjindex, page; memset( buf, 0, sizeof( buf)); charobjindex = CHAR_getWorkInt( charaindex, CHAR_WORKOBJINDEX); page = CHAR_getWorkInt( charaindex, CHAR_WORKSHOPRELEVANT); sprintf( buf, "NPC_WINMESS %d %d %d %d %s %d %d %d\n", npcindex, npcobjindex, charaindex, charobjindex, WinMess, seqno, select, page); lssproto_Send( npcfd, buf);}void NPCS_AskNpcTalk_send( int objindex, int npcsindex, int charaindex, char *Nlist){//NPCS_TALK char buf[4096]; int charobjindex; if( !CHAR_CHECKINDEX( charaindex) ) return; memset( buf, 0, sizeof( buf)); charobjindex = CHAR_getWorkInt( charaindex, CHAR_WORKOBJINDEX); sprintf( buf, "NPCS_TALK %d %d %d %d %s\n", npcsindex, objindex, charaindex, charobjindex, Nlist); lssproto_Send( npcfd, buf);}void NPCS_AskNpcList_recv( int fd, char *Nlist){ char Npclist[256]; int i=1, createnpc = 0; while( getStringFromIndexWithDelim( Nlist, "|", i, Npclist,sizeof(Npclist) ) != FALSE ){ char buf1[256], NpcName[256]; int npcsindex, dir, floor, x, y, image; i++; if( getStringFromIndexWithDelim( Npclist, ",", 1, buf1, sizeof( buf1)) == FALSE ) continue; npcsindex = atoi( buf1); if( getStringFromIndexWithDelim( Npclist, ",", 2, buf1, sizeof( buf1)) == FALSE ) continue; memcpy( NpcName, buf1, strlen( buf1)+1); if( getStringFromIndexWithDelim( Npclist, ",", 3, buf1, sizeof( buf1)) == FALSE ) continue; dir = atoi( buf1); if( getStringFromIndexWithDelim( Npclist, ",", 4, buf1, sizeof( buf1)) == FALSE ) continue; image = atoi( buf1); if( getStringFromIndexWithDelim( Npclist, ",", 5, buf1, sizeof( buf1)) == FALSE ) continue; floor = atoi( buf1); if( getStringFromIndexWithDelim( Npclist, ",", 6, buf1, sizeof( buf1)) == FALSE ) continue; x = atoi( buf1); if( getStringFromIndexWithDelim( Npclist, ",", 7, buf1, sizeof( buf1)) == FALSE ) continue; y = atoi( buf1); NpcName[ strlen( NpcName)+1] = 0; if( NPCSERVER_CreateObjindexFromServer( fd, npcsindex, NpcName, image, dir, floor, x, y) == FALSE ){ }else{ createnpc++; } }}void NPCS_AskNpcList_send( int fd){ char buf[4096]; memset( buf, 0, sizeof( buf)); sprintf( buf, "NPC_ASKLIST\n"); lssproto_Send(fd, buf);}void NPCS_NpcSLogin_recv( int fd, char *Mess){ if( !strcmp( Mess, "OK") ){ if( AskListOK == 0 ){ NPCS_AskNpcList_send( fd); AskListOK = 1; } }else { }}void NPCS_NpcSLogin_send( int fd){ char buf[4096]; memset( buf, 0, sizeof( buf)); sprintf( buf, "NPC_LOGIN ABC\n"); lssproto_Send(fd, buf);}void NPCS_NpcTalkMess_recv( int npcobjindex, int charaindex, int charobjindex, char *TalkMess, int Color){ NPCS_NpcstalkToCli( charaindex, npcobjindex, TalkMess, Color);}int connectNpcServer(char* hostname,unsigned short port){ struct sockaddr_in sock; struct hostent* hoste; int fd,lr; fd_set fdset,fde; struct timeval tmv; memset( &sock , 0 , sizeof( struct sockaddr_in ) ); sock.sin_family = AF_INET; sock.sin_port = htons( port ); sock.sin_addr.s_addr = inet_addr( hostname ); if( sock.sin_addr.s_addr == -1 ){ hoste = gethostbyname( hostname ); if( hoste == NULL ){ print( "獲取主機名: %s\n", hostname); return -1; } memcpy((void*)&sock.sin_addr.s_addr , hoste->h_addr , sizeof(struct in_addr) ); } fd = socket( AF_INET, SOCK_STREAM , 0 ); if( fd == -1 ){ print("Cannot Create Socket( errno:%d)\n",errno ); return -1; } //set the no block if ( fcntl(fd,F_SETFL,O_NONBLOCK) == -1 ){ print("set noblock error!\n"); return -1; } lr = connect(fd,(struct sockaddr*)&sock,sizeof(struct sockaddr_in)); if( lr != 0 ){ if ( errno != EINPROGRESS ){ print("Cannot connect. (errno:%d)\n",errno ); close(fd); return -1; } } FD_ZERO(&fdset); FD_SET(fd,&fdset); FD_SET(fd,&fde); tmv.tv_sec =3; tmv.tv_usec = 0; lr=select(fd+1,NULL,&fdset,&fde,&tmv); if (FD_ISSET(fd,&fde)){ print("connectNPCS fde\n"); close(fd); //add more return -1; } if ( lr > 0 && FD_ISSET(fd,&fdset)){ int errorcode; int errorcodelen; errorcode=1; errorcodelen=sizeof(errorcode); getsockopt(fd,SOL_SOCKET,SO_ERROR,&errorcode,&errorcodelen); if (errorcode == 0 ){ fcntl(fd,F_SETFL,0); print("connectNPCS return fd=%d\n",fd); return fd; }else{ print("connectNPCS errorcode error\n"); close(fd); return -1; } }else{ close(fd); return -1; }}void NPCS_SendProbe( int fd){ char buf[65535]; int i; memset( buf, 0, sizeof( buf)); sprintf( buf, "TEST %d,%d,%s,%s", 99999, 99999, "1234567891012345678901234567890", "1234567891012345678901234567890" ); strcat( buf, " "); for( i=0; i<5; i++) { if( i==0 ) strcat( buf, "99999"); else strcat( buf, ",99999"); } strcat( buf, " "); for( i=0; i<15; i++) { if( i==0 ) strcat( buf, "99999"); strcat( buf, ",99999"); } strcat( buf, "\n"); lssproto_Send(fd, buf);}BOOL NPCMESS_setChar( char *buf){ char Mbuf[4096]; int i=0,j=0; int len=0; NPCMessC *Works; NPCMessC *point; point = NULL; memset( Mbuf, 0, sizeof( Mbuf)); sprintf( Mbuf, "%s", buf); NPCMess = NULL; while( Mbuf[i] != '\0' ) { if( Mbuf[i] == '\n' ) Mbuf[i] = '\0'; i++; } i=0; len = 0; while( Mbuf[i] != '\0' && Mbuf[j] != '\0' ) { j=i; len = 0; while( Mbuf[j] != ' ' && Mbuf[j] != '\0') { len++; j++; } Works = MESS_getNew(); if( Works == NULL ) return FALSE; memcpy( Works->buf, &Mbuf[i], len); Works->len = len; if( NPCMess == NULL ) { NPCMess = Works; point = Works; }else { point->next = Works; point = point->next; } i = (j+1); } return TRUE;}BOOL NPCMESS_getChar( char *buf, int len){ NPCMessC *Works; Works = NPCMess; if( Works == NULL ) return FALSE; memcpy( buf, Works->buf, len); buf[ strlen( buf)+1] = 0; NPCMess = Works->next; free( Works); return TRUE;}NPCMessC *MESS_getNew(){ NPCMessC *MBUF=NULL; MBUF = (NPCMessC *) calloc( 1, sizeof( struct _NPCMessCommand) ); if( MBUF == NULL ) return NULL; memset( MBUF->buf, 0, sizeof( MBUF->buf)); MBUF->len = 0; MBUF->next = NULL; return MBUF;}#endif?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -