main.c
==========================
#include
#include
#include
#include
#include
#include
#include
#include "sockcomm.h"
#define TimeOut 30
static int iSockID1;
static int iSockID;
static int iSock;
typedef void sigfunc( int );
jmp_buf tohere2;int CloseSock();【中间业务 server 端通讯jizhi源程序】
main()
{
int iRet,p,p1,len,pid;
int iPort,jPort,packlen;
int iSndLen,iRcvLen,retcode;
long mtype;
char type[7];
char szBuf[1028];
char rzBuf[1028];
char szHost[20],szSnd[1028],szRcv[1028];
char requ[1025],resp[1028];
char msgbuf[1028];
char head;
sigfunc *sig1;
Record *rec;
MsgId = msg_init();
mtype = 6L;iPort = 8300;
iSockID = sockServerOpen( iPort );
if( iSockID < 0 )
{
printf("SockServerOpen FAIL! ret_code = %dn",iSockID);
exit(0);
}
signal(SIGCLD,SIGIGN);
signal(SIGINT,CloseSock);while(1)
{
memset( szBuf,"",1028);
iSock = sockListen( iSockID );
if( iSock < 0 ) break;
iRet = sockRecvBuf( iSock, szBuf, 4 ,TimeOut );
if(iRet<=0)
{
printf("nn接收网点socket失败!n");
close(iSock);
continue;
}
len=atoi(szBuf);
iRet = sockRecvBuf( iSock, szBuf, len ,TimeOut );
if(iRet<=0)
{
printf("nn接收网点socket失败!n");
close(iSock);
continue;
}printf("nn接收网点socket:[%s]n",szBuf);if((pid=fork())<0 )
{
printf("Fork Error!");
close(iSock);
continue;
}
else if( pid>0 )
{
strcpy( szHost,"192.168.0.1" );
jPort = 5555;
memset( szRcv,0,sizeof(szRcv) );iSockID1=sockClIEntOpen( szHost, jPort);
/***** Begin to Send *****/
packlen = htons(strlen(szBuf));
iRet=sockSendBuf( iSockID1, (char *)&packlen,2,TimeOut);
if(iRet<0)
{
printf("发送socket ERROR 1!n");
close(iSockID1);
close(iSock);
exit (-1);
}
len = strlen(szBuf);
iRet=sockSendBuf( iSockID1, szBuf,len,TimeOut);
if(iRet<0)
{
printf("发送socket ERROR 2!n");
close(iSockID1);
close(iSock);
exit (-1);
}
/***** End of Send *****//***** Begin to Recv Return Code *****/
iRet=sockRecvBuf( iSockID1,(char *)&len,2 ,TimeOut);
if(iRet<0)
{
printf("接收socket ERROR 1!n");
close(iSockID1);
close(iSock);
exit (-1);
}
len=ntohs(len);
memset(szRcv,0,sizeof(szRcv));
iRet=sockRecvBuf( iSockID1, szRcv,len,TimeOut);
if(iRet<0)
{
printf("接收socket ERROR 2!n");
close(iSockID1);
close(iSock);
exit (-1);
}
printf("接收socket:[%s]n",szRcv);
/***** End of Recv Return Code *****/
memset(szBuf,"",1028);
sprintf(szBuf,"d",len);
iRet=sockSendBuf(iSock,szBuf,4,TimeOut);
if(iRet<0)
{
printf("发送socket至网点失败1!n");
close(iSockID1);
close(iSock);
exit(-1);
}
iRet=sockSendBuf(iSock,szRcv,len,TimeOut);
if(iRet<0)
{
printf("发送socket至网点失败2!n");
close(iSockID1);
close(iSock);
exit (-1);
}
printf("发送socket至网点成功!n");
}
close(iSock);
}
}
int CloseSock()
{
close(iSock);
close(iSockID);
close(iSockID1);
return 0;
}comm.c 通讯函数
=============================#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include typedef void sigfunc( int );
jmp_buf tohere1;
void alrm1(int a)
{
alarm(0);
longjmp( tohere1, 1 );
}int sockServerOpen( int sinPort )
{
int sHandle;
int iLen;
struct sockaddr_in server; if( ( sHandle = socket( AF_INET, SOCK_STREAM, 0 ) ) < 0 )
return sockOpenFail;
server.sin_family = AF_INET;
server.sin_addr.s_addr = ntohl(INADDR_ANY);
server.sin_port = ntohs(sinPort); if( bind( sHandle, ( struct sockaddr * )&server, sizeof(server) ) < 0 )
return sockBindFail;
推荐阅读
- 如何在OpenServer上建立可以显示中文的终端机
- 济宁经纬度是多少
- 什么叫双电源末端切换
- simp server for unix 配置教程
- 完美世界中玩手游端游联动具体操作方法
- 在手机端完美解决百度云下载速度慢的问题
- 只针对非图形的用户 如何注销sco openserver的空闲用户
- 端午节手抄报资料内容短 端午节手抄报
- SCO OpenServer序列号sn
- 在安装SCO OpenServer时如何设置硬盘驱动器