On 6/20/07, <b class="gmail_sendername">Delgado, Edgardo CIV NAVAIR <a href="http://4.1.4.3">4.1.4.3</a></b> <<a href="mailto:edgardo.delgado@navy.mil">edgardo.delgado@navy.mil</a>> wrote:<div><span class="gmail_quote">
</span><blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;">Here's the code:<br><br>from twisted.internet.protocol import ServerFactory, ClientFactory,
<br>Protocol, ClientCreator<br>from twisted.protocols.basic import LineReceiver<br>from twisted.application.service import Service, Application,<br>IServiceCollection<br>from twisted.application.internet import TCPServer, TCPClient
<br>from twisted.internet.stdio import StandardIO<br>from twisted.internet import reactor<br>import re<br><br>class DnLinkProtocol(LineReceiver):<br><br> def connectionMade(self):<br> self.sendLine("Connected from: " + "host " +
<br> str(self.transport.getPeer().host) + " " +<br> "port " +<br> str(self.transport.getPeer().port) + '\n')<br>
<br> def lineReceived(self, line):<br> self.sendLine("DnLink echo: " + line + '\n')<br><br>class DSPEProtocol(LineReceiver):<br><br> def connectionMade(self):<br> self.sendLine("Connected from: " + "host " +
<br> str(self.transport.getPeer().host) + " " +<br> "port " +<br> str(self.transport.getPeer().port) + '\n')<br>
<br> def lineReceived(self, line):<br> self.sendLine("DSPE echo: " + line + '\n')<br><br>class PAPSExecService(Service):<br><br> def getDnLinkInFactory(self):<br> f = ServerFactory()<br>
f.protocol = DnLinkProtocol<br> f.startService = self.startService<br> return f<br><br> def getDSPEInFactory(self):<br> f = ServerFactory()<br> f.protocol = DSPEProtocol<br> f.startService
= self.startService<br> return f<br><br>application = Application('PAPSExec')<br>f = PAPSExecService()<br>serviceCollection = IServiceCollection(application)<br>TCPServer(9595,<br>f.getDnLinkInFactory()).setServiceParent(serviceCollection)
<br>TCPServer(8585,<br>f.getDSPEInFactory()).setServiceParent(serviceCollection)<br><br><br>I would like that, for example, when data is received in port 9595 it<br>will forward the data to another server in port xxxx.<br>
Where would I create a TPC Client connection?<br>Where would I send the message?<br><br>Edgar<br><br>-----Original Message-----<br>From: <a href="mailto:twisted-python-bounces@twistedmatrix.com">twisted-python-bounces@twistedmatrix.com
</a><br>[mailto:<a href="mailto:twisted-python-bounces@twistedmatrix.com">twisted-python-bounces@twistedmatrix.com</a>] On Behalf Of Christian<br>Simms<br>Sent: Wednesday, June 20, 2007 11:01 AM<br>To: Twisted general discussion
<br>Subject: Re: [Twisted-Python] Server/Client<br><br>On 6/20/07, Delgado, Edgardo CIV NAVAIR <a href="http://4.1.4.3">4.1.4.3</a><br><<a href="mailto:edgardo.delgado@navy.mil">edgardo.delgado@navy.mil</a>> wrote:<br>
<br> I would like to build a server that when it gets a message on a<br>specific<br> port it will "forward" that message to another port.<br> I.e. "Server1" listens on port 10000. When it gets data on port
<br>10000 it<br> will forward the data to "Server2" listening on port 15000.<br><br><br>Assuming you're using TCP, you could just create a server listening on a<br>port using reactor.listenTCP(port, factory) as detailed here
<br><<a href="http://twistedmatrix.com/projects/core/documentation/howto/servers.html">http://twistedmatrix.com/projects/core/documentation/howto/servers.html</a><br>> and when you receive a message you would create a client using
<br>reactor.connectTCP(host, port, factory) as detailed here<br><<a href="http://twistedmatrix.com/projects/core/documentation/howto/clients.html">http://twistedmatrix.com/projects/core/documentation/howto/clients.html
</a><br>> to then send the message.<br><br>Cheers,<br>Christian</blockquote><div><br>Assuming you want to create a new connection every time a client connects to your port 9595, it's slightly tricky because you can't just forward the data as soon as you get it, since the connection to the other server may not be created yet. A relatively complex way is explained in the Python Cookbook in
<a href="http://aspn.activestate.com/ASPN/Cookbook/Python/Recipe/502293">article "Hex-dump port-forwarding network proxy server"</a>, where it queues up the data until the outgoing connection is made. A simpler way is used in
twisted.protocols.portforward.ProxyFactory/ProxyServer, where it just pauses receiving data until the outgoing connection is made. I found a <a href="http://mail.python.org/pipermail/python-list/2003-June/212102.html">Python mailing list entry
</a> which explains how to override the portforward's methods.<br><br>Cheers,<br>Christian<br><br></div><br></div>