单线程实现检索当当网泄露的1GB用户数据

简介:  新建项目dangdangusersearch 2.编写头文件head.h #ifndef _HEAD_H_ #define _HEAD_H_   #include <stdio.h>    //注意文件操作相关函数的头文件是stdio.h #include<stdlib.h>    //为了

  1. 新建项目dangdangusersearch

2.编写头文件head.h

#ifndef _HEAD_H_

#define _HEAD_H_

 

#include <stdio.h>    //注意文件操作相关函数的头文件是stdio.h

#include<stdlib.h>    //为了使用system函数

#include <string.h>   //字符串操作所用到的头文件

#include<Windows.h>   //使用休眠函数时用到的头文件

#include <crtdbg.h>   //做内存泄露检测所需的头文件

 

//开启内存检测

#define _CRTDBG_MAP_ALLOC

 

/*菜单查看*/

extern void main_view();

 

/*获得文件的字节大小*/

extern int getFileSize(const char *path);

/*加载文件,fPath为传递进去的文件路径*/

extern void loadFile(const char *fPath, const int rowSize);

/*通过关键字查找*/

extern void findStringByKeyword(const char *keyword, const int rowSize);

/*查看文件中有多少行*/

extern int getFileRow(const char *path);

/*释放存放每行直至的数组的内存和每行字符串所占的内存*/

extern void freeMemory(char **pp, const int rowSize);

 

#endif

3.编写main.c

//注意文件操作相关函数的头文件是stdio.h

#include "head.h"

 

/*菜单查看*/

void main_view()

{

    system("cls");

    printf("\n******************当当用户信息查询系统*******************\n");

    printf("\t1.载入数据至内存(-l)\n");

    printf("\t2.查找字符串(-s)\n");

    printf("\t3.释放内存(-f)\n");

    printf("\n*************************0.退出**************************\n");

}

4.编写file.c

#define _CRT_SECURE_NO_WARNINGS

#include "head.h"

 

char **pp = NULL; //存储指针数组的地址

FILE *pf = NULL;  //定义一个文件指针

int flag = 0;     //这个标识符用于判断是否加载完成,0:标识没有加载,1:表示完成加载,2:表示释放释放内存

 

/*获得文件的字节大小*/

int getFileSize(const char *path)

{

    //按照读取的模式打开

    pf = fopen(path, "r");

    if (pf == NULL)

    {

        //代表获取文件失败

        return -1;

    }

    else

    {

        //fseek():Moves thefile pointer to a specified location.

        fseek(pf, 0, SEEK_END);

        //ftell( FILE*stream ):文件开头到当前位置有多少个字节

        int num = ftell(pf);

        fclose(pf);//关闭文件

        return num;

    }

}

 

/*加载文件,fPath为传递进去的文件路径*/

void loadFile(const char *fPath, const int rowSize)

{

    printf("加载文件中,请稍后....");

    //pp里面存储的是每行字符串的地址

    pp = (char **)malloc(sizeof(char *)*rowSize);

    pf = fopen(fPath, "r");

    if (pf == NULL)

    {

        printf("对不起,加载文件失败!");

        return;

    }

    else

    {

        int i;

        for (i = 0; i < rowSize; i++)

        {

            //读取字符串的缓冲区

            char str[275] = { 0 };

            //*fgets( char*string, int n, FILE *stream );

            //从文件中逐行读取字符串

            fgets(str, 275, pf);

            //获取要分配的字符串长度,最后加一是因为'\0'

            int strlength = strlen(str) + 1;

            //分配内存

            char *px = malloc(sizeof(char)*strlength);

            //拷贝字符串

            strcpy(px, str);

            //设定最后一个字符串为'\0'

            px[strlength - 1] = '\0';

            //存储字符串的首地址到指针数组

            pp[i] = px;

        }

    }

    fclose(pf);

    flag = 1;

    printf("载入内存OK\n");

}

 

/*通过关键字查找*/

void findStringByKeyword(const char *keyword, const int rowSize)

{

    if (pp == NULL)

    {

        printf("对不起,您还没有加载文件,请您先加载文件\n");

        return;

    }

    int i;

    for (i = 0; i < rowSize; i++)

    {

        //遍历所有的指针数组的地址,字符串查找

        char *ptemp = strstr(pp[i], keyword);

        if (ptemp != NULL)

        {

            printf("\n%s", pp[i]);//打印字符串

        }

    }

}

 

int getFileRow(const char *path)

{

    //读取的模式打开

    pf = fopen(path, "r");

    if (pf == NULL)

    {

        //代表获取失败

        return -1;

    }

    else

    {

        int i = 0;

        //是否到文件末尾

        while (!feof(pf))

        {

            char str[275];

            fgets(str, 275, pf);//读取一行

            i++;

        }

        fclose(pf);

        return i;

    }

}

 

/*释放存放每行直至的数组的内存和每行字符串所占的内存*/

void freeMemory(char **pp, const int rowSize)

{

    printf("正在释放内存,请稍后!");

    int i;

    for (i = 0; i < rowSize; i++)

    {

        //通过这种方式释放内存的时候较慢,因为是一行行的释放的

        free(pp[i]);

    }

    free(pp);

    flag = 0;

}

5.编写DDSS.c

#define _CRT_SECURE_NO_WARNINGS

#include "head.h"

 

extern int flag;

extern char **pp;

 

/************************************************************************/

/* 当当用户信息查询系统                                                */

/************************************************************************/

int main(int argc, char *argv[])

{

    //文件所在位置

    char *path = "G:\\dangdangwang.txt";

    int fileSize = getFileSize(path);

    //printf("%d字节,%fK,%fM", fileSize, fileSize /1024.0, fileSize / 1024.0 / 1024.0);

    //这个选择菜单是的字符串

    char choice[25];

 

    //获得行号

    int row = getFileRow(path);

    printf("%d\n", row);

 

flag:system("cls");

    main_view();

    if (flag)

    {

        printf("文件加载完毕,可以进行查找了!\n");

    }

    else if (flag == 0)

    {

        printf("文件未加载状态,请您先加载文件!\n");

    }

    while (1)

    {

        printf("输入内容或选择('-v'显示菜单):");

        scanf("%24s", choice);

 

        if (!strcmp(choice, "-v") || !strcmp(choice, "-view")){

            main_view();

        }

        else if (!strcmp(choice, "-l") || !strcmp(choice, "-loadFile"))

        {

            loadFile(path, row);

        }

        else if (!strcmp(choice, "-s") || !strcmp(choice, "-search"))

        {

            while (1)

            {

                char keyword[100] = { 0 };

                printf("\n请输入要查找的字符串,输入-exit将退出查找\n");

                scanf("%s", keyword);

 

                if (strcmp(keyword, "-exit"))

                {

                    findStringByKeyword(keyword, row);

                }

                else

                {

                    break;

                }

            }

        }

        else if (!strcmp(choice, "-f") || !strcmp(choice, "-free"))

        {

            freeMemory(pp, row);

        }

        goto flag;

    }

 

    system("pause");

    return 0;

}

 

 

 

 

将查询到的结果封装到txt文本中

#define _CRT_SECURE_NO_WARNINGS   //关闭安全检查

#include <stdio.h>

#include <stdlib.h>

 

void main()

{

    char *path = "G:\\dangdangwang.txt";

    char *respath = "G:\\1.txt";

 

    FILE *pf;

    FILE *fp;

    pf = fopen(path,"r");//读的模式

    fp = fopen(respath,"w");//写的模式

    if (pf == NULL)

    {

        printf("文件打开失败");

    }

    else

    {

        //文件指针到末尾

        fseek(pf, 0, SEEK_END);

        int num = ftell(pf);

        char  strinfo[200];

        sprintf(strinfo, "\nnum=%d字节,%fK,%fM", num, num / 1024.0, num / 1024.0 / 1024.0);

        fputs(strinfo, fp);//写入文件

        rewind(pf);//回到文件开头

        while (!feof(pf))

        {

            //缓冲区

            char str[200];

            //读取,按照行读取

            fgets(str, 200, pf);

            if (strstr(str,"谭胜") != NULL)  //字符串查找

            {

                fputs(str, fp);//写入文件

                printf("\n%s", str);//打印结果

            }

        }

        fclose(fp);   //关闭文件

        fclose(pf);   //关闭文件

    }

    //打开结果文件

    system(respath);

    system("pause");

}

 

目录
相关文章
|
8月前
|
存储 前端开发 Java
【C++ 多线程 】C++并发编程:精细控制数据打印顺序的策略
【C++ 多线程 】C++并发编程:精细控制数据打印顺序的策略
218 1
|
4月前
|
消息中间件 监控 安全
服务Down机了,线程池中的数据如何保证不丢失?
在分布式系统与高并发应用开发中,服务的稳定性和数据的持久性是两个至关重要的考量点。当服务遭遇Down机时,如何确保线程池中处理的数据不丢失,是每一位开发者都需要深入思考的问题。以下,我将从几个关键方面分享如何在这种情况下保障数据的安全与完整性。
79 2
|
2月前
|
消息中间件 监控 Java
线程池关闭时未完成的任务如何保证数据的一致性?
保证线程池关闭时未完成任务的数据一致性需要综合运用多种方法和机制。通过备份与恢复、事务管理、任务状态记录与恢复、数据同步与协调、错误处理与补偿、监控与预警等手段的结合,以及结合具体业务场景进行分析和制定策略,能够最大程度地确保数据的一致性,保障系统的稳定运行和业务的顺利开展。同时,不断地优化和改进这些方法和机制,也是提高系统性能和可靠性的重要途径。
124 62
|
3月前
|
缓存 安全 Java
使用 Java 内存模型解决多线程中的数据竞争问题
【10月更文挑战第11天】在 Java 多线程编程中,数据竞争是一个常见问题。通过使用 `synchronized` 关键字、`volatile` 关键字、原子类、显式锁、避免共享可变数据、合理设计数据结构、遵循线程安全原则和使用线程池等方法,可以有效解决数据竞争问题,确保程序的正确性和稳定性。
65 2
|
7月前
|
缓存 NoSQL Java
Java高并发实战:利用线程池和Redis实现高效数据入库
Java高并发实战:利用线程池和Redis实现高效数据入库
540 0
|
8月前
|
消息中间件 Java Kafka
实时计算 Flink版操作报错之Apache Flink中的SplitFetcher线程在读取数据时遇到了未预期的情况,该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
4月前
|
消息中间件 存储 Java
服务重启了,如何保证线程池中的数据不丢失?
【8月更文挑战第30天】为确保服务重启时线程池数据不丢失,可采用数据持久化(如数据库或文件存储)、使用可靠的任务队列(如消息队列或分布式任务队列系统)、状态监测与恢复机制,以及分布式锁等方式。这些方法能有效提高系统稳定性和可靠性,需根据具体需求选择合适方案并进行测试优化。
266 5
|
5月前
处理串口线程数据的函数
【8月更文挑战第4天】处理串口线程数据的函数。
33 4
|
5月前
|
数据处理 Python
解锁Python多线程编程魔法,告别漫长等待!让数据下载如飞,感受科技带来的速度与激情!
【8月更文挑战第22天】Python以简洁的语法和强大的库支持在多个领域大放异彩。尽管存在全局解释器锁(GIL),Python仍提供多线程支持,尤其适用于I/O密集型任务。通过一个多线程下载数据的例子,展示了如何使用`threading`模块创建多线程程序,并与单线程版本进行了性能对比。实验表明,多线程能显著减少总等待时间,但在CPU密集型任务上GIL可能会限制其性能提升。此案例帮助理解Python多线程的优势及其适用场景。
52 0
|
5月前
|
NoSQL Redis
Lettuce的特性和内部实现问题之在同步调用模式下,业务线程是如何拿到结果数据的
Lettuce的特性和内部实现问题之在同步调用模式下,业务线程是如何拿到结果数据的