hey Charli -

Glad to hear that it might be useful to you. I’m going production with it this weekend and it has done well in all my tests thus far.

Let me know how it works for you (and where you’re using it, since I’m curious).

cheers!

is SphinxClient thread safe? Can I make a static SphinxClient and use it across threads?

hi ankesh -

that sounds like a firewall blocking your traffic or the wrong port you’re trying to use. make sure your sphinx server is at the hostname you pass to the SphinxClient constructor, and make sure the server is using the default port 3312 or change the port to match your server.

that TCP error probably has nothing to do with the client API code.

hope that helps.

[quote comment="3017"]Hello sir,
there is a small problem with the attributes reading – the numbers are not real. I’ve fixed it. If anyone need these sources, I’m here.[/quote]

I am also interested in this fix: peter at emblemsoftware dot com

Thanks.

For unsigned integer attributes to appear correctly you need to change:

/* handle everything else as unsigned ints */
long val = bw.ReadUInt32();
to
/* handle everything else as unsigned ints */
uint val = ReadUInt32(bw);

to make it go through byte reversal. (no need to ask me for the source!). Also easy to add the latest enumerations (and change the validation code) to use options in 0.9.9.

Hi,

I had change the port according to the server but getting error
“Connect: Read from socket failed: Unable to read data from the transport connection: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond.”

Plz help…
and also can you please let me know how we can assure that whichever port i m using is the correct one?.

Thanks
Mohit

Maybe my problem is the same to you.
When can the version be published?

Great initiative Christoper. Any chance you’ll be putting up a shared project somewhere? Google code? Github? I’m sure others are willing to contribute as well.

Also added UpdateAttributes API Call:

/**
* Connect to searchd server and update given attributes on given documents in given indexes.
* Sample code that will set group_id=123 where id=1 and group_id=456 where id=3:
*
*
* String[] attrs = new String[1];
*
* attrs[0] = “group_id”;
* long[][] values = new long[2][2];
*
* values[0] = new long[2]; values[0][0] = 1; values[0][1] = 123;
* values[1] = new long[2]; values[1][0] = 3; values[1][1] = 456;
*
* int res = cl.UpdateAttributes ( “test1″, attrs, values );
*
*
* @param index index name(s) to update; might be distributed
* @param attrs array with the names of the attributes to update
* @param values array of updates; each long[] entry must contains document ID
* in the first element, and all new attribute values in the following ones
* @return -1 on failure, amount of actually found and updated documents (might be 0) on success
*
* @throws SphinxException on invalid parameters
*/
public int UpdateAttributes ( String index, String[] attrs, long[][] values )
{
/* check args */
Debug.Assert ( !string.IsNullOrEmpty(index), “no index name provided” );
Debug.Assert ( attrs!=null && attrs.Length>0, “no attribute names provided” );
Debug.Assert ( values!=null && values.Length>0, “no update entries provided” );
for ( int i=0; i<values.Length; i++ )
{
Debug.Assert ( values[i]!=null, “update entry #” + i + ” is null” );
Debug.Assert ( values[i].Length == 1 + attrs.Length, “update entry #” + i + ” has wrong length” );
}

/* build and send request */
if (_client == null || !_client.Connected)
{
this.Connect();
}
if (_client == null) return -1;
StreamReader sr = new StreamReader(_client.GetStream());
BinaryWriter sw = new BinaryWriter(_client.GetStream());
BinaryWriter tsw = new BinaryWriter(new MemoryStream()); /* temp command buffer */
try
{
WriteToStream(sw, VER_MAJOR_PROTO);
WriteToStream(sw, (short)SEARCHD_COMMAND_UPDATE);
WriteToStream(sw, (short)VER_COMMAND_UPDATE);
this.WriteToStream(tsw, index);
this.WriteToStream(tsw, attrs.Length);
for (int i = 0; i< attrs.Length; i++)
{
this.WriteToStream(tsw, attrs[i]);
}

this.WriteToStream(tsw, values.Length);

for (int i = 0; i < values.Length; i++)
{
this.WriteToStream(tsw, values[i][0]); /* send docid as 64bit value */
for (int j = 1; j < values[i].Length; j++)
{
this.WriteToStream(tsw, (int)values[i][j]); /* send values as 32bit values; FIXME! what happens when they are over 2^31? */
}
}

this.WriteToStream(sw, (int)tsw.BaseStream.Length); // send the request size
sw.Write(((MemoryStream)tsw.BaseStream).ToArray());
sw.Flush();

} catch ( Exception e )
{
_error = “internal error: failed to build request: ” + e;
return -1;
}

/* get and parse response */
byte[] response = GetResponse(_client, VER_COMMAND_UPDATE);
if ( response == null )
return -1;

try
{
BinaryReader br = new BinaryReader(new MemoryStream(response));
return this.ReadInt32(br);
} catch ( Exception )
{
_error = “incomplete reply”;
return -1;
}
}

Hey everyone, I re-wrote a .NET client for Sphinx from scratch this past weekend and have posted it up on Google Code (http://code.google.com/p/sphinxdotnet) Feel free to join the project and help out if you want. I think it is feature complete for the sphinxsearch trunk (release 2011)

Hi there – have you published any updates to your code since this post? I’m wondering how stable you found this release. I’m going to check it out.

Question – does your API include methods to add text to the index or do I do that separately?

Thanks…

I am attempting to use you api with VB.net however I am having just a bit of trouble. In your example I do not see where you import the
SphinxSearchApi.dll. Could you please shed a little light on this for me.

Hi,

Thanks for this library, I wonder if it allows real time index, I want to use that new feature, available since sphinx 1.10.