From 1537186f437bb5f07269231724772f8de68e8a72 Mon Sep 17 00:00:00 2001
From: username@email.com <yzy2002yzy@163.com>
Date: 星期五, 20 六月 2025 08:56:44 +0800
Subject: [PATCH] no message
---
zhengcaioa/Crawler/Program.cs | 104 +++++++++++++++++++++++++++++++++++----------------
1 files changed, 71 insertions(+), 33 deletions(-)
diff --git a/zhengcaioa/Crawler/Program.cs b/zhengcaioa/Crawler/Program.cs
index 8a34395..3f181c0 100644
--- a/zhengcaioa/Crawler/Program.cs
+++ b/zhengcaioa/Crawler/Program.cs
@@ -20,10 +20,12 @@
//public static string connection = @"server=.;database=WebCrawler;uid=sa;pwd=123456;";
//public static string connection1 = @"server=.;database=zhengcaioa;uid=sa;pwd=123456;";
+ //public static string connection2 = @"server=.;database=FZCZTB;uid=sa;pwd=123456;";
//public static string api_domain = "http://192.168.0.9:9200";
public static string connection = @"server=172.26.97.184;database=WebCrawler;uid=sa;pwd=Za20222812;";
public static string connection1 = @"server=172.26.97.184;database=zhengcaioa;uid=sa;pwd=Za20222812;";
+ public static string connection2 = @"server=172.26.97.184;database=FZCZTB;uid=sa;pwd=Za20222812;";
public static string api_domain = "http://172.26.97.184:9200";
static void Main(string[] args)
{
@@ -140,12 +142,12 @@
Program obj = new Program();
//鏂规硶涓�锛氳皟鐢ㄧ嚎绋嬫墽琛屾柟娉曪紝鍦ㄦ柟娉曚腑瀹炵幇姝诲惊鐜紝姣忎釜寰幆Sleep璁惧畾鏃堕棿
- Thread thread = new Thread(new ThreadStart(obj.Method1));
+ Thread thread = new Thread(new ThreadStart(obj.Method));
thread.Start();
- //Thread thread1 = new Thread(new ThreadStart(obj.Method2));
- //thread1.Start();
+ Thread thread1 = new Thread(new ThreadStart(obj.Method2));
+ thread1.Start();
//Thread thread2 = new Thread(new ThreadStart(obj.Method3));
@@ -154,59 +156,95 @@
Console.WriteLine("Hello World!");
}
- void Method1()
+ void Method()
{
while (true)
{
- ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
+ //ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
- var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
+ var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection2).Options);
- var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
- var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
+ //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
+ //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
- //鑾峰彇鍥涘窛鐨勬斂閲囨暟鎹�
- sichuanoperation.operations(cccontext, cccontext1);
+ //鑾峰彇鍥涘窛鐨勬姇璇夊鐞嗘暟鎹�
+ sichuantousuoperation.operations(cccontext);
//Console.WriteLine("杩欎釜鏆傚仠");
Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
}
}
+
void Method2()
{
while (true)
{
- ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
+ //ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
- var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
-
- var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
- var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
-
- //鑾峰彇鍥涘窛鐨勬斂閲囨暟鎹�
- OldSichuanoperation.operations(cccontext, cccontext1);
- Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
- }
- }
-
-
- void Method3()
- {
- while (true)
- {
- ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
- var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
- var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
+ var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection2).Options);
//var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
//var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
- //鑾峰彇涓浗鏀块噰缃戠殑鍥涘窛鏀块噰鏁版嵁
- CcgpSichuanoperation.operations(cccontext);
- Thread.CurrentThread.Join(1000 * 60 * 10);//闃绘璁惧畾鏃堕棿
+ sichuantousuoperation.operations1(cccontext);
+ //Console.WriteLine("杩欎釜鏆傚仠");
+ Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
}
}
+ //void Method1()
+ //{
+ // while (true)
+ // {
+ // ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
+ // var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
+ // var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
+
+ // var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
+ // var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
+
+ // //鑾峰彇鍥涘窛鐨勬斂閲囨暟鎹�
+ // sichuanoperation.operations(cccontext, cccontext1);
+ // //Console.WriteLine("杩欎釜鏆傚仠");
+ // Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
+ // }
+ //}
+
+ //void Method2()
+ //{
+ // while (true)
+ // {
+ // ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
+ // var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
+ // var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
+
+ // var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
+ // var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
+
+ // //鑾峰彇鍥涘窛鐨勬斂閲囨暟鎹�
+ // OldSichuanoperation.operations(cccontext, cccontext1);
+ // Thread.CurrentThread.Join(1000 * 60 * 60 * 2);//闃绘璁惧畾鏃堕棿
+ // }
+ //}
+
+
+ //void Method3()
+ //{
+ // while (true)
+ // {
+ // ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
+ // var dbContextOptionBuilder = new DbContextOptionsBuilder<WebCrawlerContext>();
+ // var cccontext = new WebCrawlerContext(dbContextOptionBuilder.UseSqlServer(connection).Options);
+
+ // //var dbContextOptionBuilder1 = new DbContextOptionsBuilder<zhengcaioaContext>();
+ // //var cccontext1 = new zhengcaioaContext(dbContextOptionBuilder1.UseSqlServer(connection1).Options);
+
+ // //鑾峰彇涓浗鏀块噰缃戠殑鍥涘窛鏀块噰鏁版嵁
+ // CcgpSichuanoperation.operations(cccontext);
+ // Thread.CurrentThread.Join(1000 * 60 * 10);//闃绘璁惧畾鏃堕棿
+ // }
+ //}
+
--
Gitblit v1.9.1