标签: connection-pooling

我正在 IBM WAS 7.0 上运行我的多线程 Struts 应用程序，并在峰值负载期间出现以下异常。最初我将最大连接数配置为 50，连接等待时间为 180 秒，但是当我收到此错误时，我在进行大量谷歌搜索以解决此问题后将最大连接数更改为 70，将连接等待时间更改为 600 秒，但仍然收到此错误有时在高峰负载期间......

原因：com.ibm.websphere.ce.j2c.ConnectionWaitTimeoutException：连接不可用，等待超时 180008

请任何人能帮助我。

我正在通过使用redis集成。一台redis服务器被不同的应用程序使用。我的问题是ofbizjedis client

1. 默认情况下将保留多少个连接JedisPool。

2. 如果我创建多个JedisPool会影响redis性能

注意：我正在JedisPool另一个应用程序中使用默认配置进行创建。

client = new JedisPool(ip, port);

有没有更好的方法？，建议我。谢谢

更新：redis server使用默认配置用户启动spring data

<bean id="connectionFactory"
    class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
    p:host-name="${app.cache.redis.host}" p:port="${app.cache.redis.port}" p:password="${app.cache.redis.password}" />

由于 HTTP2 支持多路复用，我们还需要一个连接池来进行微服务通信吗？如果是，拥有这样的游泳池有什么好处？

示例：服务 A => 服务 B

以上两种服务都只有一个实例可用。

多个连接可能有助于克服每个连接（套接字）的操作系统缓冲区大小限制？还有什么？

使用连接池在nodejs中连接MySQL后如何切换数据库？

我曾经使用与 MySQL 的正常连接，因为它有一些问题，现在我想使用连接池。但是如何在与 MySQL 建立连接后更改数据库？

这是我更改数据库的方法：

conn.changeUser({
    database: req.session.dbname
}, function (err) {
    if (err) {
        console.log(err);
    } else {
        next();
    }
});

但现在它显示conn.changeUser不是一个函数

下面是连接mysql的方法：

const conn = mysql.createPool({
    connectionLimit: 10,
    host: config.host,
    user: config.user,
    password: config.password,
    database: 'shaw_elc_gst_13032019'
});

这是我的结果console.log(conn)：

Pool {
  _events:
   [Object: null prototype] {
     connection: [Function],
     acquire: [Function],
     enqueue: [Function],
     release: [Function],
     error: [Function] },
  _eventsCount: 5,
  _maxListeners: undefined,
  config:
   PoolConfig {
     acquireTimeout: 10000,
     connectionConfig:
      ConnectionConfig {
        host: 'localhost', …

我有一个专用的 PostgreSQL 服务器和一个 pgBouncer 服务器。所有连接都是通过 pgBouncer 建立的。我使用 Apache JMeter 和 PHP 测试了系统。结果很奇怪。500 个连接的吞吐量还不错，但当我使用更多连接进行测试时，吞吐量会下降。

这是测试结果：

pgbouncer 配置：

[databases]

maindb = host=212.212.322.323 port=5432 user=myuser dbname=mydb pool_size=1000 pool_mode=transaction

[pgbouncer]

logfile = /var/log/postgresql/pgbouncer.log
pidfile = /var/run/postgresql/pgbouncer.pid

listen_addr = *
listen_port = 6432

auth_type = trust
auth_file = /etc/pgbouncer/userlist.txt

pool_mode = session
max_client_conn = 1000
default_pool_size = 20

如何为我的网络应用程序启用ODP.Net性能计数器？

我正在使用:

• .Net 2.0
• Oracle 11g
• Windows 2008 R2

在我的项目中,Spring使用org.apache.commons.dbcp.BasicDataSource类管理连接池.是否可以获取当前时间内有多少个免费或使用的连接？

谢谢.

问候,

我正在寻找一个很好的解决方案,用于在war的context.xml中外化JNDI连接池信息,这样当应用程序从dev移动到QA到prod时,war文件将不需要重新编译.理想情况下,URL,驱动程序,用户名和密码将被变量化,然后通过为每个环境定制的属性文件进行填充.如果无法做到这一点,是否有其他建议如何处理跨环境的战争而不重新编译目标环境？Maven提供的配置文件需要针对特定​​环境的构建.

提前致谢.

如果我将dbContext作为全局变量打开,如下面的代码所示,与在每个函数中使用新的datacontext并将其包装在using块中相比,是否会导致连接池问题？

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using LoopinDeals.Helper;

namespace LoopinDeals.Model
{
    public class DealUsersRepository
    {
        private DataClassesDataContext DbContext = new DataClassesDataContext();

        public void AddUser(string Email, string Password)
        {
            DealUser deal = new DealUser()
            {
                Email = Email,
                Password = Password,
                EmailVerified = true,
                LastLogin = DateTime.Now,
                AccountCreated = DateTime.Now,
                IsActive = true,
                RegistrationMethod = RegistrationType.Normal.ToString(),
                Subscribe = "true"
            };

            DbContext.DealUsers.InsertOnSubmit(deal);
            DbContext.SubmitChanges();
        }

        public void AddSignUpUser(string Email, string City)
        {
            try
            {
                DealUser UserData = new DealUser()
                    { …

我正在尝试为我们的akka​​ http应用程序使用客户端连接池。但是，一旦达到最大连接数，请求似乎就会挂起。我将问题归结为以下几点：

import java.lang.Thread.UncaughtExceptionHandler
import java.net.ServerSocket
import akka.actor.ActorSystem
import akka.http.scaladsl.settings.ConnectionPoolSettings
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{HttpRequest, HttpResponse, Uri}
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Flow, Keep, Sink, Source}
import akka.http.scaladsl.client.RequestBuilding._

import scala.annotation.tailrec
import scala.util.{Success, Try}

object AkkaProblem extends App {
    val server = new ServerSocket(0)
    val serverPort = server.getLocalPort

    object responder extends Runnable with UncaughtExceptionHandler {
       val cr = '\r'
       val httpResponse =
  s"""HTTP/1.1 404 Not Found$cr
      |Content-Type: application/json;charset=UTF-8$cr
      |Date: Mon, 26 Sep 2016 06:30:13 GMT$cr
      |Connection: keep-alive$cr
      |Transfer-Encoding: chunked$cr
      |$cr
      |12$cr
      |{"Hello": "World"}$cr
      |0$cr …