有人能解释一下DIH是如何处理并发的吗？
我已经设置了Apache数据源，并且需要通过向MySql Stanbol增强服务器发送字段值来对导入的数据进行一些自定义处理。我通过在数据端口(onImportEnd)的末尾配置一个自定义EventListener来实现这一点。
在数据迁移过程中，我将每个文档的字段值复制到我的StanbolEventListener和onImportEnd中的静态映射中，并将它们发送到Stanbol进行增强。
我需要在这个过程中处理并发。需要使我的Map线程安全。为此，我需要了解在DIH中是如何处理并发的。
出于测试目的，我为文档0-100发出了一个/dataimpo
浏览 0提问于2014-02-01得票数 2
1回答
我最近开始在Java中学习Java，我发现我不必担心关闭每个查询的连接，就像我们为Mysql和其他sql database所做的那样。
我想知道，MongoDB java driver如何管理每个请求的连接？他们在java驱动程序中负责吗？
浏览 3提问于2014-08-16得票数 2
回答已采纳
1回答
我目前正在使用以下代码连接到mysql数据库，但项目经理指出我必须使用Spring框架来处理连接。
我怎样才能做到这一点呢？
使用Spring处理数据库连接会提高整个系统的质量吗？
下面是这个类的一个示例
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
import java.sql.DriverManager;
import java.sql.ResultSet;
public class SomeClass {
Connection connection = null;
ResultSet
浏览 1提问于2012-06-02得票数 0
回答已采纳
1回答
连接云SQL时出错
、、、、
我正在尝试使用Google App Engine连接到Google的Cloud SQL Server。我已经授权了自己的IP，可以使用MySQL工作台连接到云SQL实例。
public static Connection connect(){
if (SystemProperty.environment.value() ==
SystemProperty.Environment.Value.Production) {
// Connecting from App Engine.
// Load the class that provide
浏览 1提问于2014-11-11得票数 0
1回答
连接MySQL C连接器？
、、、、
我正在编写一个C++程序，使用visual 2012、x64发布模式、多线程运行时库。我的项目还包含链接的boost 1.55.0库。
我试图以某种方式获得MySQL C连接器( C++连接器编写得很差，所以我决定使用C)工作。它可以工作，但我正经历随机崩溃和搜索后，我相信MySQL C连接器没有正确地链接。
我试过的是：
( a)我为windows加载了二进制x64，并将其包含在库目录：mysql-connector-c-6.1.3-winx64\lib\vs11中。我还添加了附加的依赖项mysqlclient.lib。
( b)我下载了源代码，并使用以下方法编译：
cd C:\Users\
浏览 2提问于2014-02-13得票数 0
回答已采纳
我的java应用程序只在客户平台上运行缓慢(数据很少)。在开发和集成环境中，它的速度非常快(数据量增加了10倍)。
我使用Yourkit分析器找出了原因。原来MySQL的驱动程序每次打开准备好的语句花费大约250ms (同样的操作在我们的内部环境中是即时的)
com.mysql.jdbc.ConnectionImpl.prepareStatement(String, int, int) ConnectionImpl.java
com.mysql.jdbc.ConnectionImpl.prepareStatement(String) ConnectionImpl.java:4077
com.m
浏览 2提问于2014-10-21得票数 0
1回答
我正在进行客户机/服务器套接字编程。Android客户端和Java在我的笔记本电脑上。我想通过套接字将几幅图像从Android设备发送到Java服务器，该服务器将每个映像保存在MySQL数据库中作为blob。我关闭每个图像传输的客户端套接字，并为下一个图像传输重新连接。
我的第一个图像传输很好，并且保存在MySQL数据库中，但是当我尝试重新连接套接字到服务器并传输不同的映像时，我会得到连接重置。
java.sql.SQLException: Error reading from InputStream java.net.SocketException
at com.mysql.jdbc
浏览 4提问于2014-04-05得票数 0
2回答
有一个MySQL数据库，需要处理的记录为+800万条(这在数据库本身中是无法处理的)，当我试图将它们读入我的Java应用程序时，我会遇到一些问题。
我已经尝试过一些类似问题的解决方案(例如，)，但是没有一个解决方案适合我。我试图设置FetchSize和所有，但没有运气！我的应用程序是使用BlockingQueue构建的，生产者可以从数据库中连续读取数据，并将其存储在队列中，这样消费者就可以对其进行处理。这样，我就可以同时限制主内存中的记录数量。
我的代码适用于少量的记录(我测试了1000条记录)，因此我建议需要修复从数据库到应用程序的fase。
Edit1
connection = Conne
浏览 9提问于2014-03-17得票数 2
3回答
我正在尝试使用多个线程更新表。但我不会同时更新相同的记录/行。我正在将表分组到不同的组中，并尝试同时更新它们。但是，我一直收到锁定超时错误。
我使用Hibernate、Spring MVC、ThreadPoolTaskExecutor和MySQL。我正在从另一个DB模式获取数据，并更新我自己的数据库。数据是巨大的，这就是为什么我想使用多线程，这样可以更快地完成。但是，它会产生“锁定超时”错误。有谁能帮帮忙吗？谢谢你的好心。
我调用sessionFactory.getCurrenSession()来更新数据库表。
下面是我的配置：
<bean id="dataSource"
浏览 1提问于2015-09-29得票数 3
2回答
以下是我对Java线程在运行在现代OS实现(如solaris 9)上运行的start() api的java.lang.Thread类调用上启动线程时的计划的理解。
使用术语LWP，因为在内核编程中通常使用术语kernel thread来启动线程。
因此，在POSIX、Solaris、java.lang.Thread::start()平台上，使用java.lang.Thread::start() api创建的每个native thread都有1:1的映射，native thread的创建分别使用pthread_create()、thr_create()或CreateThread()。在转弯
浏览 4提问于2014-12-05得票数 3
我希望在tomcat外部部署一个spring引导web应用程序，但是错误，我无法修复它。请帮帮我，非常感谢。
application.properties
server.port=8080
spring.datasource.url=jdbc:mysql://localhost:3306/springboot?useUnicode=yes&characterEncoding=UTF-8&useSSL=false&allowPublicKeyRetrieval=true
spring.datasource.username=root
spring.datasource.p
浏览 0提问于2019-01-14得票数 0
回答已采纳
我正在开发一个桌面软件，它收取用户每次执行的主要行动。例如，它将向用户收取每次PDF打印0.1美元的费用。
我的软件提供了多线程。。
因此，如果它运行单线程，它工作得很好:)
但问题是如果用户同时运行多个线程(比如10/20个线程)
它(php)还允许用户允许服务器/执行余额为零..
通过我的php脚本检查balance是否为正..
但在用户运行后，多线程平衡变为-5.95$或-25.75$等
这是一个很大的安全/财务问题..
下面是我使用的代码：
<?php
$strSQL = "Select * from users where Email = '$strUser&
浏览 0提问于2013-11-04得票数 0
Js是单线程的，所以我有车辆连接到socket io，这样这些车辆就可以每秒钟或更短的时间发送位置，并用它更新MySQL和一些东西，哪种更好的方法来处理这些重负荷的事情？就像Node.Js应该是单线程的，而且我在同一个Node.Js进程中有很多东西，所以我认为它可能是坏的？Python更好吗？就像有2个服务器、1个节点、2个python一样，我不知道该做什么，哪个更好？如果我没有提到的东西比这些要好的话，请像java那样提一下，或者有什么想法吗？
浏览 7提问于2020-11-12得票数 0
回答已采纳
我想对android活动执行junit测试。
现在我在Thumb Project中有了名为Thmnail.java的活动，现在我创建了名为ThumbTest的测试项目，并在从ThmnailTest调用Thmnail的方法时将测试类设置为ThmnailTest
getSetTagName(tagId，R.id.edTag11)；
上面所说的tagid是传递的，但R.id.edTag11是AutoCompleteTextView，它在缩略图中，它会给出错误
android.view.ViewRoot$CalledFromWrongThreadException:只有创建视图层次结构的原始线程才能接
浏览 1提问于2010-12-24得票数 0
1回答
我有一个PHP程序，它顺序地从MySQL数据库表中读取记录，向URL发送消息，然后使用响应中的信息更新表。
但是，按顺序一次一行地执行此操作非常慢。我是否可以在代码中使用多线程(PHP或Java)一次发送多条消息并更快地更新表？
浏览 3提问于2016-01-22得票数 0
回答已采纳
在这里提到的Java 8特性。我不能理解parallelSort()到底做了什么。有人能解释一下sort()和parallelSort()之间的实际区别吗
浏览 0提问于2018-10-31得票数 2
我在MYSQL中使用了一个表名"test“，它是在事务T1期间锁定的，它将在20分钟内完成。当我用另一个事务T2在这20分钟内更新这个表时。我有个例外：-
11:58:38,584 ERROR [STDERR] java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction
11:58:38,584 ERROR [STDERR] at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2928)
11:58:38,584 ERROR
浏览 0提问于2012-10-04得票数 1
回答已采纳
在从Java JDBC driver调用MySQL中的存储过程时，我偶尔会遇到一个奇怪的异常。我的应用程序代码如下所示：
int newID = 0;
if (myObj != null)
newID = myObj.getId(); //getId() returns an int value...
CallableStatement stmt = conn.prepareCall("{CALL MySP(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)}");
stmt.registerOutParamet
浏览 1提问于2013-04-03得票数 0
回答已采纳
1回答
我已经编写了一个复杂的java程序，我想要加载它。我该怎么做呢？
我尝试过设置JMeter，但感觉很糟糕:很难设置，文档很难理解。
我有什么可供选择的？
浏览 4提问于2016-12-24得票数 0
回答已采纳
我正在尝试构建一个示例应用程序，其中消息可以保存到数据库中，然后当websocket连接到保存这些消息的sessionId时，它们都会被发送出去。 下面是我的代码： Message.java
---
package org.acme.hibernate.orm.panache;
import java.util.Date;
import javax.persistence.Cacheable;
import javax.persistence.Entity;
import io.quarkus.panache.common.Sort;
import io.quarkus.hiberna
浏览 38提问于2021-07-13得票数 0
我正在尝试用Java构建分布式应用程序，我在这些领域做了大量的实践和研究。很多例子都很好用。这里的代码是针对服务器端的，当我通过cmd运行应用程序时，它没有任何问题，但是在它绑定服务之前，它会在2-4秒后关闭，因此客户端会给出一个"NOTBOUND异常“。最疯狂的一点是，同样的代码在anthor应用程序中运行得非常顺利。
这是我使用的所有代码
RInterface.java
package rmi;
import java.rmi.*;
public interface RInterface extends Remote {
public boolean log(String Unam
浏览 1提问于2015-04-19得票数 0
回答已采纳
我有一个用于多线程的静态HashMap<UUID, MyObject> ALL = new HashMap<>(); .
为了再现错误，我编写了以下代码：
HashMap<Integer, String> list = new HashMap<>();
list.put(1, "str 1");
list.put(2, "str 2");
new Thread(() -> {
while(true) {
ArrayList<String> val;
sy
浏览 4提问于2021-12-17得票数 -1
回答已采纳
1回答
我有以下一段代码，用于检查给定主机中的端口443是否打开。
import java.net.*;
import java.io.IOException;
public class Scan {
public static void main (String[] args) {
String host="put hostname here";
int port=443;
try{
Socket s = new Socket(host,port);
System.out.p
浏览 0提问于2012-07-04得票数 0
回答已采纳
1回答
我之前已经使用了几个连接池api，但我认为是时候自己做点什么了。我目前正在寻找一个非常基本的MySQL连接池功能，我可以在此基础上进行构建。如果你们能给我一个诚实的意见，我将不胜感激！
代码如下：
package temp.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class MySQL {
private static
浏览 0提问于2014-09-05得票数 0
2回答
我编写了下面的代码-我希望DataSource是一个单例，并使用enum成语作为单例。过了一段时间后，我得到了大量的Data source rejected establishment of connection, message from server: "Too many connections" --我的单例模式的实现是错误的还是原因在其他地方？
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
浏览 3提问于2012-09-22得票数 0
5回答
我目前正在做一个Java项目，我需要准备一个大的(对我来说) mysql数据库。我必须使用Jsoup进行web抓取，并将结果存储到我的数据库中。据我估计，我将插入大约1,500,000到2,000,000条记录。在我的第一次试验中，我只是使用循环来插入这些记录，我花了一周的时间来插入大约1/3的所需记录，我认为这太慢了。有没有可能让这个过程多线程，这样我就可以将我的记录分成3个集合，比如每个集合500,000条记录，然后将它们插入到一个数据库中(特别是一个表)？
浏览 3提问于2012-03-12得票数 5
1回答
MPP体系结构上的多线程应用
、、、、
简而言之：：
是否值得将多线程可伸缩性(垂直可伸缩性)添加到将始终运行在MPP基础设施(如串联HPNS (水平可伸缩性))中的应用程序？
现在，让我再深入一点：
我在许多地方见过使用Java的MPP (大规模并行处理)下的开发，通常认为，如果是Java，您可以使用Java提供的所有内容(您知道，编写一次运行在任何地方！)其中多线程库(如线程、AKKA、线程池等)通过使用并行性来提高性能，可以帮助很多人。
忘记了，如果它是MPP，它是水平可伸缩的，这意味着如果您需要一个更快的应用程序，您必须设计它来运行应用程序的多个副本，每个副本在一个不同的处理器上。
另一方面，我们有SMP (对称多处理)基础
浏览 1提问于2016-05-20得票数 0
回答已采纳
1回答
我已经配置了一个包含1个主服务器、1个备用服务器和1个从服务器的MySql复制。主备在美国东区不同的可用区，Slave在美国西区。Standby和Slave都是从Master复制的。
应用层可以执行从主服务器到Standby.For的故障转移，在主服务器死时将从服务器的复制切换到备用服务器。我无法保证与Slave的数据相比，备用服务器的数据是否在前面。如果Standby的数据在Slave的数据之后，我需要扫描Slave的二进制和中继日志，以找出丢失的内容，并将其传输到Standby。这就是理论。
有谁知道有什么工具可以处理这个问题吗？或者针对我的环境的替代解决方案？最终目标是为应用层提供MyS
浏览 2提问于2011-10-20得票数 1
回答已采纳
我是Java的初学者，我的问题是，如果我开发一个Java应用程序(使用Spring框架)，那么业务逻辑需要多方面的考虑吗？这样多人可以同时访问应用程序吗？
浏览 4提问于2013-08-01得票数 2
回答已采纳
我正在学习不同的一致性模式，比如严格/顺序/因果/最终的一致性。
我发现MySQL的主集群和从集群(使用InnoDB作为默认引擎)似乎是顺序一致性的一种实现: MySQL的主服务器通过全局事务ID定义事务更改的全局序列，并通过使用分组提交使Binlog和Redolog保持相同的顺序。
有人能帮我判断一下我理解的正确性吗？
浏览 0提问于2022-03-29得票数 3
4回答
我在一个托管小型Java应用程序的平台上工作，所有这些应用程序目前都使用单个线程，位于Docker引擎中，使用来自Kafka服务器的数据并记录到中央数据库。
现在，我需要将另一个Java应用程序放到这个平台上。手边的这个应用程序使用了大量的多线程，我已经在Docker容器中测试了它，它在那里工作得很好，所以我已经准备好将它部署到手动缩放的平台上，也就是说，有人会定义要启动的容器的数量，每个容器都包含这个应用程序的一个实例。
我的架构师有一个反对意见，他说“在分布式环境中，我们从不使用多线程”。因此，现在，我必须重构我的应用程序，消除其中任何与线程相关的逻辑，使其成为单线程。我要求他提供更详细的
浏览 1提问于2019-05-17得票数 3
1回答
下面是我用来将数据上传到MySQL的多线程脚本。使用线程来做多个插入，对我来说听起来不错。
但是没有性能上的提升。MySql被设置为接受多个连接，但是当我检查进程列表时，我没有看到我期望的5-10个连接。cxn字符串为
有没有办法解决这个问题？
import sys, threading, Queue pyodbc
class WorkerThread(threading.Thread):
def __init__(self, queue):
threading.Thread.__init__(self)
self.queue = queue
def run(self
浏览 0提问于2011-04-02得票数 4
我正在用Java编写一些程序，并且刚刚开始真正的多线程处理。我在玩线程计数，并意识到使用20个线程比使用8个线程要快，这就是我有多少物理+虚拟内核。
如果我的处理器中的每个内核一次只能处理一个线程，那么为什么使用20个线程比使用8个线程快呢？
浏览 0提问于2015-06-25得票数 4
回答已采纳
我是一个新手，用Java对csv文件做一些数据处理。为此，我使用Java (线程池)的多线程功能对csv文件进行批处理，并对它们的每一行进行一些操作。在我的四核上，多线程大大加快了进程。
，我很想知道多处理将如何/是否会更快地加快操作？如果有的话，是否有教程可供使用？( Java教程提到了一个类，但我对语法还不太熟悉，无法自己理解该类：
来自
Java虚拟机的大多数实现都是作为单个进程运行的。Java应用程序可以使用ProcessBuilder对象创建其他进程。多进程应用程序超出了本课的范围--，然后在哪里解释？。
浏览 3提问于2011-11-03得票数 22
回答已采纳
3回答
我当时正在读"Java并发在实践中“一书。在第二章，我读了这份声明。
任何单线程程序也是有效的多线程程序。
我不明白这句话。
请分享你对此的想法，这样我的困惑才能被消除。提前谢谢。
浏览 0提问于2017-03-08得票数 6
回答已采纳
我有10个文本文件，这些文本文件包含我想要插入到数据库中的xml。每个文件大小约为113 MB。在读取5-6个文件后，我得到了“java.io.IOException:流关闭”错误。下面是我的Spring批处理配置。你能建议我如何纠正这个问题吗？
<bean id="gimReader"
class="org.springframework.batch.item.file.MultiResourceItemReader"
scope="step">
<property name=&
浏览 3提问于2015-05-01得票数 0
1回答
我正在使用Java CommV3驱动程序来连接GSM调制解调器(华为E173)和Java应用程序。我正在尝试将一条文本消息转发给mySQL数据库中的几个号码。我总是收到一个PortInUseException。但是，使用相同的代码手动发送和接收消息效果非常好。我尝试过在消息之间使用最多15秒的延迟(在循环中)，但我仍然面临同样的问题。
这里我漏掉了什么？我们是否有用于将消息转发到多个号码的AT命令？有没有我应该注意的特殊延迟？
浏览 1提问于2013-03-18得票数 0
回答已采纳
1回答
我将在命令行中导入一个5 GB的表：
mysql -u dbuser -p customersdb < transactions.sql
以前，我导入了一个2GB文件，这导致复制延迟了很长一段时间。这里有什么可以避免的吗？不知何故，在我的脑海中，每隔几千次进口就增加一个超时似乎是理想的。
我尝试过搜索它，但似乎这个用例不经常出现。
编辑:另外，还有监控导入进程的方法吗？
浏览 2提问于2016-06-11得票数 1
回答已采纳
我正在用JMeter测试MQTT连接。
测试在非GUI模式下运行。在测试期间，所有侦听器都被禁用。
在我将线程数量从2k增加到3k之前，一切都很好。现在，当我运行测试时会发生此错误：
Uncaught Exception java.lang.OutOfMemoryError: unable to create new native thread. See log file for details.
我尝试通过编辑可执行文件“the”来增加堆的大小。
这是我怎么编辑的。我把它从512米改为1024米：
但不起作用。然后我换到了一个更大的价值2.048亿，仍然不起作用。
我搜索了这个问
浏览 3提问于2017-05-10得票数 0
Java类片段：
public static void main(String[] args) throws FileNotFoundException SQLException, ParseException {
TaskCheck tc = new TaskCheck();
if (args.length != 1)
{
System.err.println("Missing parameter. Please pass the task Name.");
System.exit(1);
}
else
浏览 4提问于2016-03-22得票数 1
回答已采纳
2回答
我在servlet的init()方法中初始化了一个Document对象，并在doPost()方法中使用它为请求提供服务。
当servlet服务同时有多个请求时，selectNodeList() xpath查询会出现异常。例外如下所示：
Caused by: javax.xml.transform.TransformerException: -1
at org.apache.xpath.XPath.execute(XPath.java:331)
at org.apache.xpath.CachedXPathAPI.eval(CachedXPathAPI.java:328)
浏览 1提问于2012-06-22得票数 0
回答已采纳
1回答
我正在编写一个自定义的PHP MySQL库，它将连接到多个MySQL服务器，并提供应用程序级别的负载平衡。基本上，它尝试连接到一组服务器(所有服务器)，第一个成功连接wins。
问题是，对于我来说，无论是mysql还是mysqli PHP库，我都找不到一种方法来异步连接，也就是使用回调。显然，我不想阻止每个连接尝试，否则库将不得不等待超时，然后尝试下一个服务器。
它应该像这样工作：
foreach($servers as $server) {
mysql_async_connect($server, function($connection) {
if($connect
浏览 0提问于2012-05-30得票数 0
我不理解java多线程系统和Nodejs多线程系统在性能和资源共享方面的区别。由于NodeJS为您的程序使用事件循环单线程，但在场景后面，它将任务分配给不同的线程，如文件读取或db查询。因此，它使用多线程和线程池(类似于Java?)。但是，当我们比较性能时，NodeJS应用程序比其他多线程系统要好得多。
NodeJS实际上是如何处理多线程编程挑战的，比如溢出或锁定线程。它如何在线程之间共享资源--例如，我同时使用两个I/O访问同一个文件--因此将有两个线程访问一个资源，它是否适用于NodeJS多线程系统？还是我误解了这一点？
浏览 7提问于2016-02-15得票数 3
回答已采纳
我将JPA与hibernate一起用于mysql。
我想知道在默认情况下，jpa查询方法是否会在事务中执行。
我不使用事务管理或任何类型的锁定。
敬请提供权威参考。
谢谢！
浏览 6提问于2022-04-22得票数 1
回答已采纳
1回答
我是redis的新手，我启动了关于这个的服务器。而且起作用了。然后使用java编写代码连接redis，然后就可以了，如下所示：
Jedis jedis = new Jedis("localhost");
System.out.println("Connection to server sucessfully");
//store data in redis list
jedis.lpush("tutorial-list", "Redis");
jedis.lpush(&#
浏览 3提问于2015-10-10得票数 0
2回答
我正在使用和进行一些负载测试。我计算Servlet和方法runAlgo在processRequest中的调用数。我使用以下代码：
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
i
浏览 0提问于2012-03-02得票数 2
回答已采纳
我正在windows 2003机器上运行MySQL 5.0，目前运行在单个CPU上。我正在考虑添加另一个处理器来提高性能，因为服务器上的一些应用程序在发出数据库请求时正在减速。MySQL是否能够使两个cpus之间的负载均匀化？
浏览 0提问于2012-09-27得票数 1
2回答
我正在我的库中实现一个名为C++的HttpDataStream类。为了在Android下使用我的库，我必须做JNI绑定，目标-C绑定用于iOS。
我需要在Java和Objective中创建一个专用的HttpDataStream类，但我想知道这些类是否真的会在下载完成之前阻止整个应用程序。
例如，让我们从"Android端“的read类调用一个HttpDataStream方法：
std::streamsize DataStreamJava::read(double value) {
jmethodID m = jni->GetMethodID(j_dataStream_clas
浏览 6提问于2015-07-31得票数 3
回答已采纳
1回答
运行两个并行事务
、、、
我有标记为@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW) someMethod() {}的方法。我需要创建一个测试用例，在其中我将运行此方法(第一个事务)，并且在第一个事务提交之前，我将在第二个事务中并行运行此方法。我使用eclipseLink和java ee。你能给我一些建议怎么做吗？
浏览 0提问于2018-11-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
