ejecutando hilos en componenetes indy tcp

richy08 · #1 27-07-2010

bueno por fin encontre mi problema jeje al parecer la forma en que creo los componentes no es la adecuada seguire investigando

manuc · #2 28-07-2010

Hola Richy08,

La verdad es que no lo entendí muy bien, pero me alegro que hayas encontrado la solución.

Un saludo.

richy08 · #3 28-07-2010

Buenas tardes manuc he estado reajustando el codigo con los ejemplos que me has dado pero me saltan algunos errores que no he conseguido resolverlos

1. el primero es al crear la clase en la linea de destructor Destroy;

Código Delphi [-]tmisComponentes=Class(tPersistent)
  private
   fConexionADO:TADOConnection;
   fQueryADO:TAdoQuery;
   fConexionZ:TZConnection;
   fQueryZ:TZQuery;
  Public  
   destructor Destroy; 
   property Conexion:TADOConnection read fConexionADO write fConexionADO;
   property Query:TAdoQuery read fQueryADO write fQueryADO;
   property Conexion1:TZConnection read fConexionZ write fConexionZ;
   property Query1:TZQuery read fQueryZ write fQueryZ;
  end;

[Error] Interfaces.pas(47): Unsatisfied forward or external declaration: 'tmisComponentes.Destroy', al comentarla el programa corre pero no se s iesto me desencadena algunos otros errores

2.-al querer asignarle al componente "conexion" la cadena de conexion que fue creada en el evento formcreate

Código Delphi [-]procedure TFrm_Interfaces.FormCreate(Sender: TObject);
begin
  Clients := TThreadList.Create;
   cadena:='Provider=SQLOLEDB.1;Password=Siti2009;Persist Security Info=True;User ID=sa;Initial Catalog=PMS;Data Source=SITISERVER08\SITISQL_05; ';
  cadena:=cadena+' Use Procedure for Prepare=1;Auto Translate=True;Packet Size=4096;Workstation ID=DESARROLLO;Use Encryption for Data=False;Tag with column collation when possible=False';
  CBServerActive.Checked:=true;
end;

al querer asignarle la cadena en el evento serverexecute MisComponentes.Conexion.ConnectionString:=cadena;

Código Delphi [-]procedure TFrm_Interfaces.ServerExecute(AThread: TIdPeerThread);
var
  ActClient, RecClient: PClient;                                                                              
  CommBlock, NewCommBlock: TCommBlock;
  RecThread: TIdPeerThread;
  i, seleccion: Integer;
  MisComponentes:tmisComponentes;
begin
  if not AThread.Terminated and AThread.Connection.Connected then
  begin
    AThread.Connection.ReadBuffer (CommBlock, SizeOf (CommBlock));
    ActClient := PClient(AThread.Data);
    ActClient.LastAction := Now;  // update the time of last action
    MisComponentes :=  tmisComponentes(AThread.Data);
    //conneccionMSSQL
    MisComponentes.Conexion.ConnectionString:=cadena;
    MisComponentes.Conexion.loginprompt:=false;
    MisComponentes.Conexion.provider:='SQLOLEDB.1';
    MisComponentes.Conexion.connected;
    //conneccionMSSQL
    //conneccionMysql
    MisComponentes.Conexion1.Catalog:= 'lookup';
    MisComponentes.Conexion1.Database:= 'cdr';
    MisComponentes.Conexion1.HostName:= '192.168.10.3';
    MisComponentes.Conexion1.Password:= 'siti270';
    MisComponentes.Conexion1.Protocol:= 'mysql-5';
    MisComponentes.Conexion1.port:= 3306;
    MisComponentes.Conexion1.User:= 'root';
    MisComponentes.Conexion1.connect; 
    //conneccionMysql
    //queryMssql
    MisComponentes.Query.Close;
    MisComponentes.Query.Connection:= MisComponentes.Conexion;
    MisComponentes.Query.SQL.Text:='select idext, DesTel from pbx_ext where acode=:acode';
    MisComponentes.Query.parameters.ParamByName('acode').Value:=CommBlock.acode;
    MisComponentes.Query.cursorType := ctStatic;
    MisComponentes.Query.open;
    //queryMssql
    //queryMysql
     MisComponentes.Query1.Connection:=MisComponentes.Conexion1;
     MisComponentes.Query1.SQL.Text:='update lookup set  allowcalls=:allowcalls, ldesc=:ldesc where code=:code ';
    //queryMysql

    //ejecuta abrir y cerrar lineas
     i:=0;
     seleccion:=Query.RecordCount;
     MisComponentes.Query.First;
     While ido
     begin
        MisComponentes.Query1.Close;
        MisComponentes.Query1.ParamByName('allowcalls').Value:=CommBlock.estado;
        MisComponentes.Query1.ParamByName('ldesc').Value:=CommBlock.nombre;
        MisComponentes.Query1.ParamByName('code').Value:=MisComponentes.Query1.fieldbyname('idext').Value;
        MisComponentes.Query1.ExecSQL;
        i:=i+1;
        MisComponentes.Query.Next;
     end;
    //ejecuta abrir y cerrar lineas
    Protocol.Lines.Add (TimeToStr(Time)+' The process for '+CommBlock.MyUserName+' was done ');// # Confirm'+inttostr(CommBlock.nconf));
    NewCommBlock.Command := 'DIALOG';       // the message should popup on the client's screen
    NewCommBlock.MyUserName := '[PBX Server]';  // the server's username
    NewCommBlock.Msg := 'The process was done  ';  // the message to show
    NewCommBlock.ReceiverName := '[return-to-sender]'; // unnecessary
    AThread.Connection.WriteBuffer (NewCommBlock, SizeOf (NewCommBlock), true);  // and there it goes...
  end;
end;

el error que envia es Project interfacesP.exe raised exception class EAccessViolation with message 'Access violation at address 00000000. Read of address 00000000'. Process stopped. Use Step or Run to continue.

alguna idea de que pueda ser mil gracias

manuc · #4 28-07-2010

Hola Richy08,

Código Delphi [-][Error] Interfaces.pas(47): Unsatisfied forward or external declaration: 'tmisComponentes.Destroy'

No estoy seguro, pero ¿puede ser que te falte la implementación de este procedimiento?

Después en estas líneas de código:

Código Delphi [-] ActClient := PClient(AThread.Data);
 ActClient.LastAction := Now;  // update the time of last action
 MisComponentes :=  tmisComponentes(AThread.Data);

En "AThread.Data" ¿que almacenas la estructura de tipo "PClient" y de tipo "tmisComponentes"?

Por otro lado, si puedieras hacer un seguimiento a la ejecución del código e indicarme la línea más o menos donde te da el error, te podría dar alguna sugerencia.

No obstante revisaré el código que has puesto a ver si veo algo raro.

Un saludo.

richy08 · #5 28-07-2010

Cita:

Empezado por manuc

Hola Richy08,
Código Delphi [-]
[Error] Interfaces.pas(47): Unsatisfied forward or external declaration: 'tmisComponentes.Destroy'

No estoy seguro, pero ¿puede ser que te falte la implementación de este procedimiento?

a ok si me imaginaba algo asi, sabes estoy un poco enredado es la primera ves que me veo en la necesidad de usar clases que yo mismo creo, me imagino que en esta parte es donde le doy .free a los querys que creo para que liberen dicha memoria??

Cita:

Empezado por manuc

Después en estas líneas de código:

Código Delphi [-]
ActClient := PClient(AThread.Data);
ActClient.LastAction := Now; // update the time of last action
MisComponentes := tmisComponentes(AThread.Data);

En "AThread.Data" ¿que almacenas la estructura de tipo "PClient" y de tipo "tmisComponentes"?

asi es en AThread.Data almaceno los datos de esas dos estructuras.

Cita:

Empezado por manuc

Por otro lado, si puedieras hacer un seguimiento a la ejecución del código e indicarme la línea más o menos donde te da el error, te podría dar alguna sugerencia.

No obstante revisaré el código que has puesto a ver si veo algo raro.

Un saludo.

ya he corrido paso a paso el codigo y en la linea que me salta el error es

MisComponentes.Conexion.ConnectionString:=cadena;

Código Delphi [-]procedure TFrm_Interfaces.ServerExecute(AThread: TIdPeerThread);
var
  ActClient, RecClient: PClient;                                                                              
  CommBlock, NewCommBlock: TCommBlock;
  RecThread: TIdPeerThread;
  i, seleccion: Integer;
  MisComponentes:tmisComponentes;
begin
  if not AThread.Terminated and AThread.Connection.Connected then
  begin
    AThread.Connection.ReadBuffer (CommBlock, SizeOf (CommBlock));
    ActClient := PClient(AThread.Data);
    ActClient.LastAction := Now;  // update the time of last action
    MisComponentes :=  tmisComponentes(AThread.Data);
    //conneccionMSSQL
    MisComponentes.Conexion.ConnectionString:=cadena; //aqui es donde truena
    MisComponentes.Conexion.loginprompt:=false;
    MisComponentes.Conexion.provider:='SQLOLEDB.1';
    MisComponentes.Conexion.connected;
    //conneccionMSSQL
    //conneccionMysql
    MisComponentes.Conexion1.Catalog:= 'lookup';
    MisComponentes.Conexion1.Database:= 'cdr';
    MisComponentes.Conexion1.HostName:= '192.168.10.3';
    MisComponentes.Conexion1.Password:= 'siti270';
    MisComponentes.Conexion1.Protocol:= 'mysql-5';
    MisComponentes.Conexion1.port:= 3306;
    MisComponentes.Conexion1.User:= 'root';
    MisComponentes.Conexion1.connect; 
    //conneccionMysql
 
    //queryMssql
    MisComponentes.Query.Close;
    MisComponentes.Query.Connection:= MisComponentes.Conexion;
    MisComponentes.Query.SQL.Text:='select idext, DesTel from pbx_ext where acode=:acode';
    MisComponentes.Query.parameters.ParamByName('acode').Value:=CommBlock.acode;
    MisComponentes.Query.cursorType := ctStatic;
    MisComponentes.Query.open;
    //queryMssql
    //queryMysql
     MisComponentes.Query1.Connection:=MisComponentes.Conexion1;
     MisComponentes.Query1.SQL.Text:='update lookup set  allowcalls=:allowcalls, ldesc=:ldesc where code=:code ';
    //queryMysql

    //ejecuta abrir y cerrar lineas
     i:=0;
     seleccion:=Query.RecordCount;
     MisComponentes.Query.First;
     While ido
     begin
        MisComponentes.Query1.Close;
        MisComponentes.Query1.ParamByName('allowcalls').Value:=CommBlock.estado;
        MisComponentes.Query1.ParamByName('ldesc').Value:=CommBlock.nombre;
        MisComponentes.Query1.ParamByName('code').Value:=MisComponentes.Query1.fieldbyname('idext').Value;
        MisComponentes.Query1.ExecSQL;
        i:=i+1;
        MisComponentes.Query.Next;
     end;
    //ejecuta abrir y cerrar lineas
    Protocol.Lines.Add (TimeToStr(Time)+' The process for '+CommBlock.MyUserName+' was done ');// # Confirm'+inttostr(CommBlock.nconf));
    NewCommBlock.Command := 'DIALOG';       // the message should popup on the client's screen
    NewCommBlock.MyUserName := '[PBX Server]';  // the server's username
    NewCommBlock.Msg := 'The process was done  ';  // the message to show
    NewCommBlock.ReceiverName := '[return-to-sender]'; // unnecessary
    AThread.Connection.WriteBuffer (NewCommBlock, SizeOf (NewCommBlock), true);  // and there it goes...
  end;
end;

gracias por tus respuestas

manuc · #6 28-07-2010

Hola nuevamente,

Me podrías poner el código del evento onConnect del TCPServer?

gracias.

richy08 · #7 28-07-2010

claro este es el codigo

Código Delphi [-]procedure TFrm_Interfaces.ServerConnect(AThread: TIdPeerThread);
var
  NewClient: PClient;
  MisComponentes:tmisComponentes;
begin
   GetMem(NewClient, SizeOf(TClient));
  NewClient.DNS         := AThread.Connection.LocalName;
  NewClient.Connected   := Now;
  NewClient.LastAction  := NewClient.Connected;
  NewClient.Thread      :=AThread;
  AThread.Data:=TObject(NewClient);
  CoInitialize(nil);
  MisComponentes := tmisComponentes.Create;
  MisComponentes.Conexion := TADOConnection.Create(self);
  MisComponentes.Query := TADOQUERY.Create(Self);
  MisComponentes.Conexion1 := TZConnection.Create(self);
  MisComponentes.Query1 := TZquery.Create(Self);
  AThread.Data := @MisComponentes;
  try
    Clients.LockList.Add(NewClient);
  finally
    Clients.UnlockList;
  end;
  Protocol.Lines.Add(TimeToStr(Time)+' The connection to '+NewClient.DNS+' was connected');
end;

Herramientas	Buscar en Tema
Mostrar Versión Imprimible Enviar por Correo	Buscar en Tema: Búsqueda Avanzada
Desplegado
Cambiar a Modo Lineal Modo Híbrido Cambiar a Modo Hilado

Temas Similares
Tema	Autor	Foro	Respuestas	Último mensaje
Como instalar los componenetes de la Norma 19	diego11	Varios	3	17-10-2007 13:08:44
componenetes en un TTabControl	lucasarts_18	OOP	2	28-09-2005 00:44:43
instalar nuevos componenetes	aranel	OOP	6	02-08-2005 10:25:33
Multiple Hilos con Indy en Delphi 6	cancerbero	Varios	4	12-06-2004 20:01:21
Componenetes para envio y recepcion de mensajes en la red	enrique800	OOP	3	29-01-2004 05:31:41