使用Quartz.NET完成热词统计，web server和 WCF的使用

OA项目第八天

热词统计简介

我们在搜索的时候，比如百度，我们刚打个a在搜索框，那么它会自动弹出什么爱奇艺，阿里巴巴等相关热词，那么这个是怎么做的呢?我们按照以下的步骤来看

• 先有一张汇总表，只要用户搜索就往数据库插入一条数据

• 第二张表，明细表，每隔一段时间我们就进行统计，统计(比如说最近一周)用户搜索的数据中的相似或者相同的数据

这样一来就简单明了了，需要准备的工作就是创建数据库，每隔一段时间统计，那么这个每隔一段时间执行，这个我们怎么去做呢。我们使用的是一个开源的项目Quartz.NET.

Quartz.NET

这里是它的官网地址：https://www.quartz-scheduler.net/

在我们建立好汇总表( KeyWordsRank)，明细表（SearchDetails）后，就可以开始了。注意这里这两个表的主键ID我们用的是GUID，这样一来会比自增的数字ID性能更好。为了方便测试，我们直接在业务层写sql数据查询，这样只是偷偷懒，千万不要这样做。

public partial class KeyWordsRankService: BaseService<KeyWordsRank>, IKeyWordsRankService
   {
       //删除汇总表所有的数据
       public bool DeleteAllKeyWordsRank()
       {
           string sql = "truncate table KeyWordsRank";
           return this.CurrentDBSession.ExecuteSql(sql) > 0;
       }
       //插入查询好的数据
       public bool InsertKeyWordsRank()
       {
           string sql = "insert into KeyWordsRank(Id,KeyWords,SearchCount) select uuid(),KeyWords,count(*)  from SearchDetails where DateDiff(SearchDateTime,sysdate())<=7 group by SearchDetails.KeyWords";
           return this.CurrentDBSession.ExecuteSql(sql) > 0;
       }
       //前端请求查询的
       public List<string> GetAvailableTags(string temps)
       {
           string sql = "select keywords from KeyWordsRank where keywords like @temps";
           return this.CurrentDBSession.ExecuteSql<string>(sql, new MySqlParameter("@temps", temps + "%"));
       }
   }

Quartz.NET的用法可以参照官网的快速入门，这里就不叙述了，新建一个类继承IJob,实现它的方法，这个方法就是我们具体执行的工作

public class IndexJob : IJob
   {
       OAProject.IBLL.IKeyWordsRankService bll = new OAProject.BLL.KeyWordsRankService();
       //每隔一段时间把总的记录写入数据库，先删除再增加
       public Task Execute(IJobExecutionContext context)
       {
           Task t = Task.Run(() =>
           {
               bll.DeleteAllKeyWordsRank();

               bll.InsertKeyWordsRank();
           });
           return t;
       }
   }

我们新建一个控制太程序来执行这个方法，当热最好我们做成windows服务（话说我这是跑在linux上的咋办），

这都是直接改的官网的快速入门。这里为了看效果我是做了每10s执行一次，实际工作当热不能这样做

class Program
   {
       static void Main(string[] args)
       {
           LogProvider.SetCurrentLogProvider(new ConsoleLogProvider());

           RunProgramRunExample().GetAwaiter().GetResult();

           Console.WriteLine("Press any key to close the application");
           Console.ReadKey();
       }

       private static async Task RunProgramRunExample()
       {
           try
           {
               // 从工厂类中获取调度器实例
               NameValueCollection props = new NameValueCollection
               {
                   { "quartz.serializer.type", "binary" }
               };
               StdSchedulerFactory factory = new StdSchedulerFactory(props);
               IScheduler scheduler = await factory.GetScheduler();

               // 并开始了
               await scheduler.Start();

               // 定義工作並將其與我們的IndexJob類相關聯
               IJobDetail job = JobBuilder.Create<IndexJob>()
                   .WithIdentity("job1", "group1")
                   .Build();

               // 现在触发工作运行,然后重复每10秒
               ITrigger trigger = TriggerBuilder.Create()
                   .WithIdentity("trigger1", "group1")
                   .StartNow()
                   .WithSimpleSchedule(x => x
                       .WithIntervalInSeconds(10)//每隔10秒执行一次
                       .RepeatForever())
                   .Build();

               // 告诉石英使用我们的触发器安排工作
               await scheduler.ScheduleJob(job, trigger);

               // some sleep to show what's happening 一些睡觉，以显示发生了什么
               //await Task.Delay(TimeSpan.FromSeconds(60));//表示这个程序运行多久，要是每10秒运行一次那么表示这个程序一共修改了7次（包括一开始旧运行修改的一次）

               // 最后关闭调度器当你准备关闭程序
               //await scheduler.Shutdown();
               if (Console.Read() == 48) //要是输入的是 0，等待当前方法执行完毕结束程序
               {
                   await scheduler.Shutdown();
               }
               
               
           }
           catch (SchedulerException se)
           {
               Console.WriteLine(se);
           }
       }

       // simple log provider to get something to the console
       private class ConsoleLogProvider : ILogProvider
       {
           public Logger GetLogger(string name)
           {
               return (level, func, exception, parameters) =>
               {
                   if (level >= LogLevel.Info && func != null)
                   {
                       Console.WriteLine("[" + DateTime.Now.ToLongTimeString() + "] [" + level + "] " + func(), parameters);
                   }
                   return true;
               };
           }

           public IDisposable OpenNestedContext(string message)
           {
               throw new NotImplementedException();
           }

           public IDisposable OpenMappedContext(string key, string value)
           {
               throw new NotImplementedException();
           }
       }
   }

这里的业务类，调用的是是我们dbsession里面直接写的方法，实际工作千万别这样

public partial class DBSession: IDBSession
   {
       //IUserInfoDal _userinfodal ;

       public DbContext Db
       {
           get =>DAL.DBcontextFactory.CreatDbContext();

       }
       //EF执行sql语句
       public int ExecuteSql(string sql, params SqlParameter[] pars)
       {
           return Db.Database.ExecuteSqlCommand(sql, pars);
       }

       public List<T> ExecuteSql<T>(string sql, params MySqlParameter[] pars)
       {
           return Db.Database.SqlQuery<T>(sql, pars).ToList(); 
       }

       //保存数据的方法
       public bool SaveValueChange()
       {
           return Db.SaveChanges()>0;
       }
   }

但是这里会出现一些问题，首先我们必须在app.config里面从新配置点好程序集等等，不然会报错，要是配置好之后还出错那就是还必须引用EF，

 <appSettings>
    <add key="AssemblyPath" value="OAProject.DAL" />
    <add key="NameSpace" value="OAProject.DAL" />
  </appSettings>
  <connectionStrings>
    <add name="OAEntities" connectionString="metadata=res://*/Model1.csdl|res://*/Model1.ssdl|res://*/Model1.msl;provider=MySql.Data.MySqlClient;provider connection string=&quot;server=服务器id;user id=Long;password=密码;persistsecurityinfo=True;database=OA&quot;" providerName="System.Data.EntityClient" />
  </connectionStrings>
//要是还报错negut包引用好相同版本的EF

热词展示

我们使用https://jqueryui.com/autocomplete/，jquery ui的自动完成，效果就跟百度的搜索展示的热词一摸一样。这里要说的以点就是后端接收的请求字符串是term

web server

Web Server中文名称叫网页服务器或web服务器。WEB服务器也称为WWW(WORLD WIDE WEB)服务器，主要功能是提供网上信息浏览服务。主要web server产品有：kangle，nginx，apache。前面所说的都跟我们这里没关系哈哈哈。一句话，实现不同机器，不同平台下的应用程序之间的通信 。

VS中创建WebServer比较简单，在Web项目中右键引用，添加服务引用，把地址填上就行，要是同一个解决方案的话那就点击发现，就能找到解决方案中的WebServer.看一看到如下的方法

namespace WebServerTest
{
    /// <summary>
    /// WebService1 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。 
    // [System.Web.Script.Services.ScriptService]
    public class WebService1 : System.Web.Services.WebService
    {

        [WebMethod]
        public string HelloWorld()
        {
            return "Hello World";
        }
        [WebMethod]
        public int Sum(int a,int b)
        {
            return a + b;
        }
    }
}

winform的店家按钮调用

private void button3_Click(object sender, EventArgs e)
       {
           ServiceReference1.WebService1SoapClient client = new WebService1SoapClient();
           MessageBox.Show(client.Sum(1, 2).ToString());
       }

接下来我们试试远程调用，百度下什么天气预报的webserver

private void button3_Click(object sender, EventArgs e)
      {
         ServiceReference2.WeatherWSSoapClient client = new WeatherWSSoapClient();//找到的调用
          DataSet ds= client.getRegionDataset();
          this.dataGridView1.DataSource =ds.Tables[0];
      }

WCF

跟webserver不同，WCF是面向接口，最重要的一步是添加System.WebModle引用，不像webserver一样可以直接建，我们需要手动建立一个接口

[ServiceContract]//这就提供了一个服务契约
  public interface IUserInfoServer
  {
      [OperationContract]
      int Sum(int a, int b);
  }

实现这个接口类

public class UserInfoServer : IBLL.IUserInfoServer
   {
       public int Sum(int a, int b)
       {
           return a + b;
       }
   }

现在新建立一个客户端(这里使用的是控制台程序，记得添加引用，包括System.WebModle的引用)

class Program
  {
      static void Main(string[] args)
      {
          using (ServiceHost host = new ServiceHost(typeof(BLL.UserInfoServer)))//这里不能写接口
          {
              host.Open();
              Console.ReadKey();
          }
      }
  }

配置号config

<?xml version="1.0" encoding="utf-8" ?>
<configuration>

  
  <system.web>
    <compilation debug="true" />
  </system.web>
  <!-- 部署服务库项目时，必须将配置文件的内容添加到 
  主机的 app.config 文件中。System.Configuration 不支持库的配置文件。-->
  <system.serviceModel>
    <services>
      <!--名字-->
      <service name="BLL.UserInfoServer">
        <!--修改地址以及契约-->
        <endpoint address="" binding="basicHttpBinding" contract="IBLL.IUserInfoServer">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
        <!--<endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />-->
        <host>
          <baseAddresses>
            <add baseAddress="http://127.0.0.1:8000" /><!--修改地址-->
          </baseAddresses>
        </host>
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior>
          <!-- 为避免泄漏元数据信息，
          请在部署前将以下值设置为 false -->
          <serviceMetadata httpGetEnabled="True" httpsGetEnabled="True"/>
          <!-- 要接收故障异常详细信息以进行调试，
          请将以下值设置为 true。在部署前设置为 false 
            以避免泄漏异常信息-->
          <serviceDebug includeExceptionDetailInFaults="False" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>

</configuration>

接下来我们可以使用微软的测试wcf的客户端，我们先用管理员运行我们的控制台程序

找到Vs的安装路径，找到Common7\IDE\WcfTestClient.exe，双击打开，新建服务即可

自己新建一个WCF客户端

我们可以用微软的工具来自己生成一个客户端（就是一个类），首先在新建一个控制台应用程序，找到路径，用vs提示命令符，进入路径，执行svcutil http://localhost:8000/?wsdl/o:UserInfoServeClient.cs，然后点击这个项目的显示所有文件，修改下生成的UserInfoServeClient.cs，比如注释下已经有的接口，没用的方法等等，看下配置有没有错误，引用好需要引用的。最后直接当普通类一样调用即可(当然服务必须开启)