import org.apache.vysper.xmpp.authorization.AccountManagement; //导入依赖的package包/类
public EmbeddedXMPPServer(int port) throws Exception {

        StorageProviderRegistry providerRegistry = new MemoryStorageProviderRegistry();
        AccountManagement accountManagement = (AccountManagement) providerRegistry.retrieve(AccountManagement.class);

        Entity consumer = EntityImpl.parseUnchecked("[email protected]");
        accountManagement.addUser(consumer, "secret");

        Entity producer = EntityImpl.parseUnchecked("[email protected]");
        accountManagement.addUser(producer, "secret");

        TCPEndpoint endpoint = new TCPEndpoint();
        endpoint.setPort(port);

        InputStream stream = EmbeddedXMPPServer.class.getResourceAsStream("/xmpp/server.jks");

        server = new XMPPServer("apache.camel");
        server.setStorageProviderRegistry(providerRegistry);
        server.addEndpoint(endpoint);
        server.setTLSCertificateInfo(stream, "secret");
        server.setSASLMechanisms(Arrays.asList(new SASLMechanism[]{new Anonymous()}));
    }
 

import org.apache.vysper.xmpp.authorization.AccountManagement; //导入依赖的package包/类
public XmppServer (XmppConfiguration configuration)
{
    checkState(configuration != null);
    this.configuration_ = configuration;
    this.server_ = new XMPPServer(configuration.getDomain());
    
    StorageProviderRegistry providerRegistry = new MemoryStorageProviderRegistry();
    this.accountManagement_ = (AccountManagement) providerRegistry.retrieve(AccountManagement.class);
    server_.setStorageProviderRegistry(providerRegistry);
    
    TCPEndpoint tcpEndpoint = new TCPEndpoint();
    tcpEndpoint.setPort(configuration.getTcpPort());
    S2SEndpoint s2sEndpoint = new S2SEndpoint();
    s2sEndpoint.setPort(configuration.getS2SPort());
    
    server_.addEndpoint(tcpEndpoint);
    server_.addEndpoint(s2sEndpoint);
    
    try
    {
        server_.setTLSCertificateInfo(configuration.getCertificate(), configuration.getPassword());
    }
    catch (FileNotFoundException e)
    {
        LOG.error("File {} not found! Trying to look for in the application dir!", configuration.getCertificate().getPath());
        
        File certificateHomeDir = new File(SystemUtils2.getApplicationDataDir(), configuration.getCertificate().getName());
        
        if (certificateHomeDir.exists())
        {
            try
            {
                server_.setTLSCertificateInfo(certificateHomeDir, configuration.getPassword());
            }
            catch (FileNotFoundException e1)
            {
                throw new XMPPFailureException(e1.getMessage(), e1);
            }
        }
        else
        {
            throw new XMPPFailureException(e.getMessage(), e);
        }
    }
}
 

import org.apache.vysper.xmpp.authorization.AccountManagement; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
	domain = UUID.randomUUID().toString().replace("-", "");
	username = UUID.randomUUID().toString().replace("-", "");
	password = UUID.randomUUID().toString().replace("-", "");
	resource = UUID.randomUUID().toString().replace("-", "");
	
       ServerSocket socketServer = new ServerSocket();
       socketServer.bind(null);
       
       port = socketServer.getLocalPort();
       socketServer.close();
       
       StorageProviderRegistry providerRegistry = new MemoryStorageProviderRegistry();

       final Entity adminJID = EntityImpl.parseUnchecked(username + "@" + domain);
       final AccountManagement accountManagement = (AccountManagement) providerRegistry .retrieve(AccountManagement.class);
       
       if (!accountManagement.verifyAccountExists(adminJID)) {
           accountManagement.addUser(adminJID, password);
       }
       
       TCPEndpoint tcpEndpoint = new TCPEndpoint();
       tcpEndpoint.setPort(port);

       try (InputStream certStream = this.getClass().getResourceAsStream("/bogus_mina_tls.cert")) {
		server = new XMPPServer(domain);
        server.addEndpoint(tcpEndpoint);
        server.setStorageProviderRegistry(providerRegistry);
        server.setTLSCertificateInfo(certStream, "boguspw");

        server.start();
        
        server.addModule(new SoftwareVersionModule());
        server.addModule(new EntityTimeModule());
        server.addModule(new XmppPingModule());
        server.addModule(new InBandRegistrationModule());
        server.addModule(new AdhocCommandsModule());
        final ServiceAdministrationModule serviceAdministrationModule = new ServiceAdministrationModule();
        // unless admin user account with a secure password is added, this will be not become effective
        serviceAdministrationModule.setAddAdminJIDs(Arrays.asList(adminJID)); 
        server.addModule(serviceAdministrationModule);
       }
}