Socket编程是一种在计算机网络中进行通信的基础方式,它被广泛运用于网络应用程序的设计中。在Linux环境中,Socket编程是一种基本的网络编程方式,可以实现客户端与服务器之间的数据传输与通信。在本文中,我们将介绍Linux下的Socket编程,并分享一些简单的实例供读者参考。
一、Socket编程基础知识
1.1 Socket定义
Socket是一种通信方式,它是一种计算机网络数据传输协议的API。Socket是一组用于接收和发送数据的API,它可以在计算机网络上建立连接,进行网络通信。Socket是一种抽象层,它实际上是一个文件描述符,可以用于数据的输入和输出。
1.2 Socket类型
在Socket编程中,有两种主要的Socket类型:
– 流Socket(SOCK_STREAM):用于建立面向连接的TCP连接,数据传输具有可靠性和顺序性;
– 数据报Socket(SOCK_DGRAM):用于无连接的UDP通信,数据传输速度快但不可靠,消息之间没有顺序。
1.3 Socket编程基本流程
在使用Socket编程进行数据通信时,需要进行如下的基本流程:
– 服务器端创建Socket、绑定IP与端口、监听客户端连接;
– 客户端创建Socket、连接服务器;
– 服务器端接受客户端连接请求,生成新的Socket与客户端通信;
– 客户端和服务器端进行数据传输。
二、Linux下Socket编程实践
为了更好地理解Socket编程,下面我们介绍一个简单的实例,该实例演示了如何实现基本的客户端和服务器端之间的消息传输。
2.1 服务器端代码
下面是基本的服务器端代码:
“`
#include
#include
#include
#include
#include
#include
#define PORT 8000
#define MAX_CONN 10
int mn(int argc, char *argv[])
{
int server_fd, client_fd, len;
struct sockaddr_in server_addr, client_addr;
char buffer[1024];
// 创建Socket
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror(“Cannot create socket”);
exit(1);
}
// 绑定端口
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
perror(“Bind error”);
exit(1);
}
// 监听
if (listen(server_fd, MAX_CONN) == -1) {
perror(“Listen error”);
exit(1);
}
printf(“Server listening on port %d…\n”, PORT);
// 循环接受连接请求
while (1) {
len = sizeof(client_addr);
if ((client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &len)) == -1) {
perror(“Accept error”);
continue;
}
printf(“Connection established from client %s:%d\n”,
inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
// 与客户端进行通信
while (1) {
memset(buffer, 0, sizeof(buffer));
if (recv(client_fd, buffer, sizeof(buffer), 0)
perror(“Recv error”);
break;
}
printf(“Received message from client %s:%d: %s\n”,
inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), buffer);
if (strncmp(buffer, “exit”, 4) == 0)
break;
if (send(client_fd, buffer, strlen(buffer), 0) == -1) {
perror(“Send error”);
break;
}
}
close(client_fd);
printf(“Connection closed from client %s:%d\n”,
inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
}
close(server_fd);
return 0;
}
“`
在该代码中,我们首先创建了一个Socket,并绑定了IP地址和端口号。然后,我们开始监听客户端的连接请求。当有一个连接请求到来时,我们将生成一个新的Socket,并通过这个Socket与客户端进行通信。在与客户端进行通信时,我们可以通过recv()函数从客户端接收消息,也可以通过send()函数向客户端发送消息。
2.2 客户端代码
下面是基本的客户端代码:
“`
#include
#include
#include
#include
#include
#include
#define PORT 8000
int mn(int argc, char *argv[])
{
int client_fd, len;
struct sockaddr_in server_addr;
char buffer[1024];
// 创建Socket
if ((client_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror(“Cannot create socket”);
exit(1);
}
// 连接服务器
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr(argv[1]);
if (connect(client_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
perror(“Connect error”);
exit(1);
}
printf(“Connect to server %s:%d successfully.\n”, argv[1], PORT);
// 与服务器进行通信
while (1) {
printf(“Input message: “);
fgets(buffer, sizeof(buffer), stdin);
if (send(client_fd, buffer, strlen(buffer), 0) == -1) {
perror(“Send error”);
break;
}
if (strncmp(buffer, “exit”, 4) == 0)
break;
memset(buffer, 0, sizeof(buffer));
if (recv(client_fd, buffer, sizeof(buffer), 0)
perror(“Recv error”);
break;
}
printf(“Received message from server: %s”, buffer);
}
close(client_fd);
return 0;
}
“`
在该代码中,我们首先创建了一个Socket,并使用该Socket连接了服务器。在与服务器进行通信时,我们使用fgets()函数从标准输入读取用户的消息,并使用send()函数向服务器发送消息。同时,在接收服务器的回复时,我们通过recv()函数进行接收。
三、
相关问题拓展阅读:
1你就打开文件,然后一个字符一竖伍个字符的读文件,然后一个字符一个字符的接收,再一个字符一个迅纤凳字符写入文件就行了阿
2这个问题你问的有点模亩旅糊,服务器端的编程有很多方式,也不是要每来个连接就要创建一个进程的。
之一数桐个问题:
对,是那样的,用open打开文件,用read读取文件,在发送给对方,接收方接收到薯码坦后,写入文件就可以了。不过在这个过程中更好别用字符串函数,除非你很熟悉。
第二个问题
首先你得去搞清楚什么是线程,什么是进程,fork出来的叫进程,pthread_create出来的才叫线程。服务器有很多种模型(多进程,多线程,select,epoll模型,这个我的blog上有,famdestiny.cublog.cn),不一定要用多进程。
给你写了个代码,自己先看看:
注意,在自己的目录下创建模知一个叫pserverb的文件,程序会把这个文件复制成test文件。你可以自己根据需要改改
server:
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define SERV_PORT 5358
#define MAX_CONN 10
#define BUF_LEN 1024
void str_echo(FILE *fp, int sockfd){
ssize_t nread;
int file_fd;
char buf = {0};
file_fd = open(“test”, O_WRON | O_TRUNC | O_CREAT, 0755);
while(1) {
bzero(buf, BUF_LEN);
if((nread = read(sockfd, buf, BUF_LEN)) == -1) {
if(errno == EINTR) {
continue;
}
else {
printf(“readn error: %s\n”, strerror(errno));
continue;
}
}
else if (nread == 0) {
break;
}
else {
printf(“%s\n”, buf);
write(file_fd, buf, nread);
}
}
close(file_fd);
}
void sig_chld(int sig){
pid_t pid;
int state;
while((pid = waitpid(-1, &state, WNOHANG)) > 0){
printf(“child process %d exited.”, pid);
}
return;
}
int main(int argc, char **argv)
{
int listenfd, connfd;
socklen_t cliaddrlen;
pid_t childpid;
struct sockaddr_in servaddr, cliaddr;
if((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){
printf(“socket error: %s\n”, strerror(errno));
return 0;
}
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(SERV_PORT);
if(bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1){
printf(“bind error: %s\n”, strerror(errno));
return 0;
}
if(listen(listenfd, MAX_CONN) == -1){
printf(“listen error: %s\n”, strerror(errno));
return 0;
}
signal(SIGCHLD, sig_chld);
while(1){
cliaddrlen = sizeof(cliaddr);
if((connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddrlen)) == -1){
if(errno == EINTR){
continue;
}
else{
printf(“accept error: %s\n”, strerror(errno));
continue;
}
}
if((childpid = fork()) == 0){
close(listenfd);
str_echo(stdin, connfd);
exit(0);
}
else if(childpid > 0){
close(connfd);
}
else{
printf(“fork error!\n”);
continue;
}
}
}
client:
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define SERV_ADDR “127.0.0.1”
#define SERV_PORT 5358
#define BUF_LEN 1024
void str_cli(char *path, int sockfd)
{
char sendbuf = {0};
int fd, n;
if((fd = open(“./pserverb”, O_RDON)) == -1){
printf(“%s\n”, strerror(errno));
exit(0);
}
while((n = read(fd, sendbuf, BUF_LEN)) != 0) {
if(n
printf(“%s\n”, strerror(errno));
exit(0);
}
write(sockfd, sendbuf, n);
bzero(sendbuf, BUF_LEN);
}
close(fd);
return;
}
int main(int argc, char **argv)
{
int fd;
struct sockaddr_in servaddr;
fd = socket(AF_INET, SOCK_STREAM, 0);
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = inet_addr(SERV_ADDR);
servaddr.sin_port = htons(SERV_PORT);
if (connect(fd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
printf(“connect error: %s\n”, strerror(errno));
return 0;
}
str_cli(argv, fd);
return 0;
}
挖~
关于linux socket 编程实例的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。
创新互联成都网站建设公司提供专业的建站服务,为您量身定制,欢迎来电(028-86922220)为您打造专属于企业本身的网络品牌形象。
成都创新互联品牌官网提供专业的网站建设、设计、制作等服务,是一家以网站建设为主要业务的公司,在网站建设、设计和制作领域具有丰富的经验。
分享文章:Linux下Socket编程:简单实例分享(linuxsocket编程实例)
转载来源:http://www.shufengxianlan.com/qtweb/news27/321677.html
网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联