Code Monkey home page Code Monkey logo

Comments (11)

majst01 avatar majst01 commented on August 23, 2024

Hi zhuyuping,

are you sure your specified influxdb address is working ?
The error you pasted looks like okhttpd got a response from a webserver which is not influxdb.

Greetings

from influxdb-java.

majst01 avatar majst01 commented on August 23, 2024

Any news from this ? Otherwise i will close this issue.

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

This error occurs when the writing frequently use threads , and then does not seem to appear after I use apache common pool2

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

my code when not use the common pool2

@PostConstruct
private void broadcastTimePeriodically() {
scheduler.scheduleAtFixedRate(new Runnable() {
@OverRide public void run() {
//updatePriceAndBroadcast();
Integer rnx = rand.nextInt(10000);
Serie serie = new Serie.Builder("testrandom")
.columns("test3")
.values(rnx)
.build();

             influxDB.write("db",  TimeUnit.MILLISECONDS, serie);
      }
    }, 1000);
  }

from influxdb-java.

majst01 avatar majst01 commented on August 23, 2024

Hi,

you are sure that you are not oversaturating the influxdb server ? Any logs from influxdb pointing to some errors ?

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

Server does not appear wrong, just write in the client

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

public class InfluxDBFactoryBean implements FactoryBean,InitializingBean{

private String url;//地址

private String username;//账号

private String password;//密码






public InfluxDBFactoryBean(String url, String username, String password) {
    super();
    this.url = url;
    this.username = username;
    this.password = password;
}


public void setUrl(String url) {
    this.url = url;
}


public void setUsername(String username) {
    this.username = username;
}



public void setPassword(String password) {
    this.password = password;
}

@Override
public InfluxDB getObject() throws Exception {

    return InfluxDBFactory.connect(url, username,password);
}

@Override
public Class<?> getObjectType() {

    return InfluxDB.class;
}

@Override
public boolean isSingleton() {

    return true;
}


@Override
public void afterPropertiesSet() throws Exception {


}

}

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

is Singleton cause?

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

public class InfluxDBPoll extends BasePooledObjectFactory implements FactoryBean{

private String url;//地址

private String username;//账号

private String password;//密码





public InfluxDBPoll(String url, String username, String password) {
    super();
    this.url = url;
    this.username = username;
    this.password = password;
}

//http://commons.apache.org/proper/commons-pool/examples.html

@Override
public InfluxDB create() throws Exception {

    return InfluxDBFactory.connect(url, username,password);
}

@Override
public PooledObject<InfluxDB> wrap(InfluxDB influxDB) {


    return new DefaultPooledObject<InfluxDB>(influxDB);

}

public String getUrl() {
    return url;
}

public void setUrl(String url) {
    this.url = url;
}

public String getUsername() {
    return username;
}

public void setUsername(String username) {
    this.username = username;
}

public String getPassword() {
    return password;
}

public void setPassword(String password) {
    this.password = password;
}

@Override
public GenericObjectPool getObject() throws Exception {

    return new GenericObjectPool<InfluxDB>(new InfluxDBPoll(url, username, password));
}

@Override
public Class<?> getObjectType() {

    return GenericObjectPool.class;
}

@Override
public boolean isSingleton() {

    return true;
}

}

from influxdb-java.

majst01 avatar majst01 commented on August 23, 2024

Hi,

The Proble is that the Server you are talking to response with:

Caused by: java.net.ProtocolException: Unexpected status line: w.onload = function () { 

I guess you have a loadbalancer or a other L7 server between your influxdb client and Server, and this "Reverse Proxy" sometimes does not return a influxdb result.
This might be because this "Reverse Proxy" hit some limits.
Just a wild guess.

from influxdb-java.

desperado1992 avatar desperado1992 commented on August 23, 2024

maybe

from influxdb-java.

Related Issues (20)

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.