Java程序辅导

CSCE 515:
Computer Network 
Programming
------ Advanced Socket Programming
Wenyuan Xu
Department of Computer Science and Engineering
University of South Carolina
Ref: Dave Hollinger
Ref: UNP Chapter 7, 11, 30
Concurrent Server
Design Alternatives
CSCE515 – Computer Network Programming
Concurrent Server
Design Alternatives
One child process per client
Spawn one thread per client
Preforking multiple processes
Prethreaded Server
CSCE515 – Computer Network Programming
One child per client
• Traditional Unix server:
…TCP: after call to accept(), call fork().
…UDP: after recvfrom(), call fork().
…Each process needs only a few sockets.
…Small requests can be serviced in a small 
amount of time.
• Parent process needs to clean up after 
children!!!! (call wait() ).
CSCE515 – Computer Network Programming
One thread per client
• Almost like using fork - call pthread_create
instead. 
• Using threads makes it easier (less 
overhead) to have sibling processes share 
information.
• Sharing information must be done 
carefully (use pthread_mutex)
CSCE515 – Computer Network Programming
Example
main(int argc, char **argv)
{  pthread_t tid;
listenfd=socket(…)
Bind(listenfd…)
Listen(listenfd,LISTENQ);
For( ; ;) {
connfd = Accept(listenfd, …);
Pthread_creat(&tid, NULL, &doit, (void *)connfd);
}
}
static void doit (void *arg)
{
…
Close( (int) arg);
return NULL;
}
main(int argc, char **argv)
{ listenfd=socket(…)
Bind(listenfd…)
Listen(listenfd,LISTENQ);
Signal(SIGGHLD, sig_chld);
Signal(SIGINT,sig_int);
For( ; ;) {
connfd = Accept(listenfd, …);
if ( (pid = Fork())==0) {
Close(listendf);
doit(connfd);
Close(connfd);
exit(0);
}
}
Close(connfd); 
}
Process version
Thread version
CSCE515 – Computer Network Programming
Prefork()’d Server
• Creating a new process for each client is 
expensive.
• We can create a bunch of processes, each 
of which can take care of a client.
• Each child process is an iterative server.
CSCE515 – Computer Network Programming
Prefork()’d TCP Server
• Initial process creates socket and binds to 
well known address. 
• Process now calls fork() a bunch of 
times.
• All children call accept().
• The next incoming connection will be 
handed to one child.
CSCE515 – Computer Network Programming
Example
main(int argc, char **argv)
{ listenfd=socket(…)
Bind(listenfd…)
Listen(listenfd,LISTENQ);
Signal(SIGGHLD, sig_chld);
Signal(SIGINT,sig_int);
for(i=0;i
CSCE515 – Computer Network Programming
int getsockopt( int sockfd,
int level,
int optname,
void *opval,
socklen_t *optlen);
level specifies whether the option is a 
general option or a protocol specific 
option (what level of code should 
interpret the option).
getsockopt()
CSCE515 – Computer Network Programming
Socket and IP-layer socket options
intYYYTCP_NODELAY
intYYTCP_MAXSEGIPPROTO_TCP
intYYYIP_TOS
IntYYYIP_HDRINCLIPPRORO_IP
intYYYSO_KEEPALIVE
lingerYYSO_LINGER
intNYSO_ERRORSOL_SOCKET
Data 
type
FlagSetGetOptnameLevel
CSCE515 – Computer Network Programming
int setsockopt( int sockfd,
int level,
int optname,
const void *opval,
socklen_t optlen);
setsockopt()
CSCE515 – Computer Network Programming
Example: SO_LINGER
„ Specifies how the close function operates for a 
connection-oriented protocol.
#include 
int close(int socketfd);
„ Decrease the reference count for the descriptor
„ If the reference count is 0:
… send any data that is already queued to be sent to the 
other end
… Normal TCP Connection termination sequence
CSCE515 – Computer Network Programming
SO_LINGER
Value is of type:
struct linger {
int l_onoff; /* 0 = off */
int l_linger;  /* time in seconds */
};
„ Used to control whether and how long a 
call to close will wait for pending ACKS. 
„ connection-oriented sockets only. 
CSCE515 – Computer Network Programming
SO_LINGER usage
„ By default, calling close() on a TCP 
socket will return immediately.
„ The closing process has no way of 
knowing whether or not the peer 
received all data.
„ Setting SO_LINGER means the closing 
process can determine that the peer 
machine has received the data (but not 
that the data has been read() !).
CSCE515 – Computer Network Programming
SO_LINGER
„ l_onoff = 1 & l_linger =0
… TCP aborts the connections when it is closed
„ l_onoff = 1 & l_linger != 0
„ close return if either:
…all the data is sent and acked
… the linger time has expired.
…Check an example
CSCE515 – Computer Network Programming
shutdown
„ Starts TCP’s normal connection termination sequence, 
regardless of the reference count
#include 
int shutdown(int sockfd, int howto);
„ howto
… SHUT_RD: the read half of the connection is closed
… SHUT_WR: the write half of the connection is closed
… SHUT_RDWR: the read half and the write half of the 
connection are both closed
CSCE515 – Computer Network Programming
shutdown() vs SO_LINGER
Summary
„ close returns immediately without waiting 
at all
„ close lingers until the ACK of our FIN is 
received
„ shutdown followed by a read waits until 
we receive the peer’s FIN
CSCE515 – Computer Network Programming
General Options 
„ Protocol independent options.
„ Handled by the generic socket system 
code.
„ Some general options are supported only 
by specific types of sockets 
(SOCK_DGRAM, SOCK_STREAM).
CSCE515 – Computer Network Programming
Some Generic Options
SO_BROADCAST
SO_DONTROUTE
SO_ERROR
SO_KEEPALIVE
SO_LINGER
SO_RCVBUF,SO_SNDBUF
SO_REUSEADDR
CSCE515 – Computer Network Programming
SO_BROADCAST
„ Boolean option: enables/disables 
sending of broadcast messages.
„ Underlying DL layer must support 
broadcasting!
„ Applies only to SOCK_DGRAM sockets.
„ Prevents applications from inadvertently 
sending broadcasts (OS looks for this 
flag when broadcast address is 
specified).
CSCE515 – Computer Network Programming
SO_DONTROUTE
„ Boolean option: enables bypassing of 
normal routing.
„ Used by routing daemons.
CSCE515 – Computer Network Programming
SO_ERROR
„ Integer value option. 
„ The value is an error indicator value  
(similar to errno).
„ Readable (get’able) only!
„ Reading (by calling getsockopt()) 
clears any pending error.
CSCE515 – Computer Network Programming
SO_KEEPALIVE
„ Boolean option: enabled means that 
STREAM sockets should send a probe to 
peer if no data flow for a “long time”.
„ Used by TCP - allows a process to determine 
whether peer process/host has crashed. 
„ Consider what would happen to an open 
telnet connection without keepalive.
„ Detect half-open connections and terminate 
them
CSCE515 – Computer Network Programming
SO_RCVBUF
SO_SNDBUF
„ Integer values options - change the 
receive and send buffer sizes.
„ Can be used with STREAM and DGRAM 
sockets.
„ With TCP, When should this option be 
set?
… this option effects the window size used for 
flow control - must be established before 
connection is made.
CSCE515 – Computer Network Programming
SO_REUSEADDR
„ Boolean option: enables binding to an 
address (port) that is already in use.
„ By default, bind fails when the listening 
server is trying to bind a port that is part 
of an existing connection.
„ How?
CSCE515 – Computer Network Programming
SO_REUSEADDR
„ A listening server is started.
„ A connection request arrives and a child process 
is spawned to handle that client.
„ The listening server terminates, but the child 
continues to service the client on the existing 
connections.
„ The listening server is restarted. 
CSCE515 – Computer Network Programming
SO_REUSEADDR
„ Used by servers that are transient - allows 
binding a passive socket to a port currently 
in use (with active sockets) by other 
processes. 
„ Can be used to establish separate servers 
for the same service on different interfaces 
(or different IP addresses on the same 
interface).
CSCE515 – Computer Network Programming
IP Options (IPv4): IPPROTO_IP
„ IP_HDRINCL: used on raw IP sockets 
when we want to build the IP header 
ourselves.
„ IP_TOS: allows us to set the “Type-of-
service” field in an IP header.
„ IP_TTL: allows us to set the “Time-to-live”
field in an IP header.
CSCE515 – Computer Network Programming
TCP socket options 
(IPPROTO_TCP)
„ TCP_MAXSEG: set the maximum 
segment size sent by a TCP socket.
CSCE515 – Computer Network Programming
another TCP socket option
„ TCP_NODELAY: can disable TCP’s Nagle 
algorithm that delays sending small 
packets if there is unACK’d data pending.
„ TCP_NODELAY also disables delayed 
ACKS (TCP ACKs are cumulative).
CSCE515 – Computer Network Programming
„ This was just an overview
… there are many details associated with the 
options described.
…There are many options that haven’t been 
described.
…Our text is one of the best sources of 
information about socket options.
„ Let’s see an example: 
getsockopt(fd, IPPROTO_TCP, TCP_MAXSEG, 
&val, &len);
Socket Options Summary
Posix name/address 
conversion
CSCE515 – Computer Network Programming
Posix Name/Adress Conversion
„ We've seen gethostbyname and 
gethostbyaddr - these are protocol 
dependent.
…Not part of sockets library.
„ Posix includes protocol independent
functions:
getaddrinfo() getnameinfo()
CSCE515 – Computer Network Programming
gethostbyname
struct hostent *gethostbyname( 
const char *hostname);
struct hostent is defined in netdb.h:
#include 
CSCE515 – Computer Network Programming
struct hostent
h_name
h_aliases
h_addrtype
h_length
h_addr_list
Official Name
alias 1
alias 2
null
IP address 1
IP address 2
null
struct hostent {
char *h_name;
char **h_aliases; 
int h_addrtype; 
//AF_INET
int h_length;//4
char **h_addr_list;
};
CSCE515 – Computer Network Programming
getaddrinfo, getnameinfo
„ These functions provide name/address 
conversions as part of the sockets 
library.
„ In the future it will be important to write 
code that can run on many protocols 
(IPV4, IPV6). 
CSCE515 – Computer Network Programming
Why getaddrinfo()?
„ Puts protocol dependence in library 
(where it belongs).
…Same code can be used for many protocols 
(IPV4, IPV6)
… re-entrant function - gethostbyname is not!
„ Important to threaded applications.
CSCE515 – Computer Network Programming
getaddrinfo()
int getaddrinfo( 
const char *hostname,
const char *service,
const struct addrinfo* hints,
struct addrinfo **result);
getaddrinfo() replaces both 
gethostbyname() and getservbyname()
CSCE515 – Computer Network Programming
getaddrinfo() parameters
hostname is a hostname or an address string 
(dotted decimal string for IP).
service is a service name or a decimal port 
number string.
CSCE515 – Computer Network Programming
struct addrinfo
struct addrinfo {
int ai_flags;
int ai_family;
int ai_socktype;
int ai_protocol;
size_t ai_addrlen;
char *canonname;
struct sockaddr *ai_addr;
struct addrinfo *ai_next;
};
Lin
ked
 lis
t!
CSCE515 – Computer Network Programming
getaddrinfo() hints
hints is an addrinfo * (can be NULL) that can 
contain:
… ai_flags (AI_PASSIVE , AI_CANONNAME ) 
… ai_family (AF_XXX )
… ai_socktype (SOCK_XXX )
… ai_protocol (IPPROTO_TCP, etc.)
CSCE515 – Computer Network Programming
getaddrinfo() result
result is  returned with the address of a pointer 
to an  addrinfo structure that is the head of a 
linked list.
It is possible to get multiple structures:
…multiple addresses associated with the hostname.
… The service is provided for multiple socket types.
CSCE515 – Computer Network Programming
addrinfo usage
ai_flags
ai_family
ai_socktype
ai_protocol
ai_addrlen
ai_canonname
ai_addr
ai_next
ai_flags
ai_family
ai_socktype
ai_protocol
ai_addrlen
ai_canonname
ai_addr
ai_next
Used in call to socket()
Used in call to bind(), connect()
or sendto()
ai_flags
ai_family
ai_socktype
ai_protocol
ai_addrlen
ai_canonname
ai_addr
ai_next
ai_flags
ai_family
ai_socktype
ai_protocol
ai_addrlen
ai_canonname
ai_addr
ai_next
int bind( int sockfd, const struct
sockaddr *myaddr, int addrlen);
int socket(int family,int type,int proto);
CSCE515 – Computer Network Programming
getnameinfo()
int getnameinfo( 
const struct sockaddr *sockaddr,
socklen_t addrlen
char *host,
size_t hostlen,
char *serv,
size_t servlen,
int flags);
getnameinfo() looks up a hostname and a 
service name given a sockaddr
CSCE515 – Computer Network Programming
Assignment & Next time
„ Reading:
…UNP 7.1-7.6, 11.3, 11.4, 11.6, 11.17, 30
„ Next Lecture:
…Daemons and inetd