testconnection.java

SMPP（点到点短消息协议）的java实现

package ie.omk.smpp;

import ie.omk.smpp.message.BindReceiverResp;
import ie.omk.smpp.message.DeliverSM;
import ie.omk.smpp.message.SMPPPacket;
import ie.omk.smpp.message.SubmitSM;
import ie.omk.smpp.message.UnbindResp;
import ie.omk.smpp.net.StreamLink;
import ie.omk.smpp.util.Latin1Encoding;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.UnsupportedEncodingException;
import java.util.Arrays;

import junit.framework.TestCase;

public class TestConnection extends TestCase {

    private static final String TEST_MESSAGE = "Test M�ssage @�";

    public TestConnection(String name) {
        super(name);
    }

    /**
     * Test the functionality of the per-connection default alphabet.
     */
    public void testDefaultAlphabet() {
        try {
            // Set up some packets for the connection to read!
            ByteArrayOutputStream bos = new ByteArrayOutputStream();

            BindReceiverResp br = new BindReceiverResp();
            br.setSequenceNum(1);
            br.setSystemId("testSMSC");
            br.writeTo(bos);

            DeliverSM dsm = new DeliverSM();
            dsm.setSequenceNum(1);
            dsm.setMessage(new Latin1Encoding().encodeString(
                    TEST_MESSAGE));
            dsm.writeTo(bos);

            UnbindResp ur = new UnbindResp();
            ur.setSequenceNum(2);
            ur.writeTo(bos);

            ByteArrayInputStream bis = new ByteArrayInputStream(bos
                    .toByteArray());
            bos = new ByteArrayOutputStream();

            StreamLink link = new StreamLink(bis, bos);
            Connection conn = new Connection(link);
            conn.setDefaultAlphabet(new Latin1Encoding());

            SubmitSM sm = (SubmitSM) conn.newInstance(SMPPPacket.SUBMIT_SM);
            sm.setMessageText(TEST_MESSAGE);
            try {
                byte[] expected = TEST_MESSAGE.getBytes("iso8859-1");
                assertTrue(Arrays.equals(expected, sm.getMessage()));
            } catch (UnsupportedEncodingException x) {
                // bullshit! Latin1 is a Java spec requirement
                x.printStackTrace(System.err);
                fail();
            }

            SMPPPacket p;
            p = conn.bind(Connection.RECEIVER, "test", "test", "test", 0, 0,
                    "6712345");
            if (p.getCommandId() != SMPPPacket.BIND_RECEIVER_RESP) {
                // but that's what I just put there!
                fail("Something wrong with the test class - unexpected packet");
            }

            p = conn.readNextPacket();
            if (p.getCommandId() != SMPPPacket.DELIVER_SM) {
                fail("Something wrong with the test class - unexpected packet");
            } else {
                try {
                    byte[] expected = TEST_MESSAGE.getBytes("iso8859-1");
                    assertTrue(Arrays.equals(expected, p.getMessage()));
               } catch (UnsupportedEncodingException x) {
                    x.printStackTrace(System.err);
                    fail();
               }
            }

            p = conn.unbind();
            if (p.getCommandId() != SMPPPacket.UNBIND_RESP) {
                fail("Something wrong with the test class - unexpected packet");
            }
        } catch (Exception x) {
            x.printStackTrace(System.err);
            fail();
        }
    }
}