数据专栏

智能大数据搬运工,你想要的我们都有

科技资讯:

科技学院:

科技百科:

科技书籍:

网站大全:

软件大全:

HDC调试需求开发(15万预算),能者速来!>>> dwz框架多层弹出框口,为什么第二层会在第一次的后面,怎么把第二层(新打开的)窗口 顶在最前面来 我的使用方法是:查找带回的方式打开第一个窗口: 使用js的方式打开第二层窗口: 结果是(第二层的窗口跑后面去了,要疯): 网上的资料也比较少,有哪位大神知道啊
来源:开源中国
发布时间:2016-11-30 14:15:00
HDC调试需求开发(15万预算),能者速来!>>> 找了很久毫无进展 请问下各路大神 到底是怎么回事 用火狐 ie 都一样
来源:开源中国
发布时间:2016-08-21 14:00:00
HDC调试需求开发(15万预算),能者速来!>>> 打开dialog时分页是好的,dialog上嵌套了一个form查询,查询返回来的json数据也是对的,但是分页这个查询结果时,翻页的是dialog查询之前的数据,请问怎么解决这个返回结果的分页。
...
显示 条,共${pager.totalRow}条
来源:开源中国
发布时间:2016-08-11 16:14:00
HDC调试需求开发(15万预算),能者速来!>>> 项目中发现使用HTTPClient的PostMethod方法有乱码,尝试使用 postMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "utf-8" ); client.getParams().setContentCharset("UTF-8"); client.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8"); 以上都无效的情况下可以在参数Part对象中设置编码:new StringPart(key,value, "utf-8");
来源:开源中国
发布时间:2011-12-16 14:39:01
HDC调试需求开发(15万预算),能者速来!>>> 目前我有个httpClient解析url的代码,大部分情况下都正常,但是偶尔会出现下面的报错 org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 35499; received: 18409 这个我大概知道是因为服务端发送的是35499字节内容,但是实际客户端只接收到18409字节内容,没接收完连接就关闭了,这种情况一般是什么原因引起的,有人知道么,或者是我需要在httpClient解析的时候加上什么属性设置?我有关闭连接的操作,是否可以判断接收完成再关闭连接的设置? 主要代码如下
来源:开源中国
发布时间:2016-10-28 13:26:07
HDC调试需求开发(15万预算),能者速来!>>> 写了一个rest接口,接口接受json数据解析批量入索引。入索引的频率和大都挺大的,每天看日志都会有几条写入失败,原因是收到client端的数据不完整,是一个被截断的json。如图: 我是通过httprequest的getInputStream自己解析的,解析出来就成这个样子了。长度我也记录了一下,65k多,不可能是超过tomcat接受post请求体大小限制导致的,maxPostSize我配置了50M。 客户端使用httpclient传输的,一开始担心是客户端的问题,我在客户端做了json校验,但凡客户端不是json格式直接返回失败抛出异常,但是产生这条日志的时候,客户端并没有抛异常。而且客户端是把json字符串封装成一个实体作为api,然后再反序列化成字符串传输的,如果是使用者字符串拼的有问题,肯定会在前端先报错。 那么问题就集中在服务端了,到底还有什么限制会导致服务端接受数据不全吗?我还想到一种可能,就是数据再到达我这里的时候中间经历过三次json序列化和反序列化:业务数据序列化成埋点json字符串,消费端接受mq中埋点信息反序列化成实体,通过client api序列化成json字符串传输到tomcat,几次解析都使用fastjson,所以会不会是几次解析使用的版本不一样导致的呢?tomcat用的1.2.7 client用的1.2.9
来源:开源中国
发布时间:2017-12-19 11:37:02
HDC调试需求开发(15万预算),能者速来!>>> 有人对HttpClient这块比较熟悉的嘛,最近用了腾讯的一个sdk(什么功能我就不说了)。问题来了,偶尔会出现java.net.UnknownHostException: api.weixin.qq.com。有经验的大牛,谈谈这是为啥?或者有什么建议
来源:开源中国
发布时间:2017-11-23 17:31:00
HDC调试需求开发(15万预算),能者速来!>>> 本软件可以实现WEB端控制手机,搭建WEB端服务亲等。 我只学过JavaWEB,Servlet,但是这个不是Servlet,请问怎么向浏览器输出Html。 怎么在红色部分输出html。 /* * Copyright © Yan Zhenjie. All Rights Reserved * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.yanzhenjie.andserver.sample.response; import android.os.Environment; import com.yanzhenjie.andserver.RequestHandler; import com.yanzhenjie.andserver.upload.HttpFileUpload; import com.yanzhenjie.andserver.upload.HttpUploadContext; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.FileItemFactory; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.http.HttpEntityEnclosingRequest; import org.apache.http.HttpException; import org.apache.http.HttpRequest; import org.apache.http.HttpResponse; import org.apache.http.entity.StringEntity; import org.apache.http.protocol.HttpContext; import java.io.File; import java.io.IOException; import java.util.List; import javax.servlet.*; import javax.servlet.http.*; /** *

Upload file handler.

* Created by Yan Zhenjie on 2016/6/13. */ public class RequestUploadHandler extends HttpServlet implements RequestHandler { @Override public void handle(HttpRequest request, HttpResponse response, HttpContext context) throws HttpException, IOException { // HttpFileUpload.isMultipartContent(request) // DELETE、PUT、POST method。 String str = ""; if (!HttpFileUpload.isMultipartContentWithPost(request)) { // Is POST and upload. response(403, "You must upload file." + str, response); /* 这里怎么向浏览器输出Html,显示button按钮?*/ /* 这里怎么向浏览器输出Html,显示button按钮?*/ /* 这里怎么向浏览器输出Html,显示button按钮?*/ /* 这里怎么向浏览器输出Html,显示button按钮?*/ /* 这里怎么向浏览器输出Html,显示button按钮?*/ /* 这里怎么向浏览器输出Html,显示button按钮?*/ } else { // File save directory. final File saveDirectory = Environment.getExternalStorageDirectory(); if (saveDirectory.isDirectory()) { try { processFileUpload(request, saveDirectory); response(200, "Ok.", response); } catch (Exception e) { e.printStackTrace(); response(500, "Save the file when the error occurs.", response); } } else { response(500, "The server can not save the file." + str, response); } } } private void response(int responseCode, String message, HttpResponse response) throws IOException { response.setStatusCode(responseCode); response.setEntity(new StringEntity(message, "utf-8")); } /** * Parse file and save. * * @param request request. * @param saveDirectory save directory. * @throws Exception may be. */ private void processFileUpload(HttpRequest request, File saveDirectory) throws Exception { FileItemFactory factory = new DiskFileItemFactory(1024 * 1024, saveDirectory); HttpFileUpload fileUpload = new HttpFileUpload(factory); // Set upload process listener. // fileUpload.setProgressListener(new ProgressListener(){...}); List fileItems = fileUpload.parseRequest(new HttpUploadContext((HttpEntityEnclosingRequest) request)); for (FileItem fileItem : fileItems) { if (!fileItem.isFormField()) { // File param. // Attribute. // fileItem.getContentType(); // fileItem.getFieldName(); // fileItem.getName(); // fileItem.getSize(); // fileItem.getString(); File uploadedFile = new File(saveDirectory, fileItem.getName()); // 把流写到文件上。 fileItem.write(uploadedFile); } else { // General param. String key = fileItem.getName(); String value = fileItem.getString(); } } } }
来源:开源中国
发布时间:2017-11-16 15:00:00
HDC调试需求开发(15万预算),能者速来!>>> 由于项目需要回调不同用户的接口,可能会有很多不同的ip,那么使用httpClient 的连接池只是省去了握手,那么像我这种情况是不是使用与不使用性能是不是差不多呢?
来源:开源中国
发布时间:2017-08-28 10:38:00
HDC调试需求开发(15万预算),能者速来!>>> [14/01/03 09:42:53:942][org.apache.commons.httpclient.HttpClient-] Java version: 1.6.0_37[14/01/03 09:42:53:973][org.apache.commons.httpclient.HttpClient-] Java vendor: Sun Microsystems Inc. [14/01/03 09:42:53:973][org.apache.commons.httpclient.HttpClient-] Java class path: XMLSignatureFactory; [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "3" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "3" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\r]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\n]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "{"infocode":"000000","infotext":"","result":"true"}" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\r]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\n]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "0" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\r]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\n]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\r]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\n]" [14/01/03 09:42:54:286][org.apache.commons.httpclient.Wire-wire] << "[\r][\n]" 怎么设置可以不让他打印这些
来源:开源中国
发布时间:2014-01-03 09:44:00
HDC调试需求开发(15万预算),能者速来!>>> 整个项目使用一个CloseableHttpClient实例是否适合,高并发情况下是否会响应数据混淆,希望高手赐教
来源:开源中国
发布时间:2015-08-07 17:04:00
HDC调试需求开发(15万预算),能者速来!>>> //简化代码如下,手打的有点乱 new Thread(public run(){ while(isOK){ HttpGet get=newHttpGet("http://test.get.com"); response = httpClient.execute(get); test1 = EntityUtils.toString(response.getEntity()); for(i;i paramMap=newHashMap(); paramMap.put("ie","utf-8"); paramMap.put("kw", postName); // ......... response = httpClient.execute(post);//第一次循环可以执行到这一句,然后一直卡死在此处. } else{ system.out.println("未查找到数据,等待下次刷新数据"); } } } } ).star() //请问各位大神这是怎么回事啊,只能循环post提交一次,第二次就卡在代码注释处不动,也不报错 //网上查过好像说是execute阻塞,但是没找到方法解决,有人遇到过吗
来源:开源中国
发布时间:2016-05-05 11:10:00
HDC调试需求开发(15万预算),能者速来!>>> 我们网站大部分功能是通过HttpClient获取其他接口提供的内容,但每隔一两天就会出现访问卡死,设置了超时时间,也无限卡死,经断点查看,是卡在closeableHttp.execute(request);开始执行这行代码后就卡死了,不报错,也不执行结束。 以下是完整代码,已查阅过相关doc,实在解决不了了, 大家帮忙看下是哪里写的不对? 非常感谢 public String getContent(String url, int timeOut) { HttpClientBuilder httpBuilder = HttpClientBuilder.create(); if (timeOut > 0) { RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(timeOut).setConnectTimeout(timeOut).setSocketTimeout(timeOut).build(); httpBuilder.setDefaultRequestConfig(requestConfig); } CloseableHttpClient closeableHttp = httpBuilder.build(); HttpGet request = new HttpGet(url); CloseableHttpResponse response = null; try { response = closeableHttp.execute(request); HttpEntity entity = response.getEntity(); return entity == null ? null : EntityUtils.toString(entity, CharacterSet.UTF8); } catch (Exception e) { e.printStackTrace(); return null; } finally { try { if (request != null) { request.abort(); } if (response != null) { response.close(); } closeableHttp.close(); } catch (IOException e) { e.printStackTrace(); } } }
来源:开源中国
发布时间:2015-06-24 11:09:00
HDC调试需求开发(15万预算),能者速来!>>> 会使用lambda,但是不清楚上面有什么用
来源:开源中国
发布时间:2017-02-15 09:32:00
HDC调试需求开发(15万预算),能者速来!>>> 有两个窗体form1为登录界面,进入form2,如果在form2中要显示登录人的全部信息,如何获取登录界面的登录编号??如果要修改此登录人的密码,在textbox中写好如何对应此登录人并写入数据库??谢谢
来源:开源中国
发布时间:2017-12-27 10:46:00
HDC调试需求开发(15万预算),能者速来!>>> 为什么第三个文件和其他的前面不一样,都是在SVN上下下来的
来源:开源中国
发布时间:2017-02-15 14:30:00
HDC调试需求开发(15万预算),能者速来!>>> @汪宪博 你好,想跟你请教个问题: 看到您之前在OS上也问过同样的问题,那就是 “C#如何调用ffmpeg并使用他处理视频?” 目前我也是要利用C#调用FFMpeg来实现 视频截图 和 视频分割 功能,ffmpeg上已经实现了我所说那两个功能,并且我也亲自运行成功,但是我打算不使用命令行的方式,而是用自己做好的前台图形界面(比如一个slider)来达到同样的功能。换句话说,我想借鉴ffmpeg的实现思路,但并不想通过命令行的方式,而是用自己的图形界面实现视频截图和视频分割功能,那么我该如何从ffmpeg入手呢? 是不是我应该定位到ffmpeg中源代码中,查看实现该功能处的程序段,然后对这部分程序段进行相应的修改呢? 请问应该如何使用sharp-ffmpeg提供的dll呢? 刚刚接触多媒体不久,对ffmpeg了解也是甚浅,还希望提的这些问题您不要见笑,也希望您能给予回答和指点,在些表示感谢。
来源:开源中国
发布时间:2013-04-02 13:26:00
HDC调试需求开发(15万预算),能者速来!>>> 我原本使用以下方法讀取資料 (可以一直讀取,例如傳送01 02 03 04 05,可以成功接收 01 02 03 04 05) serialPort1.Open(); serialPort1.DataReceived+=new SerialDataReceivedEventHandler(port_DataReceived); private void port_DataReceived(object sender, SerialDataReceivedEventArgs e) { int data = serialPort1.ReadByte(); //....... //....... } 可是改用以下方法就只能讀取一組資料,之後就都不再讀取了 (例如傳送01 02 03 04 05,只接收01 ,就沒再動作了,請問一下有辦法一直接收嗎?) Thread t; serialPort1.Open(); t = new Thread(port_DataReceived); t.Start(); private void port_DataReceived() { int data = serialPort1.ReadByte(); //....... //....... }
来源:开源中国
发布时间:2017-03-22 20:52:00
HDC调试需求开发(15万预算),能者速来!>>> @杨尚川 你好,想跟你请教个问题:termb.dll及HWControl.dll 能不能分享给大家! 谢谢!
来源:开源中国
发布时间:2017-03-19 21:30:00
HDC调试需求开发(15万预算),能者速来!>>> C#如何设置程序远程连接电脑只读界面,而不能操作界面?如:按钮点击和数据库操作。
来源:开源中国
发布时间:2016-08-23 14:56:00
HDC调试需求开发(15万预算),能者速来!>>> 伪代码如下: array=new array(); while(true){ array.add(new Object); } 这段代码java 会在消耗完虚拟内存,就crash掉 c++会消耗掉系统的内存后crash掉 C#呢? C#的内存管理是什么样子的? C#的虚拟内存用完之后是不是能向系统动态申请内存?
来源:开源中国
发布时间:2016-12-09 18:04:00
HDC调试需求开发(15万预算),能者速来!>>> for(int i=0;i<3;i++) { type a=new type(); } 请问这段代码执行,a是不断更改指向的对象(例如按照循环假定三个type对象为type1,type2,type3,那么a从type1指到type3,然后gc自动回收type1、type2)还是自动指向先前已经指向的对象(type1、type2即三个type实则为同一个对象)?
来源:开源中国
发布时间:2016-11-30 19:35:00
HDC调试需求开发(15万预算),能者速来!>>> C#语言 最近做了个实战,实战里遇到个问题,想计算下每轮游戏时间差。一轮游戏后时间归零。我该用什莫方法??? 要类似java里的这个方法。谢谢。 各位大神!!!这个是我当前用的,可是有BUG 请大神指教!!!
来源:开源中国
发布时间:2016-11-27 21:01:00
HDC调试需求开发(15万预算),能者速来!>>> winform项目,现在要将列表导出到EXCEL中,需要按照要求导出,已经提供了模板,该怎么做?导出的数据存在多个表,哪位大神给些代码或者实例
来源:开源中国
发布时间:2016-06-15 17:12:00
HDC调试需求开发(15万预算),能者速来!>>> 左边的数据是从右边的DataGridView中取得的,为啥X轴不是递增啊
来源:开源中国
发布时间:2016-09-06 22:20:00
HDC调试需求开发(15万预算),能者速来!>>> 我用c#在winform中用chart控件做了一个饼图,但是饼图中的百分比显示有点问题,我想让它在饼图的中央显示,请问该怎么做?
来源:开源中国
发布时间:2016-08-17 20:49:00
HDC调试需求开发(15万预算),能者速来!>>> c#WPF中TextBox控件设置进为只读后,想要复制他的内容,该怎么做? 求大神们解答
来源:开源中国
发布时间:2016-07-29 11:29:00
HDC调试需求开发(15万预算),能者速来!>>> 网络传输基础构建使用的是《通用数据传输构架》 http://git.oschina.net/dreamsfly900/universal-Data-Communication-System-for-windows 有很多示例可参考
来源:开源中国
发布时间:2016-07-06 10:48:00
HDC调试需求开发(15万预算),能者速来!>>> using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; using StudentManager.com.huixin.util; using System.Collections; using System.Data.ProviderBase; using SQLDMO; using System.Data.SqlClient; namespace StudentManager { public partial class DataSourceConfig : Form { //连接数据库的类型 private String sqlConType = ""; public DataSourceConfig() { InitializeComponent(); } //配置数据库链接的窗体关闭时,打开相对应登录窗体 private void DataSourceConfig_FormClosed(object sender, FormClosedEventArgs e) { try { //杀死进程 //System.Diagnostics.Process.GetCurrentProcess().Kill(); //关闭当前窗体 //终止当前进程并为基础操作系统提供指定的退出代码 //System.Environment.Exit(System.Environment.ExitCode); this.Dispose(); this.Close(); //打开登录窗体 LoginForm lf = new LoginForm(); lf.Show(); // LoginForm.loginFrm.Show(); } catch (Exception ex) { Console.WriteLine("连接数据的窗体进程出错了:" + ex.Message); } } //显示组合框的下拉部分时发生 private void comboBox1_DropDown(object sender, EventArgs e) { this.comboBox1.DataSource = SqlLocator.GetLocalSqlServerNamesWithSqlClientFactory(); this.comboBox1.DisplayMember = "ServerName"; } //当用户点击刷新按钮时,将局域网内服务器和实例名给comobox private void button1_Click(object sender, EventArgs e) { this.comboBox1.DataSource = SqlLocator.GetLocalSqlServerNamesWithSqlClientFactory(); this.comboBox1.DisplayMember = "ServerName"; } //在窗体加载时,将Sql Server按钮以及和他相关两个文本框禁用 private void DataSourceConfig_Load(object sender, EventArgs e) { //Windows的按钮默认被选中 this.radioButton1.Select(); this.textBox1.Enabled = false; this.textBox2.Enabled = false; } private void radioButton1_Click(object sender, EventArgs e) { if (this.radioButton1.Checked == true) { sqlConType = "0"; } } private void radioButton2_CheckedChanged(object sender, EventArgs e) { if (this.radioButton2.Checked == true) { sqlConType = "1"; this.textBox1.Enabled = true; this.textBox2.Enabled = true; } } //3.点击数据库链接时显示时,组合框的下拉部分时发生 private void comboBox2_DropDown(object sender, EventArgs e) { //通过第一步输入的服务器实例名,从而找到步骤三中的数据库 //通过判断用户点击的属于哪一种数据库连接方式,从而判断采用什么方法 if (sqlConType == "0") { //用户选择的是Windows方式 this.comboBox2.DataSource = GetDataBaseList(this.comboBox1.SelectedItem.ToString()); this.comboBox2.DisplayMember = ""; } else if (sqlConType == "1") { //用户选择了Sql Server方式 this.comboBox2.DataSource = GetDataBaseList(this.comboBox1.SelectedItem.ToString(),this.textBox1.Text.Trim().ToString(),this.textBox2.Text.Trim().ToString()); this.comboBox2.DisplayMember = ""; } } //得到指定SQL服务器所有数据库的列表 //这种输入Sql Server模式,需要用户名和密码 public ArrayList GetDataBaseList(string ServerName, string UserName, string Pwd) { //一般使用SQLDMO,只能用于sql server2005一般的版本 ArrayList list = new ArrayList(); SqlConnection conn = new SqlConnection("Uid=" + UserName + ";Pwd=" + Pwd + ";Data Source=SQL2012;Integrated Security=false;"); ; SqlCommand cmd = new SqlCommand("select name from sys.databases where database_id > 4", conn); ; try { if (conn.State == ConnectionState.Closed){ conn.Open(); SqlDataReader dr = cmd.ExecuteReader(); while (dr.Read()) { list.Add(dr[0]); } } } catch (Exception ex) { MessageBox.Show(ex.Message); } finally { if (conn != null && conn.State == ConnectionState.Open) { conn.Close(); conn.Dispose(); //释放资源 } } /** SQLDMO.Application sqlApp = new SQLDMO.Application(); SQLDMO.SQLServer oServer = new SQLDMO.SQLServer("Data Source="+ServerName+";Persist Security Info=True;UID="+UserName+";PWD="+Pwd+""); oServer.Connect(ServerName,UserName,Pwd); foreach (SQLDMO.Database db in oServer.Databases) { if ((db.Name != null) && (db.SystemObject == false)) { list.Add(db.Name); } } **/ return list; } //这种属于Windows方式 //此时链接数据库时,需要加integrated security=SSPI public ArrayList GetDataBaseList(string ServerName) { //一般使用SQLDMO,只能用于sql server2005一般的版本 ArrayList list = new ArrayList(); SqlConnection conn = new SqlConnection("Data Source=" + ServerName + ";Integrated Security=SSPI;Initial Catalog=mwyqms_2016-03-25"); SqlCommand cmd = new SqlCommand("select name from sys.databases where database_id > 4", conn); ; try { if (conn.State == ConnectionState.Closed) { conn.Open(); SqlDataReader dr = cmd.ExecuteReader(); while (dr.Read()) { list.Add(dr[0]); } } } catch (Exception ex) { MessageBox.Show(ex.Message); } finally { if (conn != null && conn.State == ConnectionState.Open) { conn.Close(); conn.Dispose(); //释放资源 } } return list; } } } 第1步可以获取所有区域网内的服务器名,但是第三步骤无法从特定的服务器名下,通过用户名和密码,得到数据库 代码:
来源:开源中国
发布时间:2016-07-03 10:46:00
HDC调试需求开发(15万预算),能者速来!>>> 本人新手,老师要求用VS2010的C#打开DXF文件,在网上找到许多例子,都不全,有大神分享下么?跪求啦
来源:开源中国
发布时间:2016-06-15 15:15:00
HDC调试需求开发(15万预算),能者速来!>>> 为什么我的程序对文件的读操作只能在控制台显示英文,而文件中的汉字不能正确显示,应该改哪里,好像是编码的事,但不知道怎么改。C#
来源:开源中国
发布时间:2011-03-21 19:25:00
HDC调试需求开发(15万预算),能者速来!>>> 查询了许多资料 都是使用PerformanceCounter来获取进程使用率的 但是在多个进程名字一样的情况下 会出现获取错误的情况 所以 想询问下如何使用Process来获取进程的CPU使用率 谢谢
来源:开源中国
发布时间:2014-11-16 15:03:00
HDC调试需求开发(15万预算),能者速来!>>> 我发现KafkaTemplate 和 KafkaProperties 都没有关于设置P artitioner的地方? 也搜不到; 难道只能用Properties.put ()这样原始的方式吗?
来源:开源中国
发布时间:2019-12-08 12:10:00
HDC调试需求开发(15万预算),能者速来!>>> 关于kafka重复消费的问题你们是怎么解决的?我看网上说引入第三方中间键redis, 每次消费前先判断该消息是否存在Redis, 没有则进行消费, 消费完再将该条记录的唯一标识存入Redis中。 重复消费是因为业务处理完后偏移量修改失败的导致的, 但是引入Redis的也话会出现Redis写失败啊, 问题就没解决啊
来源:开源中国
发布时间:2019-11-27 11:04:03
HDC调试需求开发(15万预算),能者速来!>>> sparkstreaming的kafka接口,使用高级接口好还是使用低级接口?管理kf偏移量
来源:开源中国
发布时间:2019-12-02 13:31:00
HDC调试需求开发(15万预算),能者速来!>>> 请问Kafka怎么实现延时消息,用于做定时器,网上一堆写的都是时间轮什么的,有没有大神给个实例,或者给一个实现思路也行
来源:开源中国
发布时间:2019-01-25 09:50:00
HDC调试需求开发(15万预算),能者速来!>>> 2019-10-12 17:47:37.535 [kafka-producer-network-thread | producer-1] WARN NetworkClient - [Producer clientId=producer-1] Connection to node -2 terminated during authentication. This may indicate that authentication failed due to invalid credentials
来源:开源中国
发布时间:2019-10-12 17:49:00
HDC调试需求开发(15万预算),能者速来!>>> 有没有老哥推荐一个带可视化界面的定时任务框架?java的,其他我看c#有一个做的挺好的,但是好像java用不了。。。。
来源:开源中国
发布时间:2018-11-07 16:40:00
HDC调试需求开发(15万预算),能者速来!>>> 现在业务是这个样子的,有两台服务器,若干个定时任务,某些定时任务只需要有一个服务器执行就行了,另一些定时任务是所有服务器都要跑的。 现在quartz实现了前者,能够做任务调度,后者用的是java自带的Timer类实现的。 问:如何用quartz通过配置或其它的方法同时实现这两个需求
来源:开源中国
发布时间:2019-10-30 18:04:00
HDC调试需求开发(15万预算),能者速来!>>> 采用sqlserver数据库 整合之后发现启动报错FOR UPDATE clause allowed only for DECLARE CURSOR,找了下原因说是quartz要使用游标,sqlserver默认是不打开游标的,需要在链接URL上加上SelectMethod=cursor,我使用了 com.microsoft.sqlserver.jdbc.SQLServerDriver jdbc:sqlserver://127.0.0.1:51013;SelectMethod=cursor;DatabaseName=AAA 这样没问题了,但现在使用 net.sourceforge.jtds.jdbc.Driver 驱动 jdbc:jtds:sqlserver://127.0.0.1:51013;DatabaseName=AAA;SelectMethod=cursor 加上SelectMethod=cursor还是报这个错,有必要用jtds的理由,请问这种情况怎么解决
来源:开源中国
发布时间:2019-10-15 14:51:00