C# VS2019 WebService创建与发布,并部署到Windows Server 2012R
程序员文章站
2023-11-15 17:04:34
前言 上一次数据库灾备和性能优化后,数据库专家建议,在不扩容的情况下,客户端不能再频繁的扫描数据库了!一句惊醒梦中人,因为我也发现数据库越来越卡了,自从上个项目上线后,就出现了这个情况。后来分析其原因,发现客户端每3秒中扫描一次数据库,一共5000+客户端,可想而知,频繁扫描严重影响到数据库性能。所 ......
前言
上一次数据库灾备和性能优化后,数据库专家建议,在不扩容的情况下,客户端不能再频繁的扫描数据库了!一句惊醒梦中人,因为我也发现数据库越来越卡了,自从上个项目上线后,就出现了这个情况。后来分析其原因,发现客户端每3秒中扫描一次数据库,一共5000+客户端,可想而知,频繁扫描严重影响到数据库性能。所以,我这边准备采用三层架构来解决这个问题,将现有的业务逻辑全部移植到webservice服务器上,客户端通过webservice服务,进而实现对数据库的操作。
此篇只是记录一下,便于后续的学习,不足之处请指正。
创建webservice服务
- 新建asp.net web解决方案,命名为webservicetest,框架选择.net framework 4,如下图;
- 添加一个web服务,命名为webserviceoracletest,如下图;
- 开始写一些基础helper类;
1 using system; 2 using system.collections.generic; 3 using system.linq; 4 using system.web; 5 using system.data; 6 using system.configuration; 7 using oracle.manageddataaccess.client; 8 using system.text; 9 using system.io; 10 11 namespace webservicetest 12 { 13 public class oraclehelper 14 { 15 //连接字符串 16 public static string oraconnstr = "data source=(description=(address=(protocol=tcp)(host=xxx)(port=1521))(connect_data=(service_name=xxx)));persist security info=true;user id=xxx;password=xxx"; 17 18 #region oracle数据库操作通用方法 19 /// <summary> 20 /// 测试数据库连接是否正常 21 /// </summary> 22 /// <param name="strconn"></param> 23 /// <returns></returns> 24 public static bool checkoracleconnect() 25 { 26 try 27 { 28 oracleconnection conn = new oracleconnection(); 29 conn.connectionstring = oraconnstr; 30 conn.open(); 31 return true; 32 } 33 catch 34 { 35 return false; 36 } 37 } 38 39 /// <summary> 40 /// 执行数据库非查询操作,返回受影响的行数 41 /// </summary> 42 /// <param name="connectionstring">数据库连接字符串</param> 43 /// <param name="cmdtype">命令的类型</param> 44 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 45 /// <param name="cmdparms">命令参数集合</param> 46 /// <returns>当前查询操作影响的数据行数</returns> 47 public static int executenonquery(string connectionstring, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 48 { 49 oraclecommand cmd = new oraclecommand(); 50 using (oracleconnection conn = new oracleconnection(connectionstring)) 51 { 52 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 53 int val = cmd.executenonquery(); 54 cmd.parameters.clear(); 55 return val; 56 } 57 } 58 59 /// <summary> 60 /// 执行数据库事务非查询操作,返回受影响的行数 61 /// </summary> 62 /// <param name="transaction">数据库事务对象</param> 63 /// <param name="cmdtype">command类型</param> 64 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 65 /// <param name="cmdparms">命令参数集合</param> 66 /// <returns>当前事务查询操作影响的数据行数</returns> 67 public static int executenonquery(oracletransaction trans, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 68 { 69 oraclecommand cmd = new oraclecommand(); 70 preparecommand(cmd, trans.connection, trans, cmdtype, cmdtext, cmdparms); 71 int val = cmd.executenonquery(); 72 cmd.parameters.clear(); 73 return val; 74 } 75 76 /// <summary> 77 /// 执行数据库非查询操作,返回受影响的行数 78 /// </summary> 79 /// <param name="connection">oracle数据库连接对象</param> 80 /// <param name="cmdtype">command类型</param> 81 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 82 /// <param name="cmdparms">命令参数集合</param> 83 /// <returns>当前查询操作影响的数据行数</returns> 84 public static int executenonquery(oracleconnection connection, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 85 { 86 if (connection == null) 87 throw new argumentnullexception("当前数据库连接不存在"); 88 oraclecommand cmd = new oraclecommand(); 89 preparecommand(cmd, connection, null, cmdtype, cmdtext, cmdparms); 90 int val = cmd.executenonquery(); 91 cmd.parameters.clear(); 92 return val; 93 } 94 95 /// <summary> 96 /// 执行数据库查询操作,返回oracledatareader类型的内存结果集 97 /// </summary> 98 /// <param name="connectionstring">数据库连接字符串</param> 99 /// <param name="cmdtype">命令的类型</param> 100 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 101 /// <param name="cmdparms">命令参数集合</param> 102 /// <returns>当前查询操作返回的oracledatareader类型的内存结果集</returns> 103 public static oracledatareader executereader(string connectionstring, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 104 { 105 oraclecommand cmd = new oraclecommand(); 106 oracleconnection conn = new oracleconnection(connectionstring); 107 try 108 { 109 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 110 oracledatareader reader = cmd.executereader(commandbehavior.closeconnection); 111 cmd.parameters.clear(); 112 return reader; 113 } 114 catch 115 { 116 cmd.dispose(); 117 conn.close(); 118 throw; 119 } 120 } 121 122 /// <summary> 123 /// 执行数据库查询操作,返回dataset类型的结果集 124 /// </summary> 125 /// <param name="connectionstring">数据库连接字符串</param> 126 /// <param name="cmdtype">命令的类型</param> 127 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 128 /// <param name="cmdparms">命令参数集合</param> 129 /// <returns>当前查询操作返回的dataset类型的结果集</returns> 130 public static dataset executedataset(string connectionstring, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 131 { 132 oraclecommand cmd = new oraclecommand(); 133 oracleconnection conn = new oracleconnection(connectionstring); 134 dataset ds = null; 135 try 136 { 137 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 138 oracledataadapter adapter = new oracledataadapter(); 139 adapter.selectcommand = cmd; 140 ds = new dataset(); 141 adapter.fill(ds); 142 cmd.parameters.clear(); 143 } 144 catch 145 { 146 throw; 147 } 148 finally 149 { 150 cmd.dispose(); 151 conn.close(); 152 conn.dispose(); 153 } 154 155 return ds; 156 } 157 158 /// <summary> 159 /// 执行数据库查询操作,返回datatable类型的结果集 160 /// </summary> 161 /// <param name="connectionstring">数据库连接字符串</param> 162 /// <param name="cmdtype">命令的类型</param> 163 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 164 /// <param name="cmdparms">命令参数集合</param> 165 /// <returns>当前查询操作返回的datatable类型的结果集</returns> 166 public static datatable executedatatable(string connectionstring, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 167 { 168 oraclecommand cmd = new oraclecommand(); 169 oracleconnection conn = new oracleconnection(connectionstring); 170 datatable dt = null; 171 172 try 173 { 174 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 175 oracledataadapter adapter = new oracledataadapter(); 176 adapter.selectcommand = cmd; 177 dt = new datatable(); 178 adapter.fill(dt); 179 cmd.parameters.clear(); 180 } 181 catch 182 { 183 throw; 184 } 185 finally 186 { 187 cmd.dispose(); 188 conn.close(); 189 conn.dispose(); 190 } 191 192 return dt; 193 } 194 195 /// <summary> 196 /// 执行数据库查询操作,返回结果集中位于第一行第一列的object类型的值 197 /// </summary> 198 /// <param name="connectionstring">数据库连接字符串</param> 199 /// <param name="cmdtype">命令的类型</param> 200 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 201 /// <param name="cmdparms">命令参数集合</param> 202 /// <returns>当前查询操作返回的结果集中位于第一行第一列的object类型的值</returns> 203 public static object executescalar(string connectionstring, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 204 { 205 oraclecommand cmd = new oraclecommand(); 206 oracleconnection conn = new oracleconnection(connectionstring); 207 object result = null; 208 try 209 { 210 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 211 result = cmd.executescalar(); 212 cmd.parameters.clear(); 213 } 214 catch 215 { 216 throw; 217 } 218 finally 219 { 220 cmd.dispose(); 221 conn.close(); 222 conn.dispose(); 223 } 224 225 return result; 226 } 227 228 /// <summary> 229 /// 执行数据库事务查询操作,返回结果集中位于第一行第一列的object类型的值 230 /// </summary> 231 /// <param name="trans">一个已存在的数据库事务对象</param> 232 /// <param name="commandtype">命令类型</param> 233 /// <param name="commandtext">oracle存储过程名称或pl/sql命令</param> 234 /// <param name="cmdparms">命令参数集合</param> 235 /// <returns>当前事务查询操作返回的结果集中位于第一行第一列的object类型的值</returns> 236 public static object executescalar(oracletransaction trans, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 237 { 238 if (trans == null) 239 throw new argumentnullexception("当前数据库事务不存在"); 240 oracleconnection conn = trans.connection; 241 if (conn == null) 242 throw new argumentexception("当前事务所在的数据库连接不存在"); 243 244 oraclecommand cmd = new oraclecommand(); 245 object result = null; 246 247 try 248 { 249 preparecommand(cmd, conn, trans, cmdtype, cmdtext, cmdparms); 250 result = cmd.executescalar(); 251 cmd.parameters.clear(); 252 } 253 catch 254 { 255 throw; 256 } 257 finally 258 { 259 trans.dispose(); 260 cmd.dispose(); 261 conn.close(); 262 conn.dispose(); 263 } 264 265 return result; 266 } 267 268 /// <summary> 269 /// 执行数据库查询操作,返回结果集中位于第一行第一列的object类型的值 270 /// </summary> 271 /// <param name="conn">数据库连接对象</param> 272 /// <param name="cmdtype">command类型</param> 273 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 274 /// <param name="cmdparms">命令参数集合</param> 275 /// <returns>当前查询操作返回的结果集中位于第一行第一列的object类型的值</returns> 276 public static object executescalar(oracleconnection conn, commandtype cmdtype, string cmdtext, params oracleparameter[] cmdparms) 277 { 278 if (conn == null) throw new argumentexception("当前数据库连接不存在"); 279 oraclecommand cmd = new oraclecommand(); 280 object result = null; 281 282 try 283 { 284 preparecommand(cmd, conn, null, cmdtype, cmdtext, cmdparms); 285 result = cmd.executescalar(); 286 cmd.parameters.clear(); 287 } 288 catch 289 { 290 throw; 291 } 292 finally 293 { 294 cmd.dispose(); 295 conn.close(); 296 conn.dispose(); 297 } 298 299 return result; 300 } 301 302 /// <summary> 303 /// 执行数据库命令前的准备工作 304 /// </summary> 305 /// <param name="cmd">command对象</param> 306 /// <param name="conn">数据库连接对象</param> 307 /// <param name="trans">事务对象</param> 308 /// <param name="cmdtype">command类型</param> 309 /// <param name="cmdtext">oracle存储过程名称或pl/sql命令</param> 310 /// <param name="cmdparms">命令参数集合</param> 311 private static void preparecommand(oraclecommand cmd, oracleconnection conn, oracletransaction trans, commandtype cmdtype, string cmdtext, oracleparameter[] cmdparms) 312 { 313 if (conn.state != connectionstate.open) 314 conn.open(); 315 316 cmd.connection = conn; 317 cmd.commandtext = cmdtext; 318 319 if (trans != null) 320 cmd.transaction = trans; 321 322 cmd.commandtype = cmdtype; 323 324 if (cmdparms != null) 325 { 326 foreach (oracleparameter parm in cmdparms) 327 cmd.parameters.add(parm); 328 } 329 } 330 331 /// <summary> 332 /// 将.net日期时间类型转化为oracle兼容的日期时间格式字符串 333 /// </summary> 334 /// <param name="date">.net日期时间类型对象</param> 335 /// <returns>oracle兼容的日期时间格式字符串(如该字符串:to_date('2007-12-1','yyyy-mm-dd'))</returns> 336 public static string getoracledateformat(datetime date) 337 { 338 return "to_date('" + date.tostring("yyyy-m-dd") + "','yyyy-mm-dd')"; 339 } 340 341 /// <summary> 342 /// 将.net日期时间类型转化为oracle兼容的日期格式字符串 343 /// </summary> 344 /// <param name="date">.net日期时间类型对象</param> 345 /// <param name="format">oracle日期时间类型格式化限定符</param> 346 /// <returns>oracle兼容的日期时间格式字符串(如该字符串:to_date('2007-12-1','yyyy-mm-dd'))</returns> 347 public static string getoracledateformat(datetime date, string format) 348 { 349 if (format == null || format.trim() == "") format = "yyyy-mm-dd"; 350 return "to_date('" + date.tostring("yyyy-m-dd") + "','" + format + "')"; 351 } 352 353 /// <summary> 354 /// 将指定的关键字处理为模糊查询时的合法参数值 355 /// </summary> 356 /// <param name="source">待处理的查询关键字</param> 357 /// <returns>过滤后的查询关键字</returns> 358 public static string handlelikekey(string source) 359 { 360 if (source == null || source.trim() == "") return null; 361 362 source = source.replace("[", "[]]"); 363 source = source.replace("_", "[_]"); 364 source = source.replace("%", "[%]"); 365 366 return ("%" + source + "%"); 367 } 368 #endregion 369 } 370 }
- 写几个和oracle交互的函数;
1 [webmethod(description = "测试数据库连接,无输入参数,返回bool类型true或者false")] 2 public bool checkoraconnect() 3 { 4 return oraclehelper.checkoracleconnect(); 5 } 6 7 [webmethod(description = "输入日期型参数,返回string类型周别")] 8 public string getweek(string sdate) 9 { 10 try 11 { 12 // 创建参数对象 13 oracleparameter[] param = new oracleparameter[] { new oracleparameter(":date1", oracledbtype.varchar2) }; 14 param[0].value = sdate; 15 // 返回 datatable转换成string; 16 dataset ds = new dataset(); 17 ds = oraclehelper.executedataset(oraclehelper.oraconnstr, commandtype.text, commonsql.sqlgetweek, param); 18 if (ds.tables.count > 0 && ds.tables[0].rows.count > 0) 19 { 20 return ds.tables[0].rows[0][0].tostring(); 21 } 22 else 23 { 24 return "not found"; 25 } 26 } 27 catch (exception ex) 28 { 29 return ex.tostring(); 30 } 31 32 }
- 配置web.config(添加一段,解决“测试窗体只能用于来自本地计算机的请求”的异常)
1 <webservices> 2 <protocols> 3 <add name="httpsoap"/> 4 <add name="httppost"/> 5 <add name="httpget"/> 6 <add name="documentation"/> 7 </protocols> 8 </webservices>
项目发布
- 生成-发布;
- 编辑-文件系统;
- 选择保存,记住的文件名名称,我这里是publish;
- 发布。
项目部署
- 将publish文件复制到windowsserver 2012 r2 上指定的路径下;
- 打开iis管理器;
- 添加应用池,注意这里的.net clr版本需要与webservice服务.net版本一致;
- 添加网站(修改端口,避免端口冲突);
- 设定默认文档(添加默认文档、设定文件夹权限),如下图。
网站部署测试
选中网站,右键管理网站,选中浏览,出现如下图。
测试一下
=========================================================================================
作者:jeremy.wu
出处:
本文版权归作者和博客园共有,欢迎转载【点赞】,转载请保留此段声明,且在文章页面明显位置给出原文连接,谢谢。
上一篇: Django之图书管理系统
下一篇: 博客开通第一天