1.����˿ͻ���Դ��
2.Nacos服务端源码分析(四): 拉取服务信息
3.手撕Nacos源码剖析，服务服务建议收藏
4.AnkiDroid服务器和客户端的端客端客源码搭建过程
����˿ͻ���Դ��
源代码奉上，流程图。户端户端。源码源码。服务服务这个太简单了，端客端客暖暖小镇源码你自己看看。户端户端。源码源码。服务服务。端客端客。户端户端。源码源码。服务服务涨停强弱指标源码
//TCP
//服务器端程序
#include< stdio.h >
#include< stdlib.h >
#include< windows.h >
#include< winsock.h >
#include< string.h >
#pragma comment( lib,端客端客 "ws2_.lib" )
#define PORT
#define BACKLOG
#define TRUE 1
void main( void )
{
int iServerSock;
int iClientSock;
char *buf = "hello, world!\n";
struct sockaddr_in ServerAddr;
struct sockaddr_in ClientAddr;
int sin_size;
WSADATA WSAData;
if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )//初始化
{
printf( "initializationing error!\n" );
WSACleanup( );
exit( 0 );
}
if( ( iServerSock = socket( AF_INET, SOCK_STREAM, 0 ) ) == INVALID_SOCKET )
{
printf( "创建套接字失败!\n" );
WSACleanup( );
exit( 0 );
}
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons( PORT );//监视的端口号
ServerAddr.sin_addr.s_addr = INADDR_ANY;//本地IP
memset( & ( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );
if( bind( iServerSock, ( struct sockaddr * )&ServerAddr, sizeof( struct sockaddr ) ) == -1 )
{
printf( "bind调用失败!\n" );
WSACleanup( );
exit( 0 );
}
if( listen( iServerSock, BACKLOG ) == -1 )
{
printf( "listen调用失败!\n" );
WSACleanup( );
exit( 0 );
}
while( TRUE )
{
sin_size = sizeof( struct sockaddr_in );
iClientSock = accept( iServerSock, ( struct sockaddr * )&ClientAddr, &sin_size );
if( iClientSock == -1 )
{
printf( "accept调用失败!\n" );
WSACleanup( );
exit( 0 );
}
printf( "服务器连接到%s\n", inet_ntoa( ClientAddr.sin_addr ) );
if( send( iClientSock, buf, strlen( buf ), 0 ) == -1 )
{
printf( "send调用失败!" );
closesocket( iClientSock );
WSACleanup( );
exit( 0 );
}
}
}
/////客户端程序
#include< stdio.h >
#include< stdlib.h >
#include< windows.h >
#include< winsock.h >
#include< string.h >
#pragma comment( lib, "ws2_.lib" )
#define PORT
#define BACKLOG
#define TRUE 1
#define MAXDATASIZE
void main( void )
{
int iClientSock;
char buf[ MAXDATASIZE ];
struct sockaddr_in ServerAddr;
int numbytes;
// struct hostent *he;
WSADATA WSAData;
// int sin_size;
/* if( ( he = gethostbyname( "liuys" ) ) == NULL )
{
printf( "gethostbyname调用失败!" );
WSACleanup( );
exit( 0 );
}
*/
if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )//初始化
{
printf( "initializationing error!\n" );
WSACleanup( );
exit( 0 );
}
if( ( iClientSock = socket( AF_INET, SOCK_STREAM, 0 ) ) == INVALID_SOCKET )
{
printf( "创建套接字失败!\n" );
WSACleanup( );
exit( 0 );
}
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons( PORT );
// ServerAddr.sin_addr = *( ( struct in_addr * )he->h_addr );
ServerAddr.sin_addr.s_addr = inet_addr( "..2." );//记得换IP
memset( &( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );
if( connect( iClientSock, ( struct sockaddr * ) & ServerAddr, sizeof( struct sockaddr ) ) == -1 )
{
printf( "connect失败!" );
WSACleanup( );
exit( 0 );
}
numbytes = recv( iClientSock, buf, MAXDATASIZE, 0 );
if( numbytes == -1 )
{
printf( "recv失败!" );
WSACleanup( );
exit( 0 );
}
buf[ numbytes ] = '\0';
printf( "Received: %s", buf );
closesocket( iClientSock );
WSACleanup( );
}
/////UDP
//服务器
#include< stdio.h >
#include< string.h >
#include< winsock.h >
#include< windows.h >
#pragma comment( lib, "ws2_.lib" )
#define PORT
#define BACKLOG
#define TRUE 1
#define MAXDATASIZE
void main( void )
{
int iServerSock;
// int iClientSock;
int addr_len;
int numbytes;
char buf[ MAXDATASIZE ];
struct sockaddr_in ServerAddr;
struct sockaddr_in ClientAddr;
WSADATA WSAData;
if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )
{
printf( "initializationing error!\n" );
WSACleanup( );
exit( 0 );
}
iServerSock = socket( AF_INET, SOCK_DGRAM, 0 );
if( iServerSock == INVALID_SOCKET )
{
printf( "创建套接字失败!\n" );
WSACleanup( );
exit( 0 );
}
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons( PORT );//监视的端口号
ServerAddr.sin_addr.s_addr = INADDR_ANY;//本地IP
memset( & ( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );
if( bind( iServerSock, ( struct sockaddr * )&ServerAddr, sizeof( struct sockaddr ) ) == -1 )
{
printf( "bind调用失败!\n" );
WSACleanup( );
exit( 0 );
}
addr_len = sizeof( struct sockaddr );
numbytes = recvfrom( iServerSock, buf, MAXDATASIZE, 0, ( struct sockaddr * ) & ClientAddr, &addr_len );
if( numbytes == -1 )
{
printf( "recvfrom调用失败!\n" );
WSACleanup( );
exit( 0 );
}
printf( "got packet from %s\n", inet_ntoa( ClientAddr.sin_addr ) );
printf( "packet is %d bytes long\n", numbytes );
buf[ numbytes ] = '\0';
printf( "packet contains \"%s\"\n", buf );
closesocket( iServerSock );
WSACleanup( );
}
//客户端
#include< stdio.h >
#include< stdlib.h >
#include< windows.h >
#include< winsock.h >
#include< string.h >
#pragma comment( lib, "ws2_.lib" )
#define PORT
#define MAXDATASIZE
void main( void )
{
int iClientSock;
struct sockaddr_in ServerAddr;
int numbytes;
char buf[ MAXDATASIZE ] = { 0 };
WSADATA WSAData;
if( WSAStartup( MAKEWORD( 1, 1 ), &WSAData ) )
{
printf( "initializationing error!\n" );
WSACleanup( );
exit( 0 );
}
if( ( iClientSock = socket( AF_INET, SOCK_DGRAM, 0 ) ) == -1 )
{
printf( "创建套接字失败!\n" );
WSACleanup( );
exit( 0 );
}
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons( PORT );
ServerAddr.sin_addr.s_addr = inet_addr( "..2." );//记得换IP
memset( &( ServerAddr.sin_zero ), 0, sizeof( ServerAddr.sin_zero ) );
numbytes = sendto( iClientSock, buf, strlen( buf ), 0, ( struct sockaddr * ) & ServerAddr, sizeof( struct sockaddr ) );
if( numbytes == -1 )
{
printf( "sendto调用失败!\n" );
WSACleanup( );
exit( 0 );
}
printf( "sent %d bytes to %s\n", numbytes, inet_ntoa( ServerAddr.sin_addr ) );
closesocket( iClientSock );
WSACleanup( );
}
Nacos服务端源码分析(四): 拉取服务信息
本文深入解析Nacos服务端源码，特别关注服务信息的户端户端主动拉取机制。主动拉取服务信息的URL为：https://localhost:/nacos/v1/ns/instance/list。依据此URL，Nacos服务端会处理请求，具体操作如下： 首先，获取并校验参数，随后调用`getInstanceOperator().listInstance()`函数。 `getInstanceOperator().listInstance()`执行流程如下：通过`createIpPortClientIfAbsent()`确保client管理正常，若未存在则加入`clients`。
调用`clientOperationService.subscribeService()`发布事件`ClientOperationEvent.ClientSubscribeServiceEvent`，进行服务订阅。小白泽源码包
调用`ServiceUtil.selectInstancesWithHealthyProtection()`获取serviceInfo，包括实例列表。
分析各个方法的内部逻辑：`createIpPortClientIfAbsent()`：若`clientManager`中不存在指定`clientId`，则加入`clients`。
`clientOperationService.subscribeService()`：发布事件`ClientOperationEvent.ClientSubscribeServiceEvent`，涉及订阅操作，将服务作为key，保存在`subscriberIndexes`中。首次添加时，会触发事件`ServiceEvent.ServiceSubscribedEvent`，将服务信息推送至订阅客户端。
`ServiceUtil.selectInstancesWithHealthyProtection()`：整合相关信息，公益平台软件源码筛选健康的服务实例，最终返回。
总结以上分析，Nacos服务端主动拉取服务信息的过程涉及参数验证、事件发布、实例筛选等关键步骤。这一机制确保了服务信息的及时更新与准确传递。 下篇文章预告：探讨Nacos之Distro协议的理论基础。手撕Nacos源码剖析，建议收藏
Nacos源码剖析 深入学习Nacos，解析源码，重点关注以下两点： 源码环境搭建从官方项目克隆Nacos源码，屠龙定乾坤源码检出1.4.1版本，导入IDEA。
在本地MySQL中创建nacos-config数据库，执行resources/META-INF/nacos-db.sql脚本创建表。
修改console模块下的application.properties文件，配置相关参数。
启动console模块的启动类，非集群模式启动Nacos服务端。
访问本地Nacos服务：http://localhost:/nacos。
Nacos客户端功能 Nacos客户端集成在应用服务内，通过依赖引入实现服务注册、发现、下线及订阅功能。客户端核心功能包括服务注册、服务发现、服务下线与服务订阅。
客户端与服务端交互，主要聚焦服务注册、服务下线、服务发现与服务订阅。
服务注册注册服务时，客户端执行定时任务设置心跳监测，同时向服务端注册服务。
服务注册中，远程请求通过NacosRestTemplate封装，调用callServer()执行。
服务发现通过NamingService.getAllInstances()方法实现服务发现。
获取服务信息首先从缓存查找，若无数据，则向Nacos服务端请求更新。
服务下线服务下线操作简化，主要取消心跳检测与服务下线接口请求。
服务订阅客户端创建线程池，封装监听器，监听指定服务实例信息变化。
通过NamingService.subscribe()方法实现服务订阅，注册监听器，接收实例信息更新。
AnkiDroid服务器和客户端的源码搭建过程
在Ubuntu .系统中，我们首先需要安装Python 3.版本的环境。
接着，参考官方文档进行Anki客户端的安装依赖与运行。在遇到问题时，可以通过指定链接找到解决办法。
首先，下载并解压官方提供的pa_stable_v_.tgz文件，然后进入解压后的文件夹执行命令：$ ./configure，$ make，$ make install，以安装必要的依赖库。
对于遇到的问题，可以通过另一个指定链接找到解决方案。确保已安装libasound-dev, portaudio-dev, libportaudio2, libportaudiocpp0等依赖库。
之后，重新编译Python3。首先进入Python-3.6.3安装源目录，执行命令：$ sudo ./configure --enable-optimozations，$ sudo make -j8，$ sudo make install。验证安装是否成功，可通过执行$ python3并输入import sqlite3命令来实现。
对于Anki服务器的安装与运行，参考指定的文档。注意这是针对Anki2.1客户端的服务器，而Anki2.0的服务器依赖与此类似。
在Add-on文件夹下创建名为ankisyncd的文件夹，并在此文件夹中创建并编辑__init__.py文件。确保文件中不含汉字，保存为utf-8格式。这一步骤为Anki服务器的设置关键步骤。
