2012-03-07 43 views
1

我有一個客戶端/服務器程序和小程序。我將在下面顯示代碼。你能否告訴我爲什麼以及程序在哪裏阻塞。該小程序似乎堅持,但是當我關閉了Cpp方面它完成執行。繼承人的代碼(我遺漏了進口和包括)。Java(或Cpp)阻塞某處

public class first extends JApplet { 

    PrintWriter toServer = null; 
    BufferedReader fromServer = null; 

    public void init() { 

     System.setProperty("javax.net.ssl.keyStore", "javakeys"); 
     System.setProperty("javax.net.ssl.keyStorePassword", "javakeys"); 

try { 

     SSLSocketFactory sslsocketfactory = (SSLSocketFactory) SSLSocketFactory.getDefault(); 
     SSLSocket sslsocket = (SSLSocket) sslsocketfactory.createSocket("localhost", 4000); 

     toServer = new PrintWriter(sslsocket.getOutputStream(), true); 

     InputStreamReader isr = new InputStreamReader(sslsocket.getInputStream()); 
     fromServer = new BufferedReader(isr); 

    } catch (Exception exception) { 
      exception.printStackTrace(); 
    } 

     toServer.println("Flystar".getBytes()); 

    } 

    public void paint(Graphics g) { 

     g.setColor(Color.red); 
     g.drawString("Welcome to Java!!", 50, 60); 
    } 


} 

這裏是柬埔寨人民黨...

int conn_new_server(int); 

__attribute__((constructor)) void construct_ssl() 
{ 
    SSL_load_error_strings(); 
    SSL_library_init(); 
    OpenSSL_add_all_algorithms(); 
} 

__attribute__((destructor)) void destruct_ssl() 
{ 
    ERR_free_strings(); 
    EVP_cleanup(); 
} 

int main() 
{ 
    int sockfd, client; 
    SSL_CTX *tlsctx; 
    SSL *ssl; 
    char recvit[256]; 

    printf("Status %d\n", RAND_status()); 
    tlsctx = SSL_CTX_new(TLSv1_server_method()); 
    SSL_CTX_set_options(tlsctx, SSL_OP_SINGLE_DH_USE); 
    SSL_CTX_use_certificate_file(tlsctx, "server.crt" , SSL_FILETYPE_PEM); 
    SSL_CTX_use_PrivateKey_file(tlsctx, "server.key", SSL_FILETYPE_PEM); 

    sockfd = conn_new_server(1337); 
    while (1) 
    { 
     client = accept(sockfd, NULL, NULL); 
     ssl = SSL_new(tlsctx); 
     SSL_set_fd(ssl, client); 
     SSL_accept(ssl); 

     cout << "connection detected!\n\r"; 

     while(1) { 

//   SSL_write(ssl, "hello", sizeof("hello")); 
      SSL_read(ssl, recvit, sizeof(recvit)); 
      cout << recvit << "\n\r"; 
     } 

//  SSL_write(ssl, "Hi :3\n\r", 6); 

     SSL_shutdown(ssl); 
     SSL_free(ssl); 
//  close(client); 
    } 
    SSL_CTX_free(tlsctx); 
// close(sockfd); 

    return 0; 
} 


int conn_new_server(int port) 
{ 
    WSADATA g_wsadata;  // Winsock data holder 
    int err; 
    StartSocketLib; 
    char *messageman = "Hello.\r\n"; 
    int recv_stat; 
    int connsock = 0; 
    char *testsendbuf = "This is very good!\r\n"; 
    list<int> socklist; 

    // BEGIN CODE BLOCK 2.3 - Create a Listening Socket on port 4000 
    int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 

    if(sock == -1) { 
     cout << "Socket creation error!" << endl; 
     return 0; 
    } 

    cout << "Socket created! Standing By." << endl; 

// create a sockaddr_in for binding, listening on port 4000 
    struct sockaddr_in socketaddress; 
    socklen_t sa_size = sizeof(struct sockaddr_in); 
    socketaddress.sin_family = AF_INET; 
    socketaddress.sin_port = htons(4000); 
    socketaddress.sin_addr.s_addr = htonl(INADDR_ANY); 
    memset(&(socketaddress.sin_zero), 0, 8); 

    // bind the socket 
    err = bind(sock, (struct sockaddr*)&socketaddress, sa_size); 

    // listen on the socket 
    err = listen(sock, 16); 
+1

我建議學習調試和配置文件代碼 – pyCthon 2012-03-07 05:38:47

+0

我會運行一個跟蹤,但JCreator有一個奇怪的方式來防止發生。我只是希望有人能指出阻塞的代碼段 – Confident 2012-03-07 05:42:53

+0

我不確定是什麼:'int conn_new_servpublic類首先擴展JApplet {'是,但它肯定看起來不像C++。 C++/CLI,也許? – 2012-03-07 05:43:07

回答

1

這裏的頭號問題是使用BufferedReader。在返回任何數據之前,它會嘗試填充內部緩衝區,並且如果沒有足夠的數據填充緩衝區,它將會阻塞。如果您使用BufferedReader只是爲了得到readLine()方法 - 這就是您在這裏做的 - 那麼當您構造它時,請傳遞第二個構造方法參數1,將一個字符的緩衝區大小設置爲基本關閉緩衝。這很可能會解決您的問題。

+0

嗯,那不太合適。感謝您的幫助。我得到了一個連接,但沒有數據來回傳遞 – Confident 2012-03-07 05:58:03