Horizon前台界面用于接受用户的输入或动作（action），然后将这些参数构造成RESTful API（https://developer.openstack.org/api-ref/compute/#create-server），并通过novaclient发出。Nova-API负责接受该RESTFul API请求，通过RPC调用将消息发送到RabbitMQ，Nova-Compute订阅了该消息，接受消息后随机调用Libvirt API，指挥KVM-QEMU去真正创建虚拟机。
对虚拟机的增删改查（前台）操作，发出的url请求都会被以下模块正则匹配到：
urlpatterns = patterns(
VIEW_MOD,
url(r'^$', views.IndexView.as_view(), name='index'),
url(r'^filter/(?P<vm_state>[^/]+)/$', views.IndexView.as_view(), name='filter'),
url(r'^create$', views.CreateInstanceView.as_view(), name='create')，
url(INSTANCES % 'update', views.UpdateView.as_view(), name='update'),
url(INSTANCES % 'rebuild', views.RebuildView.as_view(), name='rebuild'),
拿创建虚拟机的操作为例，有一系列的步骤（workflow）需要用户选择和操作，目的是拼接足够多的（创建虚拟机所必须的）参数：
class CreateInstanceView(workflows.WorkflowView):
workflow_class = project_workflows.CreateInstance
ajax_template_name = constants.INSTANCE_CREATE_TEMPLATE
success_url = reverse_lazy(constants.INSTANCES_INDEX_URL)
默认的workflow为：
class CreateInstance(workflows.Workflow):
slug = "create_instance"
name = _("Create Instance")
finalize_button_name = _("Create")
success_message = _('Launched %(count)s named "%(name)s".')
failure_message = _('Unable to launch %(count)s named "%(name)s".')
success_url = constants.INSTANCES_INDEX_URL
wizard = True
default_steps = (
SelectImages,
CustomFlavors,
SelectHost,
SelectNetworks,
SetInstanceDetails
)
@sensitive_variables('context')
def handle(self, request, context):
custom_script = context.get('script_data', '')
vcpus = int(context.get('vcpus', 0))
ram = int(context.get('ram', 0)) * 1024
disk = int(float(context.get('disk', 0)))
count = int(context.get('count', 0))
pool = context.get('pool', None)
try:
rets = api.nova.server_create(request,
context['name'],
image_id,
flavor_id,
None,
normalize_newlines(custom_script),
context['groups']，
meta=meta,
fips=fips)
workflow走完之后，就执行handle方法了，Horizon中有一个api python包，里面有nova,keystone,glance等的api,这些api都是对novaclient、keystoneclient、glanceclient等的封装。
@write_log("Create Server")
def server_create(request, name, image, flavor, key_name, user_data,
security_groups, block_device_mapping=None,
block_device_mapping_v2=None, nics=None,
availability_zone=None, instance_count=1, admin_pass=None,
disk_config=None, config_drive=None, meta=None,
host=None, fips=None):
return Server(novaclient(request).servers.create(
name, image, flavor, userdata=user_data,
security_groups=security_groups,
key_name=key_name, block_device_mapping=block_device_mapping,
block_device_mapping_v2=block_device_mapping_v2,
nics=nics, availability_zone=availability_zone,
min_count=instance_count, admin_pass=admin_pass,
disk_config=disk_config, config_drive=config_drive,
meta=meta, fips=fips), request)
novaclient的create方法获得需要的参数后，构造Restful api，并发送到Nova服务中，由nova-api负责接收。
在Nova组件中，nova/api/openstack/compute/servers.py（nova-api）的Controller负责接受请求并进行处理。
class Controller(wsgi.Controller):
def create(self, req, body):
try:
_get_inst_type = flavors.get_flavor_by_flavor_id
inst_type = _get_inst_type(flavor_id, ctxt=context,
read_deleted="no") (instances, resv_id) = self.compute_api.create(context,
inst_type,
image_uuid,
display_name=name,
display_description=name,
key_name=key_name,
metadata=server_dict.get('metadata', {}),
config_drive=config_drive,
block_device_mapping=block_device_mapping,
auto_disk_config=auto_disk_config,
scheduler_hints=scheduler_hints,
legacy_bdm=legacy_bdm,
check_server_group_quota=check_server_group_quota,
floating_ips=floating_ips) return self._add_location(robj) def _delete(self, context, req, instance_uuid):
instance = self._get_server(context, req, instance_uuid)
if CONF.reclaim_instance_interval:
try:
self.compute_api.soft_delete(context, instance)
except exception.InstanceInvalidState:
self.compute_api.delete(context, instance)
else:
self.compute_api.delete(context, instance)
之后，会调用Nova Compute的api模块的相应方法：
def _create_instance(self, context, instance_type,
image_href, kernel_id, ramdisk_id,
min_count, max_count,
display_name, display_description,
key_name, key_data, security_groups,
availability_zone, user_data, metadata,
injected_files, admin_password,
access_ip_v4, access_ip_v6,
requested_networks, config_drive,
block_device_mapping, auto_disk_config,
reservation_id=None, scheduler_hints=None,
legacy_bdm=True, shutdown_terminate=False,
check_server_group_quota=False,
floating_ips=None): self.compute_task_api.build_instances(context,
instances=instances, image=boot_meta,
filter_properties=filter_properties,
admin_password=admin_password,
injected_files=injected_files,
requested_networks=requested_networks,
security_groups=security_groups,
block_device_mapping=block_device_mapping,
legacy_bdm=False,
floating_ips=floating_ips) return (instances, reservation_id)
然后，会调用Nova-Conductor API中的ComputeTaskAPI相应方法：
def build_instances(self, context, instances, image, filter_properties,
admin_password, injected_files, requested_networks,
security_groups, block_device_mapping, legacy_bdm=True,
floating_ips=None):
self.conductor_compute_rpcapi.build_instances(context,
instances=instances, image=image,
filter_properties=filter_properties,
admin_password=admin_password, injected_files=injected_files,
requested_networks=requested_networks,
security_groups=security_groups,
block_device_mapping=block_device_mapping,
legacy_bdm=legacy_bdm,
floating_ips=floating_ips)
之后，又会调用Nova-Conductor模块RPCAPI中的相应方法：
def build_instances(self, context, instances, image, filter_properties,
admin_password, injected_files, requested_networks,
security_groups, block_device_mapping, legacy_bdm=True,
floating_ips=None):
image_p = jsonutils.to_primitive(image)
kw = {'instances': instances, 'image': image_p,
'filter_properties': filter_properties,
'admin_password': admin_password,
'injected_files': injected_files,
'requested_networks': requested_networks,
'security_groups': security_groups,
'floating_ips': floating_ips} version = '1.9'
if not self.client.can_send_version('1.9'):
version = '1.8'
kw['requested_networks'] = kw['requested_networks'].as_tuples()
if not self.client.can_send_version('1.7'):
version = '1.5'
kw.update({'block_device_mapping': block_device_mapping,
'legacy_bdm': legacy_bdm}) cctxt = self.client.prepare(version=version)
cctxt.cast(context, 'build_instances', **kw)
该方法会获取messaging模块中的RPCClient，然后通过cast的方式将消息发送到RabbitMQ中。
- RPC.call：发送请求到消息队列，等待返回最终结果。例如nova-compute调用nova-network服务分配网络，需要获得结果。
- RPC.cast：发送请求到消息队列，不需要等待最终返回的结果。例如nova-conductor服务调用nova-compute的build_and_run_instance。
最终，nova-compute订阅了RabbitMQ的消息，接受到创建虚拟机的消息。创建虚拟机的操作，由/nova/compute/manager.py ComputeManager中的_do_build_and_run_instance方法完成。
def _do_build_and_run_instance(self, context, instance, image,
request_spec, filter_properties, admin_password, injected_files,
requested_networks, security_groups, block_device_mapping,
node=None, limits=None,
floating_ip=None):
try:
self._build_and_run_instance(context, instance, image,
decoded_files, admin_password, requested_networks,
security_groups, block_device_mapping, node, limits,
filter_properties,
floating_ip=floating_ip)
def _build_and_run_instance(self, context, instance, image, injected_files,
admin_password, requested_networks, security_groups,
block_device_mapping, node, limits, filter_properties,
floating_ip=None):
try:
self.driver.spawn(context, instance, image,
injected_files, admin_password,
network_info=network_info,
block_device_info=block_device_info)
最后，调用Libvirt（Driver）的api接口，完成创建虚拟机的操作。/nova/virt/libvirt/driver spawn方法为创建本地镜像，获取虚机xml文件，创建domain：
def spawn(self, context, instance, image_meta, injected_files,
admin_password, network_info=None, block_device_info=None):
disk_info = blockinfo.get_disk_info(CONF.libvirt.virt_type,
instance,
block_device_info,
image_meta) self._create_image(context, instance,
disk_info['mapping'],
network_info=network_info,
block_device_info=block_device_info,
files=injected_files,
admin_pass=admin_password)
xml = self._get_guest_xml(context, instance, network_info,
disk_info, image_meta,
block_device_info=block_device_info,
write_to_disk=True)
self._create_domain_and_network(context, xml, instance, network_info,
block_device_info, disk_info=disk_info)
LOG.debug("Instance is running", instance=instance)