c 和 java 通过 socket 进行通信

爱被打了一巴掌 2022-08-02 00:23 175阅读 0赞

# [   ][Link 1] #

socket 端口占用 命令：

1. netstat -anpt

现在使用C 的server 端 和java 的client 端进行简单的通信。

server.c

/\*  
============================================================================  
Name : server.c  
Author : king  
Version :  
Copyright : Your copyright notice  
Description : Hello World in C, Ansi-style  
============================================================================  
\*/  
\#include <stdlib.h>  
\#include <pthread.h>  
\#include <sys/socket.h>  
\#include <sys/types.h>  
\#include <netinet/in.h>  
\#include <arpa/inet.h> /\* inet(3) functions \*/  
  
\#include <stdlib.h>  
\#include <errno.h>  
\#include <stdio.h>  
\#include <string.h>  
  
int handle(int point);  
  
int main(void) \{  
int sfd, ind;  
struct sockaddr\_in addr;  
struct sockaddr\_in clent;  
char resv\[1024\], sendbuf\[1024\];  
char buf\[1024\];  
char \* myaddr = "127.0.0.1";  
  
int ret; // 返回值设置  
socklen\_t lent;  
int pid;  
addr.sin\_family = AF\_INET; //IPv4 Internet protocols  
  
addr.sin\_port = htons(5050); //这里输入服务器端口号  
  
addr.sin\_addr.s\_addr = inet\_addr(myaddr);  
; //INADDR\_ANY表示本机IP  
  
//獲取socket描述符，IPV4asd  
printf("socket start \\n");  
sfd = socket(AF\_INET, SOCK\_STREAM, 0);  
  
if (sfd < 0) \{  
printf("socket error \\n");  
return -1;  
\}  
printf("bind start \\n");  
//将套接子与指定端口链接  
if (bind(sfd, (struct sockaddr \*) &addr, sizeof(struct sockaddr)) < 0) \{  
printf("bind error \\n");  
return -1;  
\}  
  
//监听套接子  
printf("listen start \\n");  
if (listen(sfd, 1024) < 0) \{  
printf("listen error \\n");  
return -1;  
\}  
  
for (;;) \{  
//接受来自客户端的信息  
printf("accept start \\n");  
memset(&clent, 0, sizeof(clent));  
lent = sizeof(clent);  
ind = accept(sfd, (struct sockaddr \*) &clent, &lent);  
if (ind < 0) \{  
printf("accept error %d \\n", ind);  
return -1;  
\}  
  
printf("infor \\n");  
printf("clent addr%s porit %d\\n",  
inet\_ntop(AF\_INET, &clent.sin\_addr, buf, sizeof(buf)),  
ntohs(clent.sin\_port));  
  
pid = fork();  
  
if (pid == 0) \{  
//子进程  
close(sfd);  
handle(ind);  
\} else if (pid < 0) \{  
//error  
close(ind);  
\} else \{  
//父进程  
\}  
\}  
  
return EXIT\_SUCCESS;  
  
\}  
  
int handle(int point) \{  
  
int retn;  
char buf\[1024\];  
  
for (;;) \{  
retn = read(point, buf, sizeof(buf));  
if (retn < 0) \{  
printf("read error \\n");  
close(point);  
break;  
\} else if (retn == 0) \{  
printf("client exit \\n");  
close(point);  
break;  
\}  
  
printf("client:%s\\n", buf);  
  
if (strcmp("exit", buf) == 0) \{  
printf("exit \\n");  
close(point);  
return 0;  
\}  
\}  
return 0;  
\}

client.c

package HA.Socket;  
  
import java.io.\*;  
import java.net.\*;  
  
public class SocketClient \{  
static Socket client;  
  
public SocketClient(String site, int port)\{  
try\{  
client = new Socket(site,port);  
System.out.println("Client is created! site:"+site+" port:"+port);  
\}catch (UnknownHostException e)\{  
e.printStackTrace();  
\}catch (IOException e)\{  
e.printStackTrace();  
\}  
\}  
  
public String sendMsg(String msg)\{  
try\{  
BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));  
PrintWriter out = new PrintWriter(client.getOutputStream());  
out.println(msg);  
out.flush();  
return in.readLine();  
\}catch(IOException e)\{  
e.printStackTrace();  
\}  
return "";  
\}  
public void closeSocket()\{  
try\{  
client.close();  
\}catch(IOException e)\{  
e.printStackTrace();  
\}  
\}  
\}

package HA.Socket;  
  
public class TestSocketClient \{  
  
public static void main(String\[\] args)\{  
  
SocketClient client = new SocketClient("127.0.0.1",5050);  
System.out.println(client.sendMsg("test1111111111"));  
client.closeSocket();  
\}  
\}

补充说明： 服务器端和客户端 都要使用相同的端口号。

[Link 1]: http://blog.csdn.net/jubincn/article/details/6146594