【计算机网络】UDP协议编写群聊天室----附代码

UDP构建服务器 x

预备知识

认识UDP协议

此处我们也是对UDP(User Datagram Protocol 用户数据报协议)有一个直观的认识; 后面再详细讨论.

  • 传输层协议
  • 无连接
  • 不可靠传输
  • 面向数据报
网络字节序

我们已经知道,内存中的多字节数据相对于内存地址有大端和小端之分, 磁盘文件中的多字节数据相对于文件中的偏
移地址也有大端小端之分, 网络数据流同样有大端小端之分. 那么如何定义网络数据流的地址呢?

  • 发送主机通常将发送缓冲区中的数据按内存地址从低到高的顺序发出;
  • 接收主机把从网络上接到的字节依次保存在接收缓冲区中,也是按内存地址从低到高的顺序保存;
  • 因此,网络数据流的地址应这样规定:先发出的数据是低地址,后发出的数据是高地址.
  • TCP/IP协议规定,网络数据流应采用大端字节序,即低地址高字节.
  • 不管这台主机是大端机还是小端机, 都会按照这个TCP/IP规定的网络字节序来发送/接收数据;
  • 如果当前发送主机是小端, 就需要先将数据转成大端; 否则就忽略, 直接发送即可;
   #include <arpa/inet.h>uint32_t htonl(uint32_t hostlong);uint16_t htons(uint16_t hostshort);uint32_t ntohl(uint32_t netlong);uint16_t ntohs(uint16_t netshort);
  • 这些函数名很好记,h表示host(本地),n表示network(网络),l表示32位长整数,s表示16位短整数。
  • 例如htonl表示将32位的长整数从主机字节序转换为网络字节序,例如将IP地址转换后准备发送。
  • 如果主机是小端字节序,这些函数将参数做相应的大小端转换然后返回;
  • 如果主机是大端字节序,这些 函数不做转换,将参数原封不动地返回 。
socket编程接口

``// 创建 socket 文件描述符 (TCP/UDP, 客户端 + 服务器) int socket(int domain, int type, int protocol);`

// 绑定端口号 (TCP/UDP, 服务器)
int bind(int socket, const struct sockaddr *address,socklen_t address_len);*

// 开始监听socket (TCP, 服务器)
int listen(int socket, int backlog);

// 接收请求 (TCP, 服务器)
int accept(int socket, struct sockaddr* address,socklen_t* address_len);

// 建立连接 (TCP, 客户端)
int connect(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

sockaddr结构

  • Pv4和IPv6的地址格式定义在netinet/in.h中,IPv4地址用sockaddr_in结构体表示,包括16位地址类型, 16位端口号和32位IP地址.1

  • IPv4、 IPv6地址类型分别定义为常数AF_INET、 AF_INET6. 这样,只要取得某种sockaddr结构体的首地址,不需要知道具体是哪种类型的sockaddr结构体,就可以根据地址类型字段确定结构体中的内容.

  • socket API可以都用struct sockaddr *类型表示, 在使用的时候需要强制转化成sockaddr_in; 这样的好处是程序的通用性, 可以接收IPv4, IPv6, 以及UNIX Domain Socket各种类型的sockaddr结构体指针做为参数;

    有sockaddr 结构，sockaddr_in 结构, sockaddr_un 结构

sockaddr_in 结构 用于网络中通讯。

sockaddr_un 结构 用于本地进程间的通信。

我们应该要知道的是，sockaddr 结构，sockaddr_in 结构, sockaddr_un 结构，构成了多态

sockaddr 结构是基类，sockaddr_in 结构, sockaddr_un 结构是衍生类。

我们现在只需要了解sockaddr_in 结构。

在这里插入图片描述

构建服务器

初始化服务器

1 .创建socket接口，打开网络文件

2 .给服务器指明IP 和 PORT

3 .bind 将 sockaddr 套接字字段和 网络文件描述符 进行绑定

​

代码：

void Init(){//1. 创建socket接口，打开网络文件_sock=socket(AF_INET,SOCK_DGRAM,0);if(_sock==-1){std::cerr<<"socket error"<<strerror(errno)<<std::endl;exit(SOCKET_ERR);}std::cout<<"creat socket success:"<<_sock<<std::endl;//2.给服务器指明IP 和 PORTstruct sockaddr_in local;memset(&local,0,sizeof(local));local.sin_family=AF_INET;//端口号和IP地址都需要通过网络发送给目标，所以需要转换成网络序列local.sin_port=htons(_port);//字符串风格的IP需要转换成4字节int   ，1.1.1.1 -》》intlocal.sin_addr.s_addr=INADDR_ANY;//char* 类型的 c_str();//此时的 local 还只是一个临时变量// bind 将 addr套接字字段和 网络文件描述符 进行绑定if(bind(_sock,(sockaddr*)&local,sizeof(local))==-1){std::cerr<<"bind error"<<strerror(errno)<<std::endl;exit(BIND_ERR);}std::cout<<"bind success"<<std::endl;}

到这里，我们服务器的初始化就算成功了，接下来就是启动服务器了.

启动服务器

我们需要接收来自客户端的消息，并将消息进行处理后返回给客户端。

这就意味着，服务器需要有最基础的两项功能，

接收网络消息，并在网络上发送消息

  • 定义一个缓冲区，里面用来存储接收的消息
  • 我们同时也需要知道是谁给我发送的消息，定义一个sockaddr_in 结构，用于保存客户的IP和PORT
  • 最后，将消息返回给客户端

代码：

 void Start(){char buffer[1024];while(true){struct sockaddr_in client;socklen_t len=sizeof(client);//client是一个接收型参数，存储了给服务器发送消息的客户端的IP+端口号int n=recvfrom(_sock,buffer,sizeof(buffer)-1,0,(sockaddr*)&client,&len);if(n>0) buffer[n]='\0';else continue;std::string clientIp=inet_ntoa(client.sin_addr);int clientport=ntohs(client.sin_port);std::cout<<clientIp<<'-'<<clientport<<" "<<"client echo#"<<buffer<<std::endl;sendto(_sock,buffer,strlen(buffer),0,(sockaddr*)&client,len);}}

整个服务端的简易编写就此完成：

代码：

udp_server.hpp

#pragma once 
#include<sys/socket.h>
#include<sys/types.h>
#include<iostream>
#include<cstring>
#include<errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include"err.hpp"class UdpServer{
public:public:static const u_int16_t DEFAULT_PORT=8080;UdpServer(uint16_t port=DEFAULT_PORT):_port(port){std::cout<<"PORT:"<<_port<<std::endl;}void Init(){//1. 创建socket接口，打开网络文件_sock=socket(AF_INET,SOCK_DGRAM,0);if(_sock==-1){std::cerr<<"socket error"<<strerror(errno)<<std::endl;exit(SOCKET_ERR);}std::cout<<"creat socket success:"<<_sock<<std::endl;//2.给服务器指明IP 和 PORTstruct sockaddr_in local;memset(&local,0,sizeof(local));local.sin_family=AF_INET;//端口号和IP地址都需要通过网络发送给目标，所以需要转换成网络序列local.sin_port=htons(_port);//字符串风格的IP需要转换成4字节int   ，1.1.1.1 -》》intlocal.sin_addr.s_addr=INADDR_ANY;//char* 类型的 c_str();//此时的 local 还只是一个临时变量// bind 将 addr套接字字段和 网络文件描述符 进行绑定if(bind(_sock,(sockaddr*)&local,sizeof(local))==-1){std::cerr<<"bind error"<<strerror(errno)<<std::endl;exit(BIND_ERR);}std::cout<<"bind success"<<std::endl;}void Start(){char buffer[1024];while(true){struct sockaddr_in client;socklen_t len=sizeof(client);//client是一个接收型参数，存储了给服务器发送消息的客户端的IP+端口号int n=recvfrom(_sock,buffer,sizeof(buffer)-1,0,(sockaddr*)&client,&len);if(n>0) buffer[n]='\0';else continue;std::string clientIp=inet_ntoa(client.sin_addr);int clientport=ntohs(client.sin_port);std::cout<<clientIp<<'-'<<clientport<<" "<<"client echo#"<<buffer<<std::endl;sendto(_sock,buffer,strlen(buffer),0,(sockaddr*)&client,len);}}private:int _sock;uint16_t _port;//std::string _ip;//  云服务器，或者一款服务器，一般不要指明某一个确定的IP, 让我们的udpserver在启动的时候，bind本主机上的任意IP
};

udp_server.cc

#include"udp_server.hpp"
#include<iostream>
#include<memory>using namespace std;static void usage(string prc)
{cout<<"Usage\n\t"<<prc<<"port\n"<<endl;
}int main(int argc,char* argv[])
{if(argc!=2){usage(argv[0]);exit(USAGE_ERR);}uint16_t port=atoi(argv[1]);unique_ptr<UdpServer> us(new UdpServer(port));us->Init();us->Start();return 0;
}
客户端简易实现

接下来我们进行客户端的编写，客户端的编写基本按照服务端的端口来进行

现阶段也是只需要向服务端发送消息，接收服务端的消息这两种功能

流程：

  • 创建套接字
  • 我们要向客户端发送消息，需要知道其IP和PORT，所以需要一个sockaddr_in结构，填充的是服务端的信息
  • 然后就是发送消息和接收消息

但是客户端的编写有一些需要注意的地方

1.服务端的端口号和IP地址都sh是需要我们自己绑定的，那么客户端需要吗？
答：客户端也是需要绑定的，但是不需要我们自己手动绑定，而是OS帮我们进行操作。
原因：client的port要随机让OS分配防止client出现启动冲突（例如：我们的手机终端上有很多的软件（客户端），如果自己bind，会可能导致某些服务的端口号被占用，无法启动）

2.服务端为什么需要自己绑定？
原因：
1. server的端口不能随意改变，众所周知且不能随意改变的
2. 同一家公司的port号需要统一规范化

代码：
udp_client.cc

#include<sys/socket.h>
#include<sys/types.h>
#include<iostream>
#include<cstring>
#include<errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include"err.hpp"
using namespace std;//127.0.0.1（本地回环） 表示的是当前主机,用于进行本地通讯或者测试
static void Usage(string prc)
{cout<<"Usage\t\n"<<prc<<" serverip serverport\n"<<endl;
}int main(int argc,char* argv[])//./server 目标IP 目标PORT
{if(argc!=3){Usage(argv[0]);exit(USAGE_ERR);}string serverip=argv[1];uint16_t serverport=atoi(argv[2]);int sock=socket(AF_INET,SOCK_DGRAM,0);if(sock<0){cerr<<"socket fail"<<strerror(errno)<<endl;exit(SOCKET_ERR);}struct sockaddr_in server;//目标服务器的IP+PORTmemset(&server,0,sizeof(server));server.sin_family=AF_INET;server.sin_port=htons(serverport);server.sin_addr.s_addr=inet_addr(serverip.c_str());while(true){char buffer[1024];cout<<"请输入#";cin>>buffer;//1. client 这里要不要bind呢？要的！socket通信的本质[clientip:clientport, serverip:serverport]// 2.client不需要自己bind，也不要自己bind，操作系统自动给我们进行bind -- 为什么？client的port要随机让OS分配防止client出现启动冲突（我们的手机终端上有很多的软件（客户端），如果自己bind，会可能导致某些服务的端口号被占用，无法启动）// 3.server 为什么要自己bind？1. server的端口不能随意改变，众所周知且不能随意改变的 2. 同一家公司的port号需要统一规范化sendto(sock,buffer,strlen(buffer),0,(sockaddr*)&server,sizeof(server));char Rebuffer[1024];sockaddr_in tmp;socklen_t len=sizeof(tmp);int n=recvfrom(sock,Rebuffer,sizeof(Rebuffer)-1,0,(sockaddr*)&tmp,&len);if(n>0) Rebuffer[n]='\0';std::cout<<serverip<<'-'<<serverport<<" "<<"server echo#"<<Rebuffer<<std::endl;}return 0;
}

好需要对错误码进行处理：
err.hpp

#pragma onceenum ERR{SOCKET_ERR=1,BIND_ERR,USAGE_ERR
};

在服务器中，我们实现了一个简单的echo型服务器，就不对消息进行处理，只是进行将消息简单的返回。

实现效果
在这里插入图片描述

构建一个群聊系统

在之前建设的服务器基础上，进行加工处理，便可以实现一个简易的群聊功能
我们可以这么理解群聊：

就是你把自己的消息发送给服务器，服务器在转发给每一个在群聊中的人

所以我们需要做如下改动：

  1. 需要一个储存客户消息的容器，把连接过来的客户都sockaddr_in结构保存
  2. 还需要一个缓冲区，保存发送过来的消息
  3. 同时需要注意的是，不同的客户来对同一个缓冲区发送消息，会有多线程并发的问题，需要加锁
  4. 服务器也需要进行多线程化，因为单一进程会阻塞在接收或者发送消息上

组件：
RingQueue.hpp

#pragma once#include<pthread.h>
#include<semaphore.h>
#include<vector>const int DEFAULT_CAP=10; 
template<class T>
class RingQueue{
public:RingQueue(int num=DEFAULT_CAP):_cap(num),_rq(num),_consume_step(0),_produce_step(0){sem_init(&_consume_sem,0,0);sem_init(&_produce_sem,0,_cap);}~RingQueue(){sem_destroy(&_consume_sem);sem_destroy(&_produce_sem);}void lock(pthread_mutex_t& m){pthread_mutex_lock(&m);}void unlock(pthread_mutex_t& m){pthread_mutex_unlock(&m);}void P(sem_t& s){sem_wait(&s);}void V(sem_t& s){sem_post(&s);}void push(const T& in){P(_produce_sem);lock(_produce_mutex);_rq[_produce_step++]=in;_produce_step%=_cap;unlock(_produce_mutex);V(_consume_sem);}void pop(T* out){P(_consume_sem);lock(_consume_mutex);*out=_rq[_consume_step++];_consume_step%=_cap;unlock(_consume_mutex);V(_produce_sem);}private:std::vector<T> _rq;int _cap;//消费者和生产者之间的同步关系通过信号量进行调节sem_t _consume_sem;sem_t _produce_sem;//当多线程运行时，生产者和生产者，消费锁者和消费者之间的互斥关系需要通过锁来维持pthread_mutex_t _consume_mutex;pthread_mutex_t _produce_mutex;int _consume_step;int _produce_step;
};

Thread.hpp

#pragma once#include <pthread.h>
#include <iostream>
#include <string>
#include <string.h>
#include <functional>using namespace std;string to_hex(uint64_t n)
{char arr[32];snprintf(arr, sizeof(arr), "0x%x", n);return arr;
}
class Thread
{
public:// typedef void(*func_t)();using func_t = std::function<void()>;typedef enum{NEW = 0,RUNNING,EXISTED} ThreadStatus;Thread(int num, func_t func) : _tid(0), _func(func){char name[108];snprintf(name, sizeof(name), "thread-%d", num);_name = name;_status = NEW;}static void *runHelper(void *args){Thread *ts = (Thread *)args;ts->_func();return nullptr;}void run(){int n = pthread_create(&_tid, nullptr, runHelper, this);if (n != 0){exit(1);}_status = RUNNING;}int get_status(){return _status;}void join(){int n = pthread_join(_tid, nullptr);if (n != 0)exit(2);cout << _name << " "<< "has joined" << endl;_status = EXISTED;}const string &get_name(){return _name;}string get_id(){return to_hex(_tid);}// pthread_t get_id()// {//     return _tid;// }~Thread(){}private:pthread_t _tid;string _name;ThreadStatus _status;func_t _func;// void* _args;//函数调用时需要传的参数
};

err.hpp

#pragma onceenum ERR{SOCKET_ERR=1,BIND_ERR,USAGE_ERR
};

代码：
udp_server.hpp

#pragma once
#include <sys/socket.h>
#include <sys/types.h>
#include <iostream>
#include <cstring>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <functional>
#include <unordered_map>
#include <pthread.h>
#include "RingQueue.hpp"
#include "LockGuard.hpp"
#include "Thread.hpp"
#include "err.hpp"using func_t = std::function<std::string(std::string)>;class UdpServer
{
public:
public:static const u_int16_t DEFAULT_PORT = 8080;UdpServer(uint16_t port = DEFAULT_PORT) : _port(port){std::cout << "PORT:" << _port << std::endl;pthread_mutex_init(&_lock, nullptr);// p=new Thread(1,);p = new Thread(1, std::bind(&UdpServer::Receive, this));c = new Thread(1, std::bind(&UdpServer::send, this));}void Start(){// 1. 创建socket接口，打开网络文件_sock = socket(AF_INET, SOCK_DGRAM, 0);if (_sock == -1){std::cerr << "socket error" << strerror(errno) << std::endl;exit(SOCKET_ERR);}std::cout << "creat socket success:" << _sock << std::endl;// 2.给服务器指明IP 和 PORTstruct sockaddr_in local;memset(&local, 0, sizeof(local));local.sin_family = AF_INET;// 端口号和IP地址都需要通过网络发送给目标，所以需要转换成网络序列local.sin_port = htons(_port);// 字符串风格的IP需要转换成4字节int   ，1.1.1.1 -》》intlocal.sin_addr.s_addr = INADDR_ANY; // char* 类型的 c_str();// 此时的 local 还只是一个临时变量//  bind 将 addr套接字字段和 网络文件描述符 进行绑定if (bind(_sock, (sockaddr *)&local, sizeof(local)) == -1){std::cerr << "bind error" << strerror(errno) << std::endl;exit(BIND_ERR);}std::cout << "bind success" << std::endl;p->run();c->run();}void Add_user(std::string ip, int port, struct sockaddr_in user){std::string name = ip + " + " + to_string(port);LockGuard lockguard(&_lock);_online[name] = user;}void Receive(){char buffer[1024];while (true){struct sockaddr_in client;socklen_t len = sizeof(client); // client是一个接收型参数，存储了给服务器发送消息的客户端的IP+端口号int n = recvfrom(_sock, buffer, sizeof(buffer) - 1, 0, (sockaddr *)&client, &len);if (n > 0)buffer[n] = '\0';elsecontinue;std::string clientIp = inet_ntoa(client.sin_addr);int clientport = ntohs(client.sin_port);Add_user(clientIp, clientport, client);_rq.push(buffer);std::cout << clientIp << '-' << clientport << " "<< "client echo#" << buffer << std::endl;}}void send(){while (true){std::string message;_rq.pop(&message);LockGuard lockguard(&_lock);//访问临界资源，需要锁for (auto &user : _online){sendto(_sock, message.c_str(), strlen(message.c_str()), 0, (sockaddr *)&user.second, sizeof(user.second));}}}~UdpServer(){pthread_mutex_destroy(&_lock);p->join();c->join();}private:int _sock;uint16_t _port;func_t _server;std::unordered_map<std::string, sockaddr_in> _online;RingQueue<std::string> _rq;pthread_mutex_t _lock;Thread *p;Thread *c;// std::string _ip;//  云服务器，或者一款服务器，一般不要指明某一个确定的IP, 让我们的udpserver在启动的时候，bind本主机上的任意IP
};

udp_server.cc

#include "udp_server.hpp"
#include <iostream>
#include <memory>using namespace std;static void usage(string prc)
{cout << "Usage\n\t" << prc << "port\n"<< endl;
}bool isPass(const string &command)
{bool pass = true;auto pos = command.find("rm");if (pos != std::string::npos)pass = false;pos = command.find("mv");if (pos != std::string::npos)pass = false;pos = command.find("while");if (pos != std::string::npos)pass = false;pos = command.find("kill");if (pos != std::string::npos)pass = false;return pass;
}
string excuteCommand(const string &s)
{// 可能有些人会传递一些比较恶劣的代码，如rm ，所以我们需要进行安全检查if (!isPass(s))return "you are a bad man!";FILE *fp = popen((s.c_str()), "r");if (fp == NULL)return "None";// 获取结果string result;char line[2048];while (fgets(line, sizeof(line), fp) != NULL){result += line;}pclose(fp);return result;
}int main(int argc, char *argv[])
{if (argc != 2){usage(argv[0]);exit(USAGE_ERR);}uint16_t port = atoi(argv[1]);// unique_ptr<UdpServer> us(new UdpServer(excuteCommand,port));unique_ptr<UdpServer> us(new UdpServer(port));us->Start();return 0;
}

udp_client.cc

#include <iostream>
#include <bits/stdc++.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <string>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <functional>
#include "Thread.hpp"
#include "err.hpp"
#include <cstring>using namespace std;// 127.0.0.1（本地回环） 表示的是当前主机,用于进行本地通讯或者测试
static void Usage(string prc)
{cout << "Usage\t\n"<< prc << " serverip serverport\n"<< endl;
}void *recver(void *args)
{int sock = *(static_cast<int *>(args));while (true){// 接受char buffer[2048];struct sockaddr_in temp;socklen_t len = sizeof(temp);int n = recvfrom(sock, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)&temp, &len);if (n > 0){buffer[n] = 0;std::cout << buffer << std::endl; // 1}}
}int main(int argc, char *argv[]) //./server 目标IP 目标PORT
{if (argc != 3){Usage(argv[0]);exit(USAGE_ERR);}string serverip = argv[1];uint16_t serverport = atoi(argv[2]);int sock = socket(AF_INET, SOCK_DGRAM, 0);if (sock < 0){cerr << "socket fail" << strerror(errno) << endl;exit(SOCKET_ERR);}struct sockaddr_in server; // 目标服务器的IP+PORTmemset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(serverport);server.sin_addr.s_addr = inet_addr(serverip.c_str());pthread_t tid;pthread_create(&tid, nullptr, recver, &sock);while (true){char buffer[1024];cout << "请输入#";// cin>>buffer;cin.getline(buffer, 1024);// 1. client 这里要不要bind呢？要的！socket通信的本质[clientip:clientport, serverip:serverport]// 2.client不需要自己bind，也不要自己bind，操作系统自动给我们进行bind -- 为什么？client的port要随机让OS分配防止client出现启动冲突（我们的手机终端上有很多的软件（客户端），如果自己bind，会可能导致某些服务的端口号被占用，无法启动）// 3.server 为什么要自己bind？1. server的端口不能随意改变，众所周知且不能随意改变的 2. 同一家公司的port号需要统一规范化sendto(sock, buffer, strlen(buffer), 0, (sockaddr *)&server, sizeof(server));}return 0;
}

展示效果：

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/100135.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

扬尘监测：智能化解决方案让生活更美好

扬尘监测：智能化解决方案让生活更美好

随着工业化和城市化的快速发展&#xff0c;扬尘污染问题越来越受到人们的关注。扬尘不仅影响城市环境&#xff0c;还会对人们的健康造成威胁。为了解决这一问题&#xff0c;扬尘监测成为了一个重要的手段。本文将介绍扬尘监测的现状、重要性以及智能化解决方案&#xff0c;帮助…
阅读更多...
Python库学习(九):Numpy[续篇三]:数组运算

Python库学习(九):Numpy[续篇三]:数组运算

NumPy是用于数值计算的强大工具&#xff0c;提供了许多数组运算和数学函数&#xff0c;允许你执行各种操作&#xff0c;包括基本运算、统计计算、线性代数、元素级操作等 1.基本运算 1.1 四则运算 NumPy数组支持基本的四则运算&#xff08;加法、减法、乘法和除法&#xff09;…
阅读更多...
Flink学习笔记（一）：Flink重要概念和原理

Flink学习笔记（一）：Flink重要概念和原理

文章目录 1、Flink 介绍2、Flink 概述3、Flink 组件介绍3.1、Deploy 物理部署层3.2、Runtime 核心层3.3、API&Libraries 层3.4、扩展库 4、Flink 四大基石4.1、Checkpoint4.2、State4.3、Time4.4、Window 5、Flink 的应用场景5.1、Event-driven Applications【事件驱动】5.…
阅读更多...
初识 C语言文件操作

初识 C语言文件操作

目录 前言&#xff1a; 为什么我们要使用文件&#xff1f; 什么是文件&#xff1f; 程序文件&#xff1a; 数据文件&#xff1a; 文件名&#xff1a; 文件的打开和关闭 文件指针&#xff1a; 流程&#xff1a; 文件路径&#xff1a; 文件的顺序读写&#xff1a; …
阅读更多...
【Java 进阶篇】CSS语法格式详解

【Java 进阶篇】CSS语法格式详解

在前端开发中&#xff0c;CSS&#xff08;层叠样式表&#xff09;用于控制网页的样式和布局。了解CSS的语法格式是学习如何设计和美化网页的关键。本文将深入解释CSS的语法格式&#xff0c;包括选择器、属性和值等基本概念&#xff0c;同时提供示例代码以帮助初学者更好地理解。…
阅读更多...
首批成员单位 | 聚铭网络受邀加入中国人工智能产业发展联盟数据委员会

首批成员单位 | 聚铭网络受邀加入中国人工智能产业发展联盟数据委员会

近日&#xff0c;中国人工智能产业发展联盟(简称AIIA&#xff09;成立“数据委员会”&#xff0c;**聚铭网络受邀加入&#xff0c;成为首批成员单位&#xff0c;**与其他成员单位协同推动人工智能产业发展。 中国人工智能产业发展联盟是在国家发展和改革委员会、科学技术部、工…
阅读更多...
Python Opencv实践 - 车辆识别（1）读取视频，移除背景，做预处理

Python Opencv实践 - 车辆识别（1）读取视频，移除背景，做预处理

示例中的图像的腐蚀、膨胀和闭运算等需要根据具体视频进行实验得到最佳效果。代码仅供参考。 import cv2 as cv import numpy as np#读取视频文件 video cv.VideoCapture("../../SampleVideos/Traffic.mp4") FPS 10 DELAY int(1000 / FPS) kernel cv.getStructu…
阅读更多...
VSCode Intellij IDEA CE 数据库连接

VSCode Intellij IDEA CE 数据库连接

VSCode & Intellij IDEA CE 数据库连接 大概记一下现在正在用的几个工具/插件 VSCode VSCode 里面的工具我下载了很多&#xff0c;如果只是链接 MySQL 的话&#xff0c;可能用 Jun Han 这位大佬的 MySQL 就好了&#xff1a; 使用这个插件直接打开 .sql 文件单击运行就能…
阅读更多...
制作电商页面（Html）

制作电商页面（Html）

任务 制作一个电商页面&#xff0c;要求所卖物品清晰&#xff0c;页面色调清晰&#xff0c;要有主页和详情页。 网站所买物品&#xff1a;书籍 色调&#xff1a;#FF2400 橙红色 代码 主页HTML代码&#xff1a; <html><head><meta charset"utf-8"…
阅读更多...
CentOS Stream9 安装远程桌面服务 Xrdp

CentOS Stream9 安装远程桌面服务 Xrdp

1. 安装 XRDP 若服务器本身没有桌面则首先需要安装本地桌面&#xff1a; yum -y groups install "GNOME Desktop" startx配置源&#xff1a; dnf install epel-release安装 xrdp dnf install xrdp 2. 配置 Xrdp Xrdp 配置文件位于 /etc/xrdp 目录中。对于常规 X…
阅读更多...
NoSQL数据库（林子雨慕课课程）

NoSQL数据库（林子雨慕课课程）

文章目录 5.1 NoSQL数据库5.2 NoSQL和关系数据库的比较5.3 四大类型NoSQL数据库5.3.1 键值数据库和列族数据库5.3.2 文档数据库、图数据库、以及不同数据库比较分析 5.4 NoSQL数据库的理论基石CAP理论&#xff1a;BASE理论&#xff1a;Eventual consistency&#xff08;最终一致…
阅读更多...
Java架构师高并发架构设计

Java架构师高并发架构设计

目录 1 导学2 什么是高并发问题3 高并发处理之道4 akf扩展立方体5 细化理念应对高并发5 总结1 导学 本章的主要内容是大型系统架构设计的难点之一，高并发架构设计相关的知识落到实际项目上，就是订单系统的高并发架构设计。我们首先会去学习到底何为高并发问题，先把问题搞清楚…
阅读更多...
多线程(线程互斥)

多线程(线程互斥)

抢票代码编写 学习了前面有关线程库的操作后&#xff0c;我们就可以模拟抢票的过程 假设我们创建四个线程&#xff0c;分别代表我们的用户 然后设定总票数为1000张&#xff0c;四个线程分别将进行循环抢票操作&#xff0c;其实就是循环对票数进行打印&#xff0c;并进行对应的…
阅读更多...
强化学习问题（二）--- ERROR: Failed building wheel for box2d-py

强化学习问题（二）--- ERROR: Failed building wheel for box2d-py

错误&#xff1a;Could not build wheels for box2d-py, which is required to install pyproject.toml-based projects pyproject.toml-based projects&#xff1a;意思是缺少依赖包&#xff0c;对于box2d就是缺少swig 注意&#xff1a;安装python对应的swig版本 解决1&…
阅读更多...
Linux线程安全

Linux线程安全

线程安全 Linux线程互斥进程线程间的互斥相关背景概念互斥量mutex互斥量的接口互斥量实现原理探究 可重入VS线程安全概念常见的线程不安全的情况常见的线程安全的情况常见的不可重入的情况常见的可重入的情况可重入与线程安全联系可重入与线程安全区别 常见锁概念死锁死锁的四个…
阅读更多...
Unity 捕鱼游戏开发教程与源码

Unity 捕鱼游戏开发教程与源码

效果图展示 项目分析 主要功能点&#xff1a; 鱼的移动路线 这里使用简单移动的方式&#xff1a;随机位置然后随机鱼直线或者每帧更新鱼的角度实现走圆形。枪随着鼠标或点击位置移动 这个用坐标转换参考代码 private void Update(){Vector3 mousePos; // 鼠标位置// RectTra…
阅读更多...
牛津大学海外学习：14天的知识与文化之旅

牛津大学海外学习：14天的知识与文化之旅

牛津——一个充满学术氛围与古老传统的城市&#xff0c;对于我这次14天的海外学习经验来说&#xff0c;这里每一个角落都隐藏着知识和历史的故事。作为中国的一名学生&#xff0c;能够在这里学习、生活&#xff0c;真是一次难得的机会。 我报名的是《人工智能》课程&#xff0…
阅读更多...
ElasticSearch 学习7 集成ik分词器

ElasticSearch 学习7 集成ik分词器

网上找了一大堆&#xff0c;很多都介绍的不详细&#xff0c;开始安装完一直报错找不到plugin-descriptor.properties&#xff0c;有些懵这个东西不应该带在里面吗&#xff0c;参考了一篇博客说新建一个这个&#xff0c;新建完可以启动&#xff0c;但是插入索引数据会报错找不到…
阅读更多...
Step2：Java内存区域与内存溢出异常

Step2：Java内存区域与内存溢出异常

文章目录 1.1 概述1. 2 运行时数据区域1. 3 HotSpot虚拟机对象探秘1. 4 作业：OutOfMemoryError异常体验1.1 概述 对于Java程序员来说，再虚拟机自动内存管理机制的帮助下，不再需要为每一个new操作去写配对的delete/free代码，不容易出现内存泄露和内存溢出的问题，看起来由虚…
阅读更多...
图的应用：关键路径 ← PPT

图的应用：关键路径 ← PPT

阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023