serialconnector.java

无线通信的主要编程软件,是无线通信工作人员的必备工具,关天相关教程我会在后续传上.

            this.tossimSerialLabel.setEnabled(false);
            this.tossimSerialAddressTextField.setEnabled(false);
            
        }
    }//GEN-LAST:event_connectionRadioButtonTossimSerialItemStateChanged
                
    private void packetSizeTextFieldActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_packetSizeTextFieldActionPerformed
        try{
            maxMsgLength=(short)(Integer.parseInt(packetSizeTextField.getText()) & 0xff);
        }catch(Exception e){
            this.packetSizeTextField.setText(Integer.toString(maxMsgLength));
        }
        
    }//GEN-LAST:event_packetSizeTextFieldActionPerformed
    
    private void ssButtonActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_ssButtonActionPerformed
        
        if(this.ssButton.getText().equalsIgnoreCase("Start Port")){
            
            prefs.put("ComPort",this.comPortTextField.getText());
            prefs.put("ComSpeed",this.comSpeedTextField.getText());
           //prefs.put("SyncedComPort",this.sComPortTextField.getText());
            //prefs.put("SyncedComSpeed",this.sComPortSpeedTextField.getText());
            prefs.put("IpAddress",this.ipAddressTextField.getText());
            prefs.put("IpPort",this.ipPortTextField.getText());
            prefs.put("GroupId",this.groupTextField.getText());
            
            prefs.put("TossimIP",this.tossimRadioAddressTextField.getText());
            prefs.put("TossimSerialIP",this.tossimSerialAddressTextField.getText());
            prefs.put("OtherString",this.otherConnTextField.getText());
            
            String value = groupTextField.getText();
            if(value.trim().toUpperCase().startsWith("0X"))
                group=Short.parseShort(value.trim().substring(2),16);
            else
                group=Short.parseShort(value.trim());
            
            
            try{ 
                String connection = "";
                this.connectionRadioButtonCOM.setEnabled(false);
                //this.connectionRadioButtonSCOM.setEnabled(false);
                this.connectionRadioButtonIP.setEnabled(false);
                this.connectionRadioButtonTossim.setEnabled(false);
                this.connectionRadioButtonTossimSerial.setEnabled(false);
                this.connectionRadioButtonOther.setEnabled(false);
                this.oldProtocolCheckBox.setEnabled(false);
                this.threadingCheckBox.setEnabled(false);
                
                //this.connectionRadioButtonLH.setEnabled(false);
                
                setRBstate(false);
                
                //javax.swing.ButtonModel selected = this.buttonGroup1.getSelection();
                if(this.connectionRadioButtonCOM == lastSelected)
                {
                    if (oldProtocolCheckBox.isSelected())
                        connection += "old-";
                    connection += "serial@" + this.comPortTextField.getText().trim() + ":" + this.comSpeedTextField.getText().trim();
                    if (oldProtocolCheckBox.isSelected())
                        connection += "," + maxMsgLength;
                }else if(this.connectionRadioButtonIP == lastSelected)
                {
                    connection += "sf@" + this.ipAddressTextField.getText().trim() + ":" + this.ipPortTextField.getText().trim();
                }else if(this.connectionRadioButtonTossimSerial == lastSelected)
                {
                    connection += "tossim-serial@" + this.tossimSerialAddressTextField.getText().trim();
                }else if(this.connectionRadioButtonTossim == lastSelected)
                {
                    connection += "tossim-radio@" + this.tossimRadioAddressTextField.getText().trim();
                }else if(this.connectionRadioButtonOther == lastSelected)
                {
                    connection = otherConnTextField.getText().trim();
                }else {
                    throw new Exception();
                }

                System.out.println("Connecting to: " + connection);

                serialStub = BuildSource.makePacketSource(connection);

                serialStub.open(net.tinyos.util.PrintStreamMessenger.err);
                
                /*javax.swing.ButtonModel selected = this.buttonGroup1.getSelection();
                
                
                if(this.connectionRadioButtonCOM.getModel() == selected)
                    serialStub = new SerialPortStub(this.comPortTextField.getText().trim(), maxMsgLength, Integer.parseInt(this.comSpeedTextField.getText()));
                if(this.connectionRadioButtonSCOM.getModel() == selected)
                    serialStub = new SyncedCRCSerialPortStub(this.sComPortTextField.getText().trim(), maxMsgLength, Integer.parseInt(this.sComPortSpeedTextField.getText()));
                if(this.connectionRadioButtonIP.getModel() == selected)
                    serialStub = new SerialForwarderStub(ipAddressTextField.getText(), Integer.parseInt(ipPortTextField.getText()), maxMsgLength);
                if(this.connectionRadioButtonLH.getModel() == selected)
                    serialStub = new SerialForwarderStub("", Integer.parseInt(lhPortTextField.getText()), maxMsgLength);
                
             
                
                serialStub.Open();
                */
                distributorThread = new SerialConnector.DistributorThread();
                distributorThread.start();
                packetReader = new SerialConnector.PacketReader();
                packetReader.start();
                //serialStub.registerPacketListener(packetReader);
                
                this.ssButton.setText("Stop Port");
                System.out.println("Connected.");
		messageFactory = new MessageFactory(serialStub);
            }catch(Exception e) {
                System.err.println("Could not connect to local port: " + e.toString());
                this.connectionRadioButtonCOM.setEnabled(true);
                //this.connectionRadioButtonSCOM.setEnabled(true);
                this.connectionRadioButtonIP.setEnabled(true);
                this.connectionRadioButtonTossim.setEnabled(true);
                this.connectionRadioButtonTossimSerial.setEnabled(true);
                this.connectionRadioButtonOther.setEnabled(true);
                //this.connectionRadioButtonLH.setEnabled(true);
                this.oldProtocolCheckBox.setEnabled(true);
                this.threadingCheckBox.setEnabled(true);
                
                this.setRBenable(lastSelected, true);
                this.ssButton.setText("Start Port");
                
            }
            
        }else if(this.ssButton.getText().equalsIgnoreCase("Stop Port")){
            try{
                this.connectionRadioButtonCOM.setEnabled(true);
                //this.connectionRadioButtonSCOM.setEnabled(true);
                this.connectionRadioButtonIP.setEnabled(true);
                this.connectionRadioButtonTossim.setEnabled(true);
                this.connectionRadioButtonTossimSerial.setEnabled(true);
                this.connectionRadioButtonOther.setEnabled(true);
                
                this.oldProtocolCheckBox.setEnabled(true);
                this.threadingCheckBox.setEnabled(true);

                //this.connectionRadioButtonLH.setEnabled(true);
                this.setRBenable(lastSelected, true);
         
                
                packetReader.stopRun();
                distributorThread.end();
                serialStub.close();
                System.out.println("Connection closed.");
                
               
                this.ssButton.setText("Start Port");
                
            }catch(Exception e) {
                System.err.println("Could not terminate connection to local port: " + e.toString());
            }
            
        }
    }//GEN-LAST:event_ssButtonActionPerformed
    
    private void connectionRadioButtonIPItemStateChanged(java.awt.event.ItemEvent evt) {//GEN-FIRST:event_connectionRadioButtonIPItemStateChanged
        if (evt.getStateChange() == ItemEvent.SELECTED) {
            this.ipLabel.setEnabled(true);
            this.ipAddressTextField.setEnabled(true);
            this.ipPortTextField.setEnabled(true);
            this.portLabel.setEnabled(true);
            lastSelected = (ItemRadioButton) connectionRadioButtonIP;
            
        } else if(evt.getStateChange() == ItemEvent.DESELECTED) {
            this.ipLabel.setEnabled(false);
            this.ipAddressTextField.setEnabled(false);
            this.ipPortTextField.setEnabled(false);
            this.portLabel.setEnabled(false);
        }
    }//GEN-LAST:event_connectionRadioButtonIPItemStateChanged
    
    private void connectionRadioButtonCOMItemStateChanged(java.awt.event.ItemEvent evt) {//GEN-FIRST:event_connectionRadioButtonCOMItemStateChanged
        if (evt.getStateChange() == ItemEvent.SELECTED) {
            this.comPortTextField.setEnabled(true);
            this.comSpeedTextField.setEnabled(true);
            this.comPortLabel.setEnabled(true);
            this.speedLabel.setEnabled(true);
            lastSelected = (ItemRadioButton)connectionRadioButtonCOM;
            
        } else if(evt.getStateChange() == ItemEvent.DESELECTED) {
            this.comPortTextField.setEnabled(false);
            this.comSpeedTextField.setEnabled(false);
            this.comPortLabel.setEnabled(false);
            this.speedLabel.setEnabled(false);
            
            
        }
    }//GEN-LAST:event_connectionRadioButtonCOMItemStateChanged
    
    
    // Variables declaration - do not modify//GEN-BEGIN:variables
    private javax.swing.ButtonGroup buttonGroup1;
    private javax.swing.JLabel comPortLabel;
    private javax.swing.JTextField comPortTextField;
    private javax.swing.JTextField comSpeedTextField;
    private javax.swing.JRadioButton connectionRadioButtonCOM;
    private javax.swing.JRadioButton connectionRadioButtonIP;
    private javax.swing.JRadioButton connectionRadioButtonOther;
    private javax.swing.JRadioButton connectionRadioButtonTossim;
    private javax.swing.JRadioButton connectionRadioButtonTossimSerial;
    private javax.swing.JPanel controlPanel;
    private javax.swing.JLabel groupLabel;
    private javax.swing.JTextField groupTextField;
    private javax.swing.JTextField ipAddressTextField;
    private javax.swing.JLabel ipLabel;
    private javax.swing.JTextField ipPortTextField;
    private javax.swing.JSeparator jSeparator1;
    private javax.swing.JSeparator jSeparator2;
    private javax.swing.JPanel mainPanel;
    private javax.swing.JPanel messagePanel;
    private javax.swing.JCheckBox oldProtocolCheckBox;
    private javax.swing.JLabel otherConnLabel;
    private javax.swing.JTextField otherConnTextField;
    private javax.swing.JLabel packetSizeLabel;
    private javax.swing.JTextField packetSizeTextField;
    private javax.swing.JLabel placeholderjLabel;
    private javax.swing.JLabel portLabel;
    private javax.swing.JLabel receivedLabel;
    private javax.swing.JTextField receivedTextField;
    private javax.swing.JLabel sentLabel;
    private javax.swing.JTextField sentTextField;
    private javax.swing.JLabel speedLabel;
    private javax.swing.JButton ssButton;
    private javax.swing.JCheckBox threadingCheckBox;
    private javax.swing.JTextField tossimRadioAddressTextField;
    private javax.swing.JLabel tossimRadioLabel;
    private javax.swing.JTextField tossimSerialAddressTextField;
    private javax.swing.JLabel tossimSerialLabel;
    // End of variables declaration//GEN-END:variables
    
    /*********************************Message sendIF******************************/
    
    public void registerPacketListener(PacketListenerIF packetListener, int messageID){
        java.util.HashSet listenerList;
        if(messageIdRegisterMap.containsKey(new Integer(messageID))) {
            listenerList = (java.util.HashSet) this.messageIdRegisterMap.get(new Integer(messageID));
        }else {
            listenerList = new java.util.HashSet();
            this.messageIdRegisterMap.put(new Integer(messageID),listenerList);
        }
        if(clientRegisterMap.containsKey(packetListener)){
            
            ClientThread clientHandler = (ClientThread)clientRegisterMap.get(packetListener);
            clientHandler.references++;
        }else{
            ClientThread newClientHandler = new ClientThread(packetListener);
            clientRegisterMap.put(packetListener,newClientHandler);
            newClientHandler.references++;
            newClientHandler.start();
        }
        
        listenerList.add(packetListener);
        
    }
    
    public boolean removePacketListener(PacketListenerIF packetListener, int messageID){
        java.util.HashSet listenerList;
        if(messageIdRegisterMap.containsKey(new Integer(messageID))) {