2
* Copyright 2001-2004 The Apache Software Foundation.
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
* you may not use this file except in compliance with the License.
6
* You may obtain a copy of the License at
8
* http://www.apache.org/licenses/LICENSE-2.0
10
* Unless required by applicable law or agreed to in writing, software
11
* distributed under the License is distributed on an "AS IS" BASIS,
12
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
* See the License for the specific language governing permissions and
14
* limitations under the License.
16
package org.apache.axis.utils ;
19
import java.awt.BorderLayout;
20
import java.awt.Color;
21
import java.awt.Component;
22
import java.awt.Dimension;
23
import java.awt.GridBagConstraints;
24
import java.awt.GridBagLayout;
25
import java.awt.event.ActionEvent;
26
import java.awt.event.ActionListener;
27
import java.io.ByteArrayInputStream;
29
import java.io.FileOutputStream;
30
import java.io.InputStream;
31
import java.io.OutputStream;
32
import java.io.PrintWriter;
33
import java.io.StringWriter;
34
import java.net.ServerSocket;
35
import java.net.Socket;
37
import java.text.DateFormat;
38
import java.text.SimpleDateFormat;
39
import java.util.Date;
40
import java.util.Iterator;
41
import java.util.ResourceBundle;
42
import java.util.Vector;
44
import javax.swing.BorderFactory;
45
import javax.swing.Box;
46
import javax.swing.BoxLayout;
47
import javax.swing.ButtonGroup;
48
import javax.swing.JButton;
49
import javax.swing.JCheckBox;
50
import javax.swing.JFileChooser;
51
import javax.swing.JFrame;
52
import javax.swing.JLabel;
53
import javax.swing.JPanel;
54
import javax.swing.JRadioButton;
55
import javax.swing.JScrollPane;
56
import javax.swing.JSplitPane;
57
import javax.swing.JTabbedPane;
58
import javax.swing.JTable;
59
import javax.swing.JTextArea;
60
import javax.swing.JTextField;
61
import javax.swing.ListSelectionModel;
62
import javax.swing.SwingConstants;
63
import javax.swing.UIManager;
64
import javax.swing.UnsupportedLookAndFeelException;
65
import javax.swing.border.TitledBorder;
66
import javax.swing.event.ChangeEvent;
67
import javax.swing.event.ListSelectionEvent;
68
import javax.swing.event.ListSelectionListener;
69
import javax.swing.plaf.basic.BasicButtonListener;
70
import javax.swing.table.DefaultTableModel;
71
import javax.swing.table.TableColumn;
72
import javax.swing.table.TableModel;
73
import javax.swing.text.AttributeSet;
74
import javax.swing.text.BadLocationException;
75
import javax.swing.text.Document;
76
import javax.swing.text.PlainDocument;
80
* TCP monitor to log http messages and responses, both SOAP and plain HTTP.
81
* If you want to choose a different Swing look and feel, set the property
82
* tcpmon.laf to the classname of the new look and feel
83
* @author Doug Davis (dug@us.ibm.com)
84
* @author Steve Loughran
87
public class tcpmon extends JFrame {
88
private JTabbedPane notebook = null ;
90
private static final int STATE_COLUMN = 0 ;
91
private static final int TIME_COLUMN = 1 ;
92
private static final int INHOST_COLUMN = 2 ;
93
private static final int OUTHOST_COLUMN = 3 ;
94
private static final int REQ_COLUMN = 4 ;
97
private static final String DEFAULT_HOST="127.0.0.1";
98
private static final int DEFAULT_PORT=8080;
101
* this is the admin page
103
class AdminPage extends JPanel {
104
public JRadioButton listenerButton, proxyButton ;
105
public JLabel hostLabel, tportLabel;
106
public NumberField port;
107
public HostnameField host;
108
public NumberField tport ;
109
public JTabbedPane noteb ;
110
public JCheckBox HTTPProxyBox ;
111
public HostnameField HTTPProxyHost;
112
public NumberField HTTPProxyPort ;
113
public JLabel HTTPProxyHostLabel, HTTPProxyPortLabel ;
114
public JLabel delayTimeLabel, delayBytesLabel;
115
public NumberField delayTime, delayBytes;
116
public JCheckBox delayBox;
118
public AdminPage( JTabbedPane notebook, String name ) {
119
JPanel mainPane = null ;
120
JButton addButton = null ;
122
this.setLayout( new BorderLayout() );
125
GridBagLayout layout = new GridBagLayout();
126
GridBagConstraints c = new GridBagConstraints();
128
mainPane = new JPanel(layout);
130
c.anchor = GridBagConstraints.WEST ;
131
c.gridwidth = GridBagConstraints.REMAINDER;
132
mainPane.add( new JLabel(getMessage("newTCP00", "Create a new TCP/IP Monitor...") + " "), c );
134
// Add some blank space
135
mainPane.add( Box.createRigidArea(new Dimension(1, 5)), c );
138
///////////////////////////////////////////////////////////////////
139
JPanel tmpPanel = new JPanel(new GridBagLayout());
141
c.anchor = GridBagConstraints.WEST ;
143
tmpPanel.add( new JLabel(getMessage("listenPort00", "Listen Port #") + " "), c );
145
c.anchor = GridBagConstraints.WEST ;
146
c.gridwidth = GridBagConstraints.REMAINDER ;
147
tmpPanel.add( port = new NumberField(4), c );
149
mainPane.add( tmpPanel, c );
151
mainPane.add( Box.createRigidArea(new Dimension(1, 5)), c );
153
// Group for the radio buttons
154
ButtonGroup btns = new ButtonGroup();
156
c.anchor = GridBagConstraints.WEST ;
157
c.gridwidth = GridBagConstraints.REMAINDER ;
158
mainPane.add( new JLabel(getMessage("actAs00", "Act as a...") ), c );
160
// Target Host/Port section
161
///////////////////////////////////////////////////////////////////
162
c.anchor = GridBagConstraints.WEST ;
163
c.gridwidth = GridBagConstraints.REMAINDER ;
165
final String listener = getMessage("listener00", "Listener");
167
mainPane.add( listenerButton = new JRadioButton( listener ), c );
168
btns.add( listenerButton );
169
listenerButton.setSelected( true );
171
listenerButton.addActionListener( new ActionListener() {
172
public void actionPerformed(ActionEvent event) {
173
if (listener.equals(event.getActionCommand())) {
174
boolean state = listenerButton.isSelected();
176
tport.setEnabled( state );
177
host.setEnabled( state );
178
hostLabel.setForeground(state ? Color.black : Color.gray);
179
tportLabel.setForeground(state ? Color.black : Color.gray);
185
c.anchor = GridBagConstraints.WEST ;
187
mainPane.add( Box.createRigidArea(new Dimension(25, 0)) );
188
mainPane.add( hostLabel = new JLabel(getMessage("targetHostname00", "Target Hostname") + " "), c );
190
c.anchor = GridBagConstraints.WEST ;
191
c.gridwidth = GridBagConstraints.REMAINDER ;
192
host = new HostnameField(30);
193
mainPane.add( host, c );
194
host.setText(DEFAULT_HOST);
196
c.anchor = GridBagConstraints.WEST ;
198
mainPane.add( Box.createRigidArea(new Dimension(25, 0)) );
199
mainPane.add( tportLabel = new JLabel(getMessage("targetPort00", "Target Port #") + " "), c );
201
c.anchor = GridBagConstraints.WEST ;
202
c.gridwidth = GridBagConstraints.REMAINDER ;
203
tport = new NumberField(4);
204
mainPane.add( tport, c );
205
tport.setValue(DEFAULT_PORT);
207
// Act as proxy section
208
///////////////////////////////////////////////////////////////////
209
c.anchor = GridBagConstraints.WEST ;
210
c.gridwidth = GridBagConstraints.REMAINDER ;
211
final String proxy = getMessage("proxy00", "Proxy");
213
mainPane.add( proxyButton = new JRadioButton( proxy ), c);
214
btns.add( proxyButton );
216
proxyButton.addActionListener( new ActionListener() {
217
public void actionPerformed(ActionEvent event) {
218
if (proxy.equals(event.getActionCommand())) {
219
boolean state = proxyButton.isSelected();
221
tport.setEnabled( !state );
222
host.setEnabled( !state );
223
hostLabel.setForeground(state ? Color.gray : Color.black);
224
tportLabel.setForeground(state ? Color.gray : Color.black);
231
/////////////////////////////////////////////////////////////////
232
c.anchor = GridBagConstraints.WEST ;
233
c.gridwidth = GridBagConstraints.REMAINDER ;
234
mainPane.add( Box.createRigidArea(new Dimension(1, 10)), c );
237
///////////////////////////////////////////////////////////////////
238
JPanel opts = new JPanel(new GridBagLayout());
240
opts.setBorder( new TitledBorder(getMessage("options00", "Options")) );
241
c.anchor = GridBagConstraints.WEST ;
242
c.gridwidth = GridBagConstraints.REMAINDER ;
243
mainPane.add( opts, c );
245
// HTTP Proxy Support section
246
///////////////////////////////////////////////////////////////////
247
c.anchor = GridBagConstraints.WEST ;
248
c.gridwidth = GridBagConstraints.REMAINDER ;
249
final String proxySupport = getMessage("proxySupport00", "HTTP Proxy Support");
251
opts.add(HTTPProxyBox = new JCheckBox(proxySupport), c);
253
c.anchor = GridBagConstraints.WEST ;
255
opts.add( HTTPProxyHostLabel = new JLabel(getMessage("hostname00", "Hostname") + " "), c );
256
HTTPProxyHostLabel.setForeground( Color.gray );
258
c.anchor = GridBagConstraints.WEST ;
259
c.gridwidth = GridBagConstraints.REMAINDER ;
260
opts.add( HTTPProxyHost = new HostnameField(30), c );
261
HTTPProxyHost.setEnabled( false );
263
c.anchor = GridBagConstraints.WEST ;
265
opts.add( HTTPProxyPortLabel = new JLabel(getMessage("port00", "Port #") + " "), c );
266
HTTPProxyPortLabel.setForeground( Color.gray );
268
c.anchor = GridBagConstraints.WEST ;
269
c.gridwidth = GridBagConstraints.REMAINDER ;
270
opts.add( HTTPProxyPort = new NumberField(4), c );
271
HTTPProxyPort.setEnabled( false );
273
HTTPProxyBox.addActionListener( new ActionListener() {
274
public void actionPerformed(ActionEvent event) {
275
if (proxySupport.equals(event.getActionCommand())) {
276
boolean b = HTTPProxyBox.isSelected();
277
Color color = b ? Color.black : Color.gray ;
279
HTTPProxyHost.setEnabled( b );
280
HTTPProxyPort.setEnabled( b );
281
HTTPProxyHostLabel.setForeground( color );
282
HTTPProxyPortLabel.setForeground( color );
288
// Set default proxy values...
289
String tmp = System.getProperty( "http.proxyHost" );
291
if ( tmp != null && tmp.equals("") ) {
295
HTTPProxyBox.setSelected( tmp != null );
296
HTTPProxyHost.setEnabled( tmp != null );
297
HTTPProxyPort.setEnabled( tmp != null );
298
HTTPProxyHostLabel.setForeground( tmp != null ? Color.black : Color.gray);
299
HTTPProxyPortLabel.setForeground( tmp != null ? Color.black : Color.gray);
302
HTTPProxyBox.setSelected( true );
303
HTTPProxyHost.setText( tmp );
304
tmp = System.getProperty( "http.proxyPort" );
305
if ( tmp != null && tmp.equals("") ) {
311
HTTPProxyPort.setText( tmp );
314
//add byte delay fields
315
opts.add(Box.createRigidArea(new Dimension(1, 10)), c);
316
c.anchor = GridBagConstraints.WEST;
317
c.gridwidth = GridBagConstraints.REMAINDER;
318
final String delaySupport = getMessage("delay00", "Simulate Slow Connection");
319
opts.add(delayBox = new JCheckBox(delaySupport), c);
322
c.anchor = GridBagConstraints.WEST;
324
delayBytesLabel=new JLabel(getMessage("delay01", "Bytes per Pause"));
325
opts.add(delayBytesLabel, c);
326
delayBytesLabel.setForeground(Color.gray);
327
c.anchor = GridBagConstraints.WEST;
328
c.gridwidth = GridBagConstraints.REMAINDER;
329
opts.add(delayBytes = new NumberField(6), c);
330
delayBytes.setEnabled(false);
333
c.anchor = GridBagConstraints.WEST;
335
delayTimeLabel = new JLabel(getMessage("delay02", "Delay in Milliseconds"));
336
opts.add(delayTimeLabel, c);
337
delayTimeLabel.setForeground(Color.gray);
338
c.anchor = GridBagConstraints.WEST;
339
c.gridwidth = GridBagConstraints.REMAINDER;
340
opts.add(delayTime = new NumberField(6), c);
341
delayTime.setEnabled(false);
344
delayBox.addActionListener(new ActionListener() {
345
public void actionPerformed(ActionEvent event) {
346
if (delaySupport.equals(event.getActionCommand())) {
347
boolean b = delayBox.isSelected();
348
Color color = b ? Color.black : Color.gray;
350
delayBytes.setEnabled(b);
351
delayTime.setEnabled(b);
352
delayBytesLabel.setForeground(color);
353
delayTimeLabel.setForeground(color);
360
//////////////////////////////////////////////////////////////////
361
mainPane.add( Box.createRigidArea(new Dimension(1, 10)), c );
364
///////////////////////////////////////////////////////////////////
365
c.anchor = GridBagConstraints.WEST ;
366
c.gridwidth = GridBagConstraints.REMAINDER ;
367
final String add = getMessage("add00", "Add");
369
mainPane.add( addButton = new JButton( add ), c );
372
this.add( new JScrollPane( mainPane ), BorderLayout.CENTER );
374
// addButton.setEnabled( false );
375
addButton.addActionListener( new ActionListener() {
376
public void actionPerformed(ActionEvent event) {
377
if ( add.equals(event.getActionCommand()) ) {
381
lPort=port.getValue(0);
383
//no port, button does nothing
386
String tHost = host.getText();
388
tPort=tport.getValue(0);
389
SlowLinkSimulator slowLink=null;
390
if(delayBox.isSelected()) {
391
int bytes= delayBytes.getValue(0);
392
int time = delayTime.getValue(0);
393
slowLink=new SlowLinkSimulator(bytes,time);
396
l = new Listener( noteb, null, lPort, tHost, tPort,
397
proxyButton.isSelected(), slowLink);
398
} catch (Exception e){
401
// Pick-up the HTTP Proxy settings
402
///////////////////////////////////////////////////
403
text = HTTPProxyHost.getText();
404
if ( "".equals(text) ) {
407
l.HTTPProxyHost = text ;
408
text = HTTPProxyPort.getText();
409
int proxyPort=HTTPProxyPort.getValue(-1);
411
l.HTTPProxyPort = Integer.parseInt(text);
416
/* but not, any more, the target port and host
426
notebook.addTab( name, this );
428
notebook.setSelectedIndex( notebook.getTabCount() - 1 );
435
* wait for incoming connections, spawn a connection thread when
438
class SocketWaiter extends Thread {
439
ServerSocket sSocket = null ;
442
boolean pleaseStop = false ;
444
public SocketWaiter(Listener l, int p) {
452
listener.setLeft( new JLabel(getMessage("wait00", " Waiting for Connection...") ) );
454
sSocket = new ServerSocket( port );
456
Socket inSocket = sSocket.accept();
461
new Connection( listener, inSocket );
464
} catch ( Exception exp ) {
465
if ( !"socket closed".equals(exp.getMessage()) ) {
466
JLabel tmp = new JLabel( exp.toString() );
468
tmp.setForeground( Color.red );
469
listener.setLeft( tmp );
470
listener.setRight( new JLabel("") );
477
* force a halt by connecting to self and then closing the server socket
482
new Socket( "127.0.0.1", port );
483
if ( sSocket != null ) {
486
} catch ( Exception e ) {
494
* class to simulate slow connections by slowing down the system
496
static class SlowLinkSimulator {
497
private int delayBytes;
498
private int delayTime;
499
private int currentBytes;
500
private int totalBytes;
504
* @param delayBytes bytes per delay; set to 0 for no delay
505
* @param delayTime delay time per delay in milliseconds
507
public SlowLinkSimulator(int delayBytes, int delayTime) {
508
this.delayBytes = delayBytes;
509
this.delayTime = delayTime;
513
* construct by copying delay bytes and time, but not current
515
* @param that source of data
517
public SlowLinkSimulator(SlowLinkSimulator that) {
518
this.delayBytes=that.delayBytes;
519
this.delayTime=that.delayTime;
523
* how many bytes have gone past?
526
public int getTotalBytes() {
531
* log #of bytes pumped. Will pause when necessary. This method is not
535
public void pump(int bytes) {
538
//when not delaying, we are just a byte counter
541
currentBytes += bytes;
542
if(currentBytes>delayBytes) {
543
//we have overshot. lets find out how far
544
int delaysize=currentBytes/delayBytes;
545
long delay=delaysize*(long)delayTime;
546
//move byte counter down to the remainder of bytes
547
currentBytes=currentBytes%delayBytes;
551
} catch (InterruptedException e) {
552
; //ignore the exception
558
* get the current byte count
561
public int getCurrentBytes() {
566
* set the current byte count
567
* @param currentBytes
569
public void setCurrentBytes(int currentBytes) {
570
this.currentBytes = currentBytes;
576
* this class handles the pumping of data from the incoming socket to the
579
class SocketRR extends Thread {
580
Socket inSocket = null ;
581
Socket outSocket = null ;
583
InputStream in = null ;
584
OutputStream out = null ;
587
volatile boolean done = false ;
588
TableModel tmodel = null ;
591
Connection myConnection = null;
592
SlowLinkSimulator slowLink;
594
public SocketRR(Connection c, Socket inputSocket, InputStream inputStream,
595
Socket outputSocket, OutputStream outputStream,
596
JTextArea _textArea, boolean format, boolean numeric,
597
TableModel tModel, int index, final String type, SlowLinkSimulator slowLink) {
598
inSocket = inputSocket ;
600
outSocket = outputSocket ;
602
textArea = _textArea ;
604
numericEnc= numeric ;
609
this.slowLink= slowLink;
613
public boolean isDone() {
619
byte[] buffer = new byte[4096];
620
byte[] tmpbuffer = new byte[8192];
621
String message = null;
628
boolean atMargin = true ;
633
//if ( inSocket != null ) inSocket.setSoTimeout( 10 );
634
//if ( outSocket != null ) outSocket.setSoTimeout( 10 );
636
if ( tmodel != null ) {
637
String tmpStr = (String) tmodel.getValueAt(tableIndex,
640
if ( !"".equals(tmpStr) ) {
641
reqSaved = tmpStr.length();
651
//len = in.available();
652
//}catch(Exception e){len=0;}
653
len = buffer.length ;
654
// Used to be 1, but if we block it doesn't matter
655
// however 1 will break with some servers, including apache
659
if ( saved + len > buffer.length) {
660
len = buffer.length - saved ;
664
while ( len1 == 0 ) {
666
len1 = in.read(buffer, saved, len);
668
catch ( Exception ex ) {
669
if ( done && saved == 0 ) {
678
if ( len == -1 && saved == 0 ) {
685
// No matter how we may (or may not) format it, send it
686
// on unformatted - we don't want to mess with how its
687
// sent to the other side, just how its displayed
688
if ( out != null && len > 0 ) {
690
out.write( buffer, saved, len );
693
if ( tmodel != null && reqSaved < 50 ) {
694
String old = (String) tmodel.getValueAt( tableIndex,
697
old = old + new String(buffer, saved, len);
698
if ( old.length() > 50 ) {
699
old = old.substring(0, 50);
702
reqSaved = old.length();
704
if ( (i = old.indexOf('\n')) > 0 ) {
705
old = old.substring(0, i - 1);
709
tmodel.setValueAt( old, tableIndex, REQ_COLUMN );
714
boolean inXML = false ;
715
int bufferLen = saved ;
723
for ( ; i1 < bufferLen ; i1++ ) {
724
// Except when we're at EOF, saved last char
725
if ( len != -1 && i1 + 1 == bufferLen ) {
730
if ( buffer[i1] == '<' && buffer[i1 + 1] != '/' ) {
731
previousIndent = nextIndent++;
732
thisIndent = nextIndent;
735
if ( buffer[i1] == '<' && buffer[i1 + 1] == '/' ) {
736
if (previousIndent > nextIndent) {
737
thisIndent = nextIndent;
739
previousIndent = nextIndent--;
742
if ( buffer[i1] == '/' && buffer[i1 + 1] == '>' ) {
743
previousIndent = nextIndent--;
746
if ( thisIndent != -1 ) {
747
if ( thisIndent > 0 ) {
748
tmpbuffer[i2++] = (byte) '\n';
750
for ( i = tabWidth * thisIndent; i > 0; i-- ) {
751
tmpbuffer[i2++] = (byte) ' ';
754
atMargin = ( buffer[i1] == '\n' || buffer[i1] == '\r');
756
if ( !inXML || !atMargin ) {
757
tmpbuffer[i2++] = buffer[i1];
760
message = new String( tmpbuffer, 0, i2, getEncoding() );
762
textArea.append( StringUtils.escapeNumericChar(message) );
764
textArea.append( StringUtils.unescapeNumericChar(message) );
767
// Shift saved bytes to the beginning
768
for ( i = 0 ; i < saved ; i++ ) {
769
buffer[i] = buffer[bufferLen - saved + i];
773
message = new String( buffer, 0, len, getEncoding() );
775
textArea.append( StringUtils.escapeNumericChar(message) );
777
textArea.append( StringUtils.unescapeNumericChar(message) );
780
// this.sleep(3); // Let other threads have a chance to run
782
// this.sleep(3); // Let other threads have a chance to run
784
// Only set the 'done' flag if we were reading from a
785
// Socket - if we were reading from an input stream then
786
// we'll let the other side control when we're done
787
// if ( inSocket != null ) done = true ;
789
catch ( Throwable t ) {
797
if (null != outSocket) {
798
outSocket.shutdownOutput();
805
catch (Exception e) {
810
if (inSocket != null) {
811
inSocket.shutdownInput();
818
catch (Exception e) {
821
myConnection.wakeUp();
825
private String getEncoding() {
827
return XMLUtils.getEncoding();
829
} catch (Throwable t){
836
if ( inSocket != null ) {
839
if ( outSocket != null ) {
854
catch ( Exception e ) {
862
* a connection listens to a single current connection
864
class Connection extends Thread {
869
JTextArea inputText = null ;
870
JScrollPane inputScroll = null ;
871
JTextArea outputText = null ;
872
JScrollPane outputScroll = null ;
873
Socket inSocket = null ;
874
Socket outSocket = null ;
875
Thread clientThread = null ;
876
Thread serverThread = null ;
877
SocketRR rr1 = null ;
878
SocketRR rr2 = null ;
879
InputStream inputStream = null ;
881
String HTTPProxyHost = null ;
882
int HTTPProxyPort = 80 ;
883
private SlowLinkSimulator slowLink;
885
public Connection(Listener l) {
887
HTTPProxyHost = l.HTTPProxyHost ;
888
HTTPProxyPort = l.HTTPProxyPort ;
889
slowLink =l.slowLink;
892
public Connection(Listener l, Socket s ) {
898
public Connection(Listener l, InputStream in ) {
908
HTTPProxyHost = System.getProperty( "http.proxyHost" );
909
if ( HTTPProxyHost != null && HTTPProxyHost.equals("") ) {
910
HTTPProxyHost = null ;
913
if ( HTTPProxyHost != null ) {
914
String tmp = System.getProperty( "http.proxyPort" );
916
if ( tmp != null && tmp.equals("") ) {
922
HTTPProxyPort = Integer.parseInt( tmp );
926
if ( inSocket != null ) {
927
fromHost = (inSocket.getInetAddress()).getHostName();
929
fromHost = "resend" ;
933
String dateformat=getMessage("dateformat00", "yyyy-MM-dd HH:mm:ss");
934
DateFormat df = new SimpleDateFormat(dateformat);
936
time = df.format( new Date() );
938
int count = listener.connections.size();
940
listener.tableModel.insertRow(count + 1, new Object[] {
941
getMessage("active00", "Active"),
944
listener.hostField.getText(), ""
947
listener.connections.add( this );
948
inputText = new JTextArea( null, null, 20, 80 );
949
inputScroll = new JScrollPane( inputText );
950
outputText = new JTextArea( null, null, 20, 80 );
951
outputScroll = new JScrollPane( outputText );
953
ListSelectionModel lsm = listener.connectionTable.getSelectionModel();
955
if ( count == 0 || lsm.getLeadSelectionIndex() == 0 ) {
956
listener.outPane.setVisible( false );
957
int divLoc = listener.outPane.getDividerLocation();
959
listener.setLeft( inputScroll );
960
listener.setRight( outputScroll );
962
listener.removeButton.setEnabled(false);
963
listener.removeAllButton.setEnabled(true);
964
listener.saveButton.setEnabled(true);
965
listener.resendButton.setEnabled(true);
966
listener.outPane.setDividerLocation(divLoc);
967
listener.outPane.setVisible( true );
970
String targetHost = listener.hostField.getText();
971
int targetPort = Integer.parseInt(listener.tPortField.getText());
972
int listenPort = Integer.parseInt(listener.portField.getText());
974
InputStream tmpIn1 = inputStream ;
975
OutputStream tmpOut1 = null ;
977
InputStream tmpIn2 = null ;
978
OutputStream tmpOut2 = null ;
980
if ( tmpIn1 == null ) {
981
tmpIn1 = inSocket.getInputStream();
984
if ( inSocket != null ) {
985
tmpOut1 = inSocket.getOutputStream();
988
String bufferedData = null ;
989
StringBuffer buf = null ;
991
int index = listener.connections.indexOf( this );
993
if (listener.isProxyBox.isSelected() || HTTPProxyHost != null) {
994
// Check if we're a proxy
995
byte[] b = new byte[1];
997
buf = new StringBuffer();
1003
len = tmpIn1.read(b, 0, 1);
1007
s = new String( b );
1009
if ( b[0] != '\n' ) {
1015
bufferedData = buf.toString();
1016
inputText.append( bufferedData );
1018
if ( bufferedData.startsWith( "GET " ) ||
1019
bufferedData.startsWith( "POST " ) ||
1020
bufferedData.startsWith( "PUT " ) ||
1021
bufferedData.startsWith( "DELETE " ) ) {
1025
start = bufferedData.indexOf( ' ' ) + 1;
1026
while ( bufferedData.charAt(start) == ' ' ) {
1029
end = bufferedData.indexOf( ' ', start );
1030
String urlString = bufferedData.substring( start, end );
1032
if ( urlString.charAt(0) == '/' ) {
1033
urlString = urlString.substring(1);
1035
if ( listener.isProxyBox.isSelected() ) {
1036
url = new URL( urlString );
1037
targetHost = url.getHost();
1038
targetPort = url.getPort();
1039
if ( targetPort == -1 ) {
1043
listener.tableModel.setValueAt( targetHost, index + 1,
1045
bufferedData = bufferedData.substring( 0, start) +
1047
bufferedData.substring( end );
1050
url = new URL( "http://" + targetHost + ":" +
1051
targetPort + "/" + urlString );
1053
listener.tableModel.setValueAt( targetHost, index + 1,
1055
bufferedData = bufferedData.substring( 0, start) +
1056
url.toExternalForm() +
1057
bufferedData.substring( end );
1059
targetHost = HTTPProxyHost ;
1060
targetPort = HTTPProxyPort ;
1067
// Change Host: header to point to correct host
1069
byte[] b1 = new byte[1];
1071
buf = new StringBuffer();
1073
String lastLine = null ;
1078
len = tmpIn1.read(b1, 0, 1);
1082
s1 = new String( b1 );
1084
if ( b1[0] != '\n' ) {
1087
// we have a complete line
1088
String line = buf.toString();
1091
// check to see if we have found Host: header
1092
if (line.startsWith("Host: ")) {
1093
// we need to update the hostname to target host
1094
String newHost = "Host: " + targetHost + ":" + listenPort + "\r\n";
1096
bufferedData = bufferedData.concat(newHost);
1099
// add it to our headers so far
1100
if (bufferedData == null) {
1101
bufferedData = line;
1103
bufferedData = bufferedData.concat(line);
1107
if (line.equals("\r\n")) {
1110
if ("\n".equals(lastLine) && line.equals("\n")) {
1115
if ( bufferedData != null ) {
1116
inputText.append( bufferedData );
1117
int idx = bufferedData.length() < 50 ? bufferedData.length() : 50;
1118
s1 = bufferedData.substring( 0, idx );
1119
int i = s1.indexOf('\n');
1122
s1 = s1.substring(0, i - 1);
1126
s1 = s1.substring(0, 51);
1127
listener.tableModel.setValueAt( s1, index + 1,
1132
if ( targetPort == -1 ) {
1135
outSocket = new Socket(targetHost, targetPort );
1137
tmpIn2 = outSocket.getInputStream();
1138
tmpOut2 = outSocket.getOutputStream();
1140
if ( bufferedData != null ) {
1141
byte[] b = bufferedData.getBytes();
1143
slowLink.pump(b.length);
1146
boolean format = listener.xmlFormatBox.isSelected();
1147
boolean numeric = listener.numericBox.isSelected();
1150
//this is the channel to the endpoint
1151
rr1 = new SocketRR(this, inSocket, tmpIn1, outSocket,
1152
tmpOut2, inputText, format, numeric,
1153
listener.tableModel, index + 1, "request:", slowLink);
1154
//create the response slow link from the inbound slow link
1155
SlowLinkSimulator responseLink = new SlowLinkSimulator(slowLink);
1156
//this is the channel from the endpoint
1157
rr2 = new SocketRR( this, outSocket, tmpIn2, inSocket,
1158
tmpOut1, outputText, format, numeric,
1159
null, 0, "response:", responseLink);
1161
while ( rr1 != null || rr2 != null ) {
1162
// Only loop as long as the connection to the target
1163
// machine is available - once that's gone we can stop.
1164
// The old way, loop until both are closed, left us
1165
// looping forever since no one closed the 1st one.
1166
// while( !rr2.isDone() )
1167
if (null != rr1 && rr1.isDone()) {
1168
if ( index >= 0 && rr2 != null) {
1169
listener.tableModel.setValueAt(getMessage("resp00", "Resp"),
1170
1 + index, STATE_COLUMN );
1174
if (null != rr2 && rr2.isDone()) {
1175
if ( index >= 0 && rr1 != null ) {
1176
listener.tableModel.setValueAt(getMessage("req00", "Req"),
1177
1 + index, STATE_COLUMN );
1182
// Thread.sleep( 10 );
1183
synchronized ( this) {
1184
this.wait(1000); //Safety just incase we're not told to wake up.
1188
// System.out.println("Done ");
1196
if ( inSocket != null ) {
1205
listener.tableModel.setValueAt(getMessage("done00", "Done"),
1206
1 + index, STATE_COLUMN );
1210
catch ( Exception e ) {
1211
StringWriter st = new StringWriter();
1212
PrintWriter wr = new PrintWriter(st);
1213
int index = listener.connections.indexOf( this );
1216
listener.tableModel.setValueAt( getMessage("error00", "Error"), 1 + index, STATE_COLUMN );
1218
e.printStackTrace(wr);
1220
if(outputText!=null) {
1221
outputText.append( st.toString() );
1223
//something went wrong before we had the output area
1224
System.out.println(st.toString());
1230
synchronized void wakeUp() {
1234
public void halt() {
1236
if ( rr1 != null ) {
1239
if ( rr2 != null ) {
1242
if ( inSocket != null ) {
1246
if ( outSocket != null ) {
1251
catch ( Exception e ) {
1252
e.printStackTrace();
1256
public void remove() {
1261
index = listener.connections.indexOf( this );
1262
listener.tableModel.removeRow( index + 1 );
1263
listener.connections.remove( index );
1265
catch ( Exception e ) {
1266
System.err.println("index:=" + index + this );
1267
e.printStackTrace();
1274
* this is one of the tabbed panels that acts as the actual proxy
1276
class Listener extends JPanel {
1277
public Socket inputSocket = null ;
1278
public Socket outputSocket = null ;
1279
public JTextField portField = null ;
1280
public JTextField hostField = null ;
1281
public JTextField tPortField = null ;
1282
public JCheckBox isProxyBox = null ;
1283
public JButton stopButton = null ;
1284
public JButton removeButton = null ;
1285
public JButton removeAllButton = null ;
1286
public JCheckBox xmlFormatBox = null ;
1287
public JCheckBox numericBox = null ;
1288
public JButton saveButton = null ;
1289
public JButton resendButton = null ;
1290
public JButton switchButton = null ;
1291
public JButton closeButton = null ;
1292
public JTable connectionTable = null ;
1293
public DefaultTableModel tableModel = null ;
1294
public JSplitPane outPane = null ;
1295
public ServerSocket sSocket = null ;
1296
public SocketWaiter sw = null ;
1297
public JPanel leftPanel = null ;
1298
public JPanel rightPanel = null ;
1299
public JTabbedPane notebook = null ;
1300
public String HTTPProxyHost = null ;
1301
public int HTTPProxyPort = 80 ;
1302
public int delayBytes = 0;
1303
public int delayTime = 0;
1304
public SlowLinkSimulator slowLink;
1306
public final Vector connections = new Vector();
1316
* @param slowLink optional reference to a slow connection
1318
public Listener(JTabbedPane _notebook, String name,
1319
int listenPort, String host, int targetPort,
1320
boolean isProxy, SlowLinkSimulator slowLink) {
1321
notebook = _notebook ;
1322
if ( name == null ) {
1323
name = getMessage("port01", "Port") + " " + listenPort ;
1325
//set the slow link to the passed down link
1326
if(slowLink!=null) {
1327
this.slowLink=slowLink;
1329
//or make up a no-op one.
1330
this.slowLink=new SlowLinkSimulator(0,0);
1332
this.setLayout( new BorderLayout() );
1334
// 1st component is just a row of labels and 1-line entry fields
1335
/////////////////////////////////////////////////////////////////////
1336
JPanel top = new JPanel();
1338
top.setLayout( new BoxLayout(top, BoxLayout.X_AXIS) );
1339
top.setBorder(BorderFactory.createEmptyBorder(5, 5, 5, 5));
1340
final String start = getMessage("start00", "Start");
1342
top.add( stopButton = new JButton( start ) );
1343
top.add( Box.createRigidArea(new Dimension(5, 0)) );
1344
top.add( new JLabel( " " + getMessage("listenPort01", "Listen Port:") + " ", SwingConstants.RIGHT ) );
1345
top.add( portField = new JTextField( "" + listenPort, 4 ) );
1346
top.add( new JLabel( " " + getMessage("host00", "Host:"), SwingConstants.RIGHT ) );
1347
top.add( hostField = new JTextField( host, 30 ) );
1348
top.add( new JLabel( " " + getMessage("port02", "Port:") + " ", SwingConstants.RIGHT ) );
1349
top.add( tPortField = new JTextField( "" + targetPort, 4 ) );
1350
top.add( Box.createRigidArea(new Dimension(5, 0)) );
1351
top.add( isProxyBox = new JCheckBox(getMessage("proxy00", "Proxy")) );
1353
isProxyBox.addChangeListener( new BasicButtonListener(isProxyBox) {
1354
public void stateChanged(ChangeEvent event) {
1355
JCheckBox box = (JCheckBox) event.getSource();
1356
boolean state = box.isSelected();
1358
tPortField.setEnabled( !state );
1359
hostField.setEnabled( !state );
1364
isProxyBox.setSelected(isProxy);
1366
portField.setEditable(false);
1367
portField.setMaximumSize(new Dimension(50, Short.MAX_VALUE) );
1368
hostField.setEditable(false);
1369
hostField.setMaximumSize(new Dimension(85, Short.MAX_VALUE) );
1370
tPortField.setEditable(false);
1371
tPortField.setMaximumSize(new Dimension(50, Short.MAX_VALUE) );
1373
stopButton.addActionListener( new ActionListener() {
1374
public void actionPerformed(ActionEvent event) {
1375
if ( getMessage("stop00", "Stop").equals(event.getActionCommand()) ) {
1378
if ( start.equals(event.getActionCommand()) ) {
1385
this.add( top, BorderLayout.NORTH );
1387
// 2nd component is a split pane with a table on the top
1388
// and the request/response text areas on the bottom
1389
/////////////////////////////////////////////////////////////////////
1391
tableModel = new DefaultTableModel(new String[] {
1392
getMessage("state00", "State"),
1393
getMessage("time00", "Time"),
1394
getMessage("requestHost00", "Request Host"),
1395
getMessage("targetHost", "Target Host"),
1396
getMessage("request00", "Request...")
1399
tableModel.addRow( new Object[] {
1400
"---", getMessage("mostRecent00", "Most Recent"), "---", "---", "---"
1404
connectionTable = new JTable(1, 2);
1405
connectionTable.setModel( tableModel );
1406
connectionTable.setSelectionMode(ListSelectionModel.MULTIPLE_INTERVAL_SELECTION);
1407
// Reduce the STATE column and increase the REQ column
1410
col = connectionTable.getColumnModel().getColumn(STATE_COLUMN);
1411
col.setMaxWidth( col.getPreferredWidth() / 2 );
1412
col = connectionTable.getColumnModel().getColumn(REQ_COLUMN);
1413
col.setPreferredWidth( col.getPreferredWidth() * 2 );
1416
ListSelectionModel sel = connectionTable.getSelectionModel();
1418
sel.addListSelectionListener( new ListSelectionListener() {
1419
public void valueChanged(ListSelectionEvent event) {
1420
if (event.getValueIsAdjusting()) {
1423
ListSelectionModel m = (ListSelectionModel) event.getSource();
1424
int divLoc = outPane.getDividerLocation();
1426
if (m.isSelectionEmpty()) {
1427
setLeft( new JLabel(" " + getMessage("wait00", "Waiting for Connection...") ) );
1428
setRight( new JLabel("") );
1429
removeButton.setEnabled(false);
1430
removeAllButton.setEnabled(false);
1431
saveButton.setEnabled(false);
1432
resendButton.setEnabled(false);
1435
int row = m.getLeadSelectionIndex();
1438
if ( connections.size() == 0 ) {
1439
setLeft(new JLabel(" " + getMessage("wait00", "Waiting for connection...")));
1440
setRight(new JLabel(""));
1441
removeButton.setEnabled(false);
1442
removeAllButton.setEnabled(false);
1443
saveButton.setEnabled(false);
1444
resendButton.setEnabled(false);
1447
Connection conn = (Connection) connections.lastElement();
1449
setLeft( conn.inputScroll );
1450
setRight( conn.outputScroll );
1451
removeButton.setEnabled(false);
1452
removeAllButton.setEnabled(true);
1453
saveButton.setEnabled(true);
1454
resendButton.setEnabled(true);
1458
Connection conn = (Connection) connections.get(row - 1);
1460
setLeft( conn.inputScroll );
1461
setRight( conn.outputScroll );
1462
removeButton.setEnabled(true);
1463
removeAllButton.setEnabled(true);
1464
saveButton.setEnabled(true);
1465
resendButton.setEnabled(true);
1468
outPane.setDividerLocation(divLoc);
1473
JPanel tablePane = new JPanel();
1475
tablePane.setLayout( new BorderLayout() );
1477
JScrollPane tableScrollPane = new JScrollPane( connectionTable );
1479
tablePane.add( tableScrollPane, BorderLayout.CENTER );
1480
JPanel buttons = new JPanel();
1482
buttons.setLayout( new BoxLayout(buttons, BoxLayout.X_AXIS) );
1483
buttons.setBorder( BorderFactory.createEmptyBorder(5, 5, 5, 5) );
1484
final String removeSelected = getMessage("removeSelected00", "Remove Selected");
1486
buttons.add( removeButton = new JButton(removeSelected) );
1487
buttons.add( Box.createRigidArea(new Dimension(5, 0)) );
1488
final String removeAll = getMessage("removeAll00", "Remove All");
1490
buttons.add( removeAllButton = new JButton(removeAll) );
1491
tablePane.add( buttons, BorderLayout.SOUTH );
1493
removeButton.setEnabled( false );
1494
removeButton.addActionListener( new ActionListener() {
1495
public void actionPerformed(ActionEvent event) {
1496
if ( removeSelected.equals(event.getActionCommand()) ) {
1503
removeAllButton.setEnabled( false );
1504
removeAllButton.addActionListener( new ActionListener() {
1505
public void actionPerformed(ActionEvent event) {
1506
if ( removeAll.equals(event.getActionCommand()) ) {
1513
// Add Response Section
1514
/////////////////////////////////////////////////////////////////////
1515
JPanel pane2 = new JPanel();
1517
pane2.setLayout( new BorderLayout() );
1519
leftPanel = new JPanel();
1520
leftPanel.setAlignmentX( Component.LEFT_ALIGNMENT );
1521
leftPanel.setLayout( new BoxLayout(leftPanel, BoxLayout.Y_AXIS) );
1522
leftPanel.add( new JLabel(" " + getMessage("request01", "Request")) );
1523
leftPanel.add( new JLabel(" " + getMessage("wait01", "Waiting for connection") ));
1525
rightPanel = new JPanel();
1526
rightPanel.setLayout( new BoxLayout(rightPanel, BoxLayout.Y_AXIS) );
1527
rightPanel.add( new JLabel(" " + getMessage("response00", "Response")) );
1528
rightPanel.add( new JLabel("") );
1530
outPane = new JSplitPane(0, leftPanel, rightPanel );
1531
outPane.setDividerSize(4);
1532
pane2.add( outPane, BorderLayout.CENTER );
1534
JPanel bottomButtons = new JPanel();
1536
bottomButtons.setLayout( new BoxLayout(bottomButtons, BoxLayout.X_AXIS));
1537
bottomButtons.setBorder(BorderFactory.createEmptyBorder(5, 5, 5, 5));
1538
bottomButtons.add( xmlFormatBox = new JCheckBox( getMessage("xmlFormat00", "XML Format") ) );
1539
bottomButtons.add( numericBox = new JCheckBox( getMessage("numericEnc00", "Numeric" ) ) );
1540
bottomButtons.add( Box.createRigidArea(new Dimension(5, 0)) );
1541
final String save = getMessage("save00", "Save");
1543
bottomButtons.add( saveButton = new JButton( save ) );
1544
bottomButtons.add( Box.createRigidArea(new Dimension(5, 0)) );
1545
final String resend = getMessage("resend00", "Resend");
1547
bottomButtons.add( resendButton = new JButton( resend ) );
1548
bottomButtons.add( Box.createRigidArea(new Dimension(5, 0)) );
1549
final String switchStr = getMessage("switch00", "Switch Layout");
1551
bottomButtons.add( switchButton = new JButton( switchStr ) );
1552
bottomButtons.add( Box.createHorizontalGlue() );
1553
final String close = getMessage("close00", "Close");
1555
bottomButtons.add( closeButton = new JButton( close ) );
1556
pane2.add( bottomButtons, BorderLayout.SOUTH );
1558
saveButton.setEnabled( false );
1559
saveButton.addActionListener( new ActionListener() {
1560
public void actionPerformed(ActionEvent event) {
1561
if ( save.equals(event.getActionCommand()) ) {
1568
resendButton.setEnabled( false );
1569
resendButton.addActionListener( new ActionListener() {
1570
public void actionPerformed(ActionEvent event) {
1571
if ( resend.equals(event.getActionCommand()) ) {
1578
switchButton.addActionListener( new ActionListener() {
1579
public void actionPerformed(ActionEvent event) {
1580
if (switchStr.equals(event.getActionCommand()) ) {
1581
int v = outPane.getOrientation();
1585
outPane.setOrientation(1);
1589
outPane.setOrientation(0);
1591
outPane.setDividerLocation(0.5);
1597
closeButton.addActionListener( new ActionListener() {
1598
public void actionPerformed(ActionEvent event) {
1599
if (close.equals(event.getActionCommand()) ) {
1606
JSplitPane pane1 = new JSplitPane( 0 );
1608
pane1.setDividerSize(4);
1609
pane1.setTopComponent( tablePane );
1610
pane1.setBottomComponent( pane2 );
1611
pane1.setDividerLocation( 150 );
1612
this.add( pane1, BorderLayout.CENTER );
1615
////////////////////////////////////////////////////////////////////
1616
sel.setSelectionInterval(0, 0);
1617
outPane.setDividerLocation( 150 );
1618
notebook.addTab( name, this );
1622
public void setLeft(Component left) {
1623
leftPanel.removeAll();
1624
leftPanel.add(left);
1627
public void setRight(Component right) {
1628
rightPanel.removeAll();
1629
rightPanel.add(right);
1632
public void start() {
1633
int port = Integer.parseInt( portField.getText() );
1635
portField.setText( "" + port );
1636
int i = notebook.indexOfComponent( this );
1638
notebook.setTitleAt( i, getMessage("port01", "Port") + " " + port );
1640
int tmp = Integer.parseInt( tPortField.getText() );
1642
tPortField.setText( "" + tmp );
1644
sw = new SocketWaiter( this, port );
1645
stopButton.setText( getMessage("stop00", "Stop") );
1647
portField.setEditable(false);
1648
hostField.setEditable(false);
1649
tPortField.setEditable(false);
1650
isProxyBox.setEnabled(false);
1653
public void close() {
1655
notebook.remove( this );
1658
public void stop() {
1660
for ( int i = 0 ; i < connections.size() ; i++ ) {
1661
Connection conn = (Connection) connections.get( i );
1666
stopButton.setText( getMessage("start00", "Start") );
1667
portField.setEditable(true);
1668
hostField.setEditable(true);
1669
tPortField.setEditable(true);
1670
isProxyBox.setEnabled(true);
1672
catch ( Exception e ) {
1673
e.printStackTrace();
1677
public void remove() {
1678
ListSelectionModel lsm = connectionTable.getSelectionModel();
1679
int bot = lsm.getMinSelectionIndex();
1680
int top = lsm.getMaxSelectionIndex();
1682
for ( int i = top ; i >= bot ; i-- ) {
1683
((Connection) connections.get(i - 1)).remove();
1685
if ( bot > connections.size() ) {
1686
bot = connections.size();
1688
lsm.setSelectionInterval(bot, bot);
1691
public void removeAll() {
1692
ListSelectionModel lsm = connectionTable.getSelectionModel();
1693
lsm.clearSelection();
1694
while ( connections.size() > 0 ) {
1695
((Connection) connections.get(0)).remove();
1698
lsm.setSelectionInterval(0, 0);
1701
public void save() {
1702
JFileChooser dialog = new JFileChooser( "." );
1703
int rc = dialog.showSaveDialog( this );
1705
if ( rc == JFileChooser.APPROVE_OPTION ) {
1707
File file = dialog.getSelectedFile();
1708
FileOutputStream out = new FileOutputStream( file );
1710
ListSelectionModel lsm = connectionTable.getSelectionModel();
1712
rc = lsm.getLeadSelectionIndex();
1715
for (Iterator i = connections.iterator();i.hasNext();n++) {
1716
Connection conn = (Connection)i.next();
1717
if (lsm.isSelectedIndex(n + 1) ||
1718
(!(i.hasNext()) && lsm.getLeadSelectionIndex() == 0)) {
1719
rc = Integer.parseInt( portField.getText() );
1720
out.write("\n==============\n".getBytes());
1721
out.write( ((getMessage("listenPort01", "Listen Port:") + " " + rc + "\n" )).getBytes() );
1722
out.write( (getMessage("targetHost01", "Target Host:") + " " + hostField.getText() +
1723
"\n" ).getBytes() );
1724
rc = Integer.parseInt( tPortField.getText() );
1725
out.write( ((getMessage("targetPort01", "Target Port:") + " " + rc + "\n" )).getBytes() );
1727
out.write( (("==== " + getMessage("request01", "Request") + " ====\n" )).getBytes() );
1728
out.write( conn.inputText.getText().getBytes() );
1730
out.write( (("==== " + getMessage("response00", "Response") + " ====\n" )).getBytes() );
1731
out.write( conn.outputText.getText().getBytes() );
1732
out.write("\n==============\n".getBytes());
1738
catch ( Exception e ) {
1739
e.printStackTrace();
1744
public void resend() {
1748
ListSelectionModel lsm = connectionTable.getSelectionModel();
1750
rc = lsm.getLeadSelectionIndex();
1752
rc = connections.size();
1754
Connection conn = (Connection) connections.get( rc - 1 );
1757
lsm.clearSelection();
1758
lsm.setSelectionInterval(0, 0);
1761
InputStream in = null ;
1762
String text = conn.inputText.getText();
1764
// Fix Content-Length HTTP headers
1765
if ( text.startsWith("POST ") || text.startsWith("GET ") ) {
1766
// System.err.println("IN CL" );
1767
int pos1, pos2, pos3 ;
1768
String body, headers, headers1, header2 ;
1770
pos3 = text.indexOf( "\n\n" );
1772
pos3 = text.indexOf( "\r\n\r\n" );
1781
headers = text.substring( 0, pos3 );
1783
pos1 = headers.indexOf( "Content-Length:" );
1784
// System.err.println("pos1: " + pos1 );
1785
// System.err.println("pos3: " + pos3 );
1787
int newLen = text.length() - pos3 ;
1789
pos2 = headers.indexOf( "\n", pos1 );
1791
System.err.println("CL: " + newLen );
1792
System.err.println("Hdrs: '" + headers + "'" );
1793
System.err.println("subTEXT: '" +
1794
text.substring(pos3, pos3 + newLen) + "'");
1795
text = headers.substring(0, pos1) +
1796
"Content-Length: " + newLen + "\n" +
1797
headers.substring(pos2 + 1) +
1798
text.substring(pos3) ;
1799
System.err.println("\nTEXT: '" + text + "'" );
1803
in = new ByteArrayInputStream( text.getBytes() );
1804
new Connection( this, in );
1806
catch ( Exception e ) {
1807
e.printStackTrace();
1813
public tcpmon(int listenPort, String targetHost, int targetPort, boolean embedded) {
1814
super ( getMessage("tcpmon00", "TCPMonitor") );
1816
notebook = new JTabbedPane();
1817
this.getContentPane().add( notebook );
1819
new AdminPage( notebook, getMessage("admin00", "Admin") );
1821
if ( listenPort != 0 ) {
1824
if ( targetHost == null ) {
1825
l = new Listener( notebook, null, listenPort,
1826
targetHost, targetPort, true, null);
1828
l = new Listener( notebook, null, listenPort,
1829
targetHost, targetPort, false, null);
1831
notebook.setSelectedIndex( 1 );
1833
l.HTTPProxyHost = System.getProperty( "http.proxyHost" );
1834
if ( l.HTTPProxyHost != null && l.HTTPProxyHost.equals("") ) {
1835
l.HTTPProxyHost = null ;
1838
if ( l.HTTPProxyHost != null ) {
1839
String tmp = System.getProperty( "http.proxyPort" );
1841
if ( tmp != null && tmp.equals("") ) {
1844
if ( tmp == null ) {
1845
l.HTTPProxyPort = 80 ;
1847
l.HTTPProxyPort = Integer.parseInt( tmp );
1853
this.setDefaultCloseOperation(EXIT_ON_CLOSE);
1856
this.setSize( 600, 600 );
1857
this.setVisible( true );
1860
public tcpmon(int listenPort, String targetHost, int targetPort) {
1861
this(listenPort, targetHost, targetPort, false);
1867
private static void setupLookAndFeel(boolean nativeLookAndFeel) throws Exception {
1868
String classname= UIManager.getCrossPlatformLookAndFeelClassName();
1869
if(nativeLookAndFeel) {
1870
classname= UIManager.getSystemLookAndFeelClassName();
1872
String lafProperty= System.getProperty("tcpmon.laf", "");
1873
if(lafProperty.length()>0) {
1874
classname=lafProperty;
1877
UIManager.setLookAndFeel(classname);
1878
} catch (ClassNotFoundException e) {
1879
e.printStackTrace();
1880
} catch (InstantiationException e) {
1881
e.printStackTrace();
1882
} catch (IllegalAccessException e) {
1883
e.printStackTrace();
1884
} catch (UnsupportedLookAndFeelException e) {
1885
e.printStackTrace();
1889
* this is our main method
1892
public static void main(String[] args) {
1894
//switch between swing L&F here
1895
setupLookAndFeel(true);
1896
if ( args.length == 3 ) {
1897
int p1 = Integer.parseInt( args[0] );
1898
int p2 = Integer.parseInt( args[2] );
1900
new tcpmon( p1, args[1], p2 );
1902
else if ( args.length == 1 ) {
1903
int p1 = Integer.parseInt( args[0] );
1905
new tcpmon( p1, null, 0 );
1907
else if ( args.length != 0 ) {
1908
System.err.println( getMessage("usage00", "Usage:")
1909
+ " tcpmon [listenPort targetHost targetPort]\n");
1912
new tcpmon(0, null, 0);
1915
catch ( Throwable exp ) {
1916
exp.printStackTrace();
1920
// Message resource bundle.
1921
private static ResourceBundle messages = null;
1924
* Get the message with the given key. There are no arguments for this message.
1926
public static String getMessage(String key, String defaultMsg) {
1928
if (messages == null) {
1929
initializeMessages();
1931
return messages.getString(key);
1932
} catch (Throwable t) {
1933
// If there is any problem whatsoever getting the internationalized
1934
// message, return the default.
1940
* Load the resource bundle messages from the properties file. This is ONLY done when it is
1941
* needed. If no messages are printed (for example, only Wsdl2java is being run in non-
1942
* verbose mode) then there is no need to read the properties file.
1944
private static void initializeMessages() {
1945
messages = ResourceBundle.getBundle("org.apache.axis.utils.tcpmon");
1946
} // initializeMessages
1949
* a text field with a restricted set of characters
1951
static class RestrictedTextField extends JTextField {
1952
protected String validText;
1954
public RestrictedTextField(String validText) {
1955
setValidText(validText);
1958
public RestrictedTextField(int columns, String validText) {
1960
setValidText(validText);
1963
public RestrictedTextField(String text, String validText) {
1965
setValidText(validText);
1968
public RestrictedTextField(String text, int columns, String validText) {
1969
super(text, columns);
1970
setValidText(validText);
1973
private void setValidText(String validText) {
1974
this.validText = validText;
1978
* fascinatingly, this method is called in the super() constructor,
1979
* meaning before we are fully initialized. C++ doesnt actually permit
1980
* such a situation, but java clearly does...
1981
* @return a new document
1983
public Document createDefaultModel() {
1984
return new RestrictedDocument();
1988
* this class strips out invaid chars
1990
class RestrictedDocument extends PlainDocument {
1994
* Constructs a plain text document. A default model using
1995
* <code>GapContent</code> is constructed and set.
1997
public RestrictedDocument() {
2002
* add a string; only those chars in the valid text list are allowed
2006
* @throws BadLocationException
2008
public void insertString(int offset, String string, AttributeSet attributes)
2009
throws BadLocationException {
2011
if (string == null) {
2014
int len = string.length();
2015
StringBuffer buffer = new StringBuffer(string.length());
2016
for (int i = 0; i < len; i++) {
2017
char ch = string.charAt(i);
2018
if (validText.indexOf(ch) >= 0) {
2022
super.insertString(offset, new String(buffer), attributes);
2024
} //end class NumericDocument
2028
* because we cant use Java1.4's JFormattedTextField, here is
2029
* a class that accepts numbers only
2031
static class NumberField extends RestrictedTextField {
2033
private static final String VALID_TEXT = "0123456789";
2036
* Constructs a new <code>TextField</code>. A default model is created,
2037
* the initial string is <code>null</code>,
2038
* and the number of columns is set to 0.
2040
public NumberField() {
2045
* Constructs a new empty <code>TextField</code> with the specified
2046
* number of columns.
2047
* A default model is created and the initial string is set to
2048
* <code>null</code>.
2050
* @param columns the number of columns to use to calculate
2051
* the preferred width; if columns is set to zero, the
2052
* preferred width will be whatever naturally results from
2053
* the component implementation
2055
public NumberField(int columns) {
2056
super(columns, VALID_TEXT);
2061
* get the int value of a field, any invalid (non int) field returns
2063
* @param def default value
2064
* @return the field contents
2066
public int getValue(int def) {
2068
String text = getText();
2069
if (text != null && text.length() != 0) {
2071
result = Integer.parseInt(text);
2072
} catch (NumberFormatException e) {
2080
* set the text to a numeric value
2081
* @param value number to assign
2083
public void setValue(int value) {
2084
setText(Integer.toString(value));
2087
} //end class NumericTextField
2092
static class HostnameField extends RestrictedTextField {
2093
//list of valid chars in a hostname
2094
private static final String VALID_TEXT =
2095
"0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWZYZ-.";
2097
public HostnameField(int columns) {
2098
super(columns, VALID_TEXT);
2101
public HostnameField() {
added
removed
src/org/apache/axis/utils/tcpmon.java
