wengzuhong：看过来！AS/400上C语言Socket编程

tomcats

标题： 用C语言Socket编程

AS/400上用C语言Socket编程,给你提供个例程，在AS/400和unix上都可以用。
但是AS/400和unix通讯(socket)需要用EBCDIC到ASCII的转换程序(函数)。

例程如下： server.c

/***********************************************/
/* TCP/IP面向连接服务端程序 1998.9 IBM */
/* Server Connection-Oriented Protocol */
/* Header files needed to use the sockets API. */
/* File contain Macro, Data Type and Structure */
/* definitions along with Function prototypes. */
/***********************************************/
/* in qcle/h file */
#include <stdio.h>;
#include <stdlib.h>;
#include <string.h>;

/* in qsysinc library */
#include <sys/time.h>;
#include <sys/types.h>;
#include <sys/socket.h>;
#include <netinet/in.h>;
#include <errno.h>;
#include <unistd.h>;

/* BufferLength is 250 bytes */
#define BufferLength 250

/* Server port number */
#define SERVPORT 3005

void main()
{
/*********************************************/
/* Variable and structure definitions. */
/*********************************************/
int sd, sd2, rc, length = sizeof(int);
int addrlen = 0, totalcnt = 0, on = 1;
char temp;
char buffer[BufferLength];
char bufunix[BufferLength];
struct sockaddr_in serveraddr;
fd_set read_fd;
int *buflen;

struct timeval timeout;

timeout.tv_sec = 10;
timeout.tv_usec = 0;
buflen=(int *)malloc(1);
*(buflen)=BufferLength;
*(buflen+1)='\0';

/* Get a socket descriptor */
if ((sd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("socket() failed";
exit(-1);
}

/* Allow socket descriptor to be reuseable */
if ((rc = setsockopt(sd, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on))) < 0)
{
perror("setsockopt() failed";
close(sd);
exit(-1);
}

/* bind to an address */
memset(&serveraddr, 0x00, sizeof(struct sockaddr_in));
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(SERVPORT);
serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);

if ((rc = bind(sd, (struct sockaddr *)&serveraddr,
sizeof(serveraddr))) < 0)
{
perror("bind() failed";
close(sd);
exit(-1);
}

/* Up to 10 clients can be queued */
if ((rc = listen(sd, 10)) < 0)
{
perror("listen() failed";
close(sd);
exit(-1);
}

printf("Ready for client connect()...\n";
/* accept() the incoming connection request. */
if ((sd2 = accept(sd, (struct sockaddr *)NULL, &addrlen)) < 0)
{
perror("accept() failed";
close(sd);
exit(-1);
}

/* Wait for up to 10 seconds on */
/* select() for data to be read. */
FD_ZERO(&read_fd);
FD_SET(sd2,&read_fd);
rc = select(sd2+1,&read_fd,NULL,NULL,&timeout);
if ( (rc == 1) && (FD_ISSET(sd2,&read_fd)) )
{
/* Read data from the client. */
totalcnt = 0;
while(totalcnt < BufferLength)
{
/* read() from client */
rc = read(sd2, buffer, BufferLength-totalcnt);
STR_400ToPC(buffer,bufunix,BufferLength,buflen);
printf("AS400 to server:\n%s\n",bufunix);
if (rc < 0)
{
perror("read() failed";
close(sd);
close(sd2);
exit(-1);
}
else if (rc == 0)
{
printf("partner program has issued a close()";
close(sd);
close(sd2);
exit(-1);
}
else
totalcnt += rc;
}
}
else if (rc < 0)
{
perror("select() failed";
close(sd);
close(sd2);
exit(-1);
}
else /* rc == 0 */
{
printf("select() timed out.\n";
close(sd);
close(sd2);
exit(-1);
}

/* write() the 250 bytes of 'a's */
/* back to the client. */
rc = write(sd2, buffer, totalcnt);
STR_400ToPC(buffer,bufunix,BufferLength,buflen);
printf("Back to client:\n%s\n",bufunix);
if (rc != totalcnt)
{
perror("write() failed");

/* Get the error number. */
rc = getsockopt(sd2, SOL_SOCKET, SO_ERROR, &temp, &length);
if (rc == 0)
{
/********************************/
/* Print out the asynchronously */
/* received error. */
/********************************/
errno = temp;
perror("SO_ERROR was");
}
close(sd);
close(sd2);
exit(-1);
}

/* Close the connection to the client and */
/* close the server's listening socket. */
close(sd2);
close(sd);
free(buflen);
exit(0);
}

例程如下： client.c
/***********************************************/
/* TCP/IP面向连接客户端程序 1998.9 IBM */
/* Client Connection-Oriented Protocol */
/* Header files needed to use the sockets API. */
/* File contains Macro, Data Type and */
/* Structure definitions along with Function */
/* prototypes. */
/***********************************************/
/* in qcle/h file */
#include <stdio.h>;
#include <stdlib.h>;
#include <string.h>;

/* in qsysinc library */
#include <sys/types.h>;
#include <sys/socket.h>;
#include <netinet/in.h>;
#include <arpa/inet.h>;
#include <netdb.h>;
#include <unistd.h>;
#include <errno.h>;

/* BufferLength is 250 bytes */
#define BufferLength 250

/* Host name of server system */
#define SERVER "CLIUNIX"

/* Server's port number */
#define SERVPORT 3005

/* Pass in 1 parameter which is either the */
/* address or host name of the server or */
/* set the server name in the #define */
/* SERVER. */
void main(int argc, char *argv[])
{
/****************************************/
/* Variable and structure definitions. */
/****************************************/
int sd, rc, length = sizeof(int);
struct sockaddr_in serveraddr;
char buffer[BufferLength];
char server[255];
char temp;
int totalcnt = 0;
struct hostent *hostp;

/* will send 250 bytes of 'a' */
memset(buffer, 'a', 250);

/* get a socket descriptor */
if ((sd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("socket() failed");
exit(-1);
}

if (argc >; 1)
strcpy(server, argv[1]);
else
strcpy(server, SERVER);

memset(&serveraddr, 0x00, sizeof(struct sockaddr_in));
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(SERVPORT);
if ((serveraddr.sin_addr.s_addr = inet_addr(server))
== (unsigned long)INADDR_NONE)
{
/* get host address */
hostp = gethostbyname(server);
if (hostp == (struct hostent *)NULL)
{
printf("HOST NOT FOUND -->; ");
/* h_errno is usually defined */
/* in netdb.h
printf("h_errno = %d\n",h_errno);
*/
close(sd);
exit(-1);
}
memcpy(&serveraddr.sin_addr,
hostp->;h_addr,
sizeof(serveraddr.sin_addr));
}

/* Connect() to server. */
if ((rc = connect(sd,
(struct sockaddr *)&serveraddr,
sizeof(serveraddr))) < 0)
{
perror("connect() failed");
close(sd);
exit(-1);
}

/* Write() 250 'a's to the server. */
rc = write(sd, buffer, sizeof(buffer));
if (rc < 0)
{
perror("write() failed");
rc = getsockopt(sd, SOL_SOCKET, SO_ERROR,&temp,&length);
if (rc == 0)
{
/* Print out the asynchronously */
/* received error. */
errno = temp;
perror("SO_ERROR was");
}
close(sd);
exit(-1);
}

totalcnt = 0;
while(totalcnt < BufferLength)
{
/* Read data from the server. */
rc = read(sd, buffer, BufferLength-totalcnt);
if (rc < 0)
{
perror("read() failed");
close(sd);
exit(-1);
}
else if (rc == 0)
{
printf("partner program has issued a close()");
close(sd);
exit(-1);
}
else
totalcnt += rc;
}

/* Close socket descriptor from client side. */
close(sd);
exit(0);
}

wengzuhong

太好了

谢谢tomcats前辈，我收下了。

wengzuhong

最近偶公司安排我接手原来在as400上开发的程序，用到 ile c、java、RPG等，我的脑袋都快暴了，咳。。。

tomcats前辈，你有ile c语言教材吗？？

下载我手头上只有《IBM AS400e技术与应用》一本书。我都不知道从哪儿入手了？？

公司委派的活，不能不干啊，郁闷好几天了。。。